C#使用Socket实现本地多人聊天室

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

【脚本一：Server端】

使用本机地址：

完整代码

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

usingSystem.Threading;

namespaceConsoleApp1

publicclassServer

{

SocketmySocket=null;

DictionaryIPAddress,SocketcliDic=newDictionaryIPAddress,Socket

publicvoidConnect(intport)

{

stringIP="";

//IPAddressIPAddress=IPAddress.Parse("");

IPAddressaddress=IPAddress.Any;

//创建IP终结点，把IP地址与端口绑定到网络终结点上

IPEndPointendPoint=newIPEndPoint(address,port);

//创建客户端套接字

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

///监听套接字终结点

mySocket.Bind(endPoint);

//服务端可接收客户端连接数量为无限个

mySocket.Listen(0);

//开启线程监听客户端

ThreadmyThread=newThread(Listen_Con);

myThread.Start();

Console.WriteLine("开始监听...");

}

///summary

///接收连接的客户端并存储客户端的信息

////summary

///paramname="obj"/param

publicvoidListen_Con(Objectobj)

{

SocketcliSocket=null;

//持续监听客户端的请求

while(true)

{

try

{

cliSocket=mySocket.Accept();

}

catch(Exceptione)

{

Console.WriteLine(e.Message);

}

stringcliEndPoint=cliSocket.RemoteEndPoint.ToString();

IPAddresscliAddress=(cliSocket.RemoteEndPointasIPEndPoint).Address;

intcliPort=(cliSocket.RemoteEndPointasIPEndPoint).Port;

cliDic.Add(cliAddress,cliSocket);

stringMsgStr="[客户端结点:"+cliEndPoint+"\n+客户端IP："+cliAddress.ToString()+"\n客户端端口:"+

cliPort.ToString()+"\n已连接]";

byte[]MsgBytes=Encoding.UTF8.GetBytes(MsgStr);

cliSocket.Send(MsgBytes);

Threadrec_Cli=newThread(Receive_Con);

rec_Cli.Start(cliSocket);

Threadsed_Cli=newThread(SendToCli);

sed_Cli.Start(cliSocket);

}

}

///summary

///接收已连接的客户端发送的消息

////summary

///paramname="socket"/param

publicvoidReceive_Con(Objectsocket)

{

Socketclient=socketasSocket;

while(true)

{

//创建大小为1024*1024的内存缓冲区（1M）

byte[]recBytes=newbyte[1024*1024];

//尝试把接收的字节存储到缓冲区

try

{

intlength=client.Receive(recBytes);

//把机器接收的字节数组转换为string

stringrecMsg=Encoding.UTF8.GetString(recBytes,0,length);

//将服务器接收到的信息转发到所有已连接的客户端

if(cliDic.Count0)

{

foreach(varsocincliDic)

{

soc.Value.Send(Encoding.UTF8.GetBytes("["+soc.Value.RemoteEndPoint+"]:"+recMsg));

}

}

Console.WriteLine("["+client.RemoteEndPoint+"]:"+recMsg);

}

catch(Exception)

{

cliDic.Remove((client.RemoteEndPointasIPEndPoint).Address);

//客户端断开的异常

Console.WriteLine("[客户端"+(client.RemoteEndPointasIPEndPoint).Address+"已断开]");

Console.WriteLine("[客户端终结点："+client.RemoteEndPoint+"]");

//断开套接字

client.Close();

break;

}

}

}

publicvoidSendToCli(objectobj)

{

SocketcurCliSoc=objasSocket;

while(true)

{

byte[]ByteToAll=newbyte[1024*1024];

try

{

stringMsgToAll=Console.ReadLine();

ByteToAll=Encoding.UTF8.GetBytes("[服务端]:"+MsgToAll);

curCliSoc.Send(ByteToAll);

}

catch(Exception)

{

Console.WriteLine("ERROR:"+curCliSoc.RemoteEndPoint+"已与服务端断开！");

curCliSoc.Close();

if(cliDic.ContainsKey((curCliSoc.RemoteEndPointasIPEndPoint).Address))

{

cliDic.Remove((curCliSoc.RemoteEndPointasIPEndPoint).Address);

}

}

}

}

}

publicclassServerMain

{

staticvoidMain(string[]args)

{

Servers1=newServer();

s1.Connect(8800);

}

}

}

Server端运行结果：

【脚本二：Client端】

完整代码

usingSystem;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

usingSystem.Threading;

namespaceConsoleApp1

publicclassClient

{

stringSerIP="";

SocketmyClient=null;

ThreadConnectThread=null;

IPAddressSerAdd;

IPEndPointSerEP;

publicvoidConnect_To_Ser(intport)

{

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

SerAdd=IPAddress.Parse(SerIP);

SerEP=newIPEndPoint(SerAdd,port);

while(true)

{

try

{

myClient.Connect(SerEP);

break;

}

catch

{

Console.WriteLine("无法连接到服务端，请重试...");

}

}

ConnectThread=newThread(Receive_Ser);

ConnectThread.Start();

}

publicvoidReceive_Ser()

{

while(true)

{

byte[]SerBytes=newbyte[1024*1024];

try

{

intlength=myClient.Receive(SerBytes);

stringMsg=Encoding.UTF8.GetString(SerBytes,0,length);

Console.WriteLine(Msg);

}

catch(Exception)

{

Console.WriteLine("已与服务端断开连接...");

break;

}

}

}

publicvoidSendToSer()

{

while(true)

{