C#基于Socket实现多人聊天功能

第C#基于Socket实现多人聊天功能本文实例为大家分享了C#基于Socket实现多人聊天功能的具体代码，供大家参考，具体内容如下

服务器负责接受所有客户端发来的消息，和将接受到的问题群发到其他用户。

代码：

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

usingSystem.Threading;

namespaceChatRoomService

classService

{

SocketsocketSevice;

ListSocketuserList;//用户组

publicService()

{

socketSevice=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

userList=newListSocket

}

publicvoid

Start()

{

socketSevice.Bind(newIPEndPoint(IPAddress.Any,5566));

socketSevice.Listen(10);

Console.WriteLine("服务器启动成功");

//开启接受连接,用多线程

ThreadaccThread=newThread(Accept);

accThread.IsBackground=true;

accThread.Start();

}

privatevoidAccept()

{

//接受连接

SocketclientSocket=socketSevice.Accept();

userList.Add(clientSocket);

//打印已经连接IP地址

Console.WriteLine(IPToAddress(clientSocket)+"连接进来了");

//

ThreadRecvThread=newThread(ReceMessage);

RecvThread.IsBackground=true;

RecvThread.Start(clientSocket);

Accept();//递归

}

//接收客户端信息

privatevoidReceMessage(Objectobj)

{

Socketclient=objasSocket;

byte[]strByte=newbyte[1024*1024];//设定接受字符的长度

stringstr="";

try

{

intlen=client.Receive(strByte);//接受用户发送的内容

str=Encoding.Default.GetString(strByte,0,len);

Broadcast(str,client);//广播给用户

Console.WriteLine(str);

}

catch(Exceptione)

{

Console.WriteLine(IPToAddress(client)+"退出");

userList.Remove(client);

Thread.CurrentThread.Abort();//退出时掐死线程，不然递归反弹

}

ReceMessage(client);//使用递归

}

///summary

///广播信息

////summary

///paramname="useStr"传入收到的传输的内容/param

///paramname="obj"传送信息的客户/param

privatevoidBroadcast(stringuserStr,objectobj)

{

SocketclientSend=objasSocket;//当前发送信息的客户

foreach(SocketclientinuserList)

{

if(client!=clientSend)//将信息广播给其他用户

{

client.Send(Encoding.Default.GetBytes(IPToAddress(clientSend)+":"+userStr));

}

}

}

//转换出连来客户的IP地址

privatestringIPToAddress(Socketsoket)

{

return(soket.RemoteEndPointasIPEndPoint).Address.ToString();

}

}

}

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceChatRoomService

classProgram

{

staticvoidMain(string[]args)

{

Servicess=newService();

ss.Start();

Console.ReadLine();

}

}

}

客户端的功能开始十分简单，可以发送信息给服务器。也可以接收服务器转发过来其他客户端的信息。

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

usingSystem.Threading;

usingSystem.Threading.Tasks;

namespaceChatRoom

classClientRoom

{

SocketclientSocket;

publicClientRoom()

{

clientSocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);//初始化服务器

}

///summary

///连接服务器

////summary

///paramname="Ip"/param

///paramname="port"/param

publicvoidConnected(stringIp,intport)

{

clientSocket.Connect(Ip,port);

Console.WriteLine("连接成功");

//ClientSocket.Bind(newIPEndPoint());

ThreadRecvThread=newThread(RecvMessage);

RecvThread.IsBackground=true;

RecvThread.Start();

}

publicvoidSend(Stringstr)

{

clientSocket.Send(Encoding.Default.GetBytes(str));

}

///summary

///接受信息

////summary

privatevoidRecvMessage()

{

try

{

byte[]strByte=newbyte[500*1024];

intlen=clientSocket.Receive(strByte);

Console.WriteLine(Encoding.Default.GetString(strByte,0,len));

}

catch(Exceptione)//服务器关闭

{

Console.WriteLine("服务器关闭");

Thread.CurrentThread.Abort();//关闭时切断进程

}

RecvMessage();

}

}

}

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceChatRoom

classProgram

{

staticvoidMain(string[]args)

{

ClientRoomclient=newClientRoom();

client.Connected("",5566);

stringstr=Console.ReadLine();