第C#使用Socket實(shí)現(xiàn)本地多人聊天室本文實(shí)例為大家分享了C#使用Socket實(shí)現(xiàn)本地多人聊天室的具體代碼，供大家參考，具體內(nèi)容如下

【腳本一：Server端】

使用本機(jī)地址：

完整代碼

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;

//創(chuàng)建IP終結(jié)點(diǎn)，把IP地址與端口綁定到網(wǎng)絡(luò)終結(jié)點(diǎn)上

IPEndPointendPoint=newIPEndPoint(address,port);

//創(chuàng)建客戶端套接字

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

///監(jiān)聽(tīng)套接字終結(jié)點(diǎn)

mySocket.Bind(endPoint);

//服務(wù)端可接收客戶端連接數(shù)量為無(wú)限個(gè)

mySocket.Listen(0);

//開(kāi)啟線程監(jiān)聽(tīng)客戶端

ThreadmyThread=newThread(Listen_Con);

myThread.Start();

Console.WriteLine("開(kāi)始監(jiān)聽(tīng)...");

}

///summary

///接收連接的客戶端并存儲(chǔ)客戶端的信息

////summary

///paramname="obj"/param

publicvoidListen_Con(Objectobj)

{

SocketcliSocket=null;

//持續(xù)監(jiān)聽(tīng)客戶端的請(qǐng)求

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="[客戶端結(jié)點(diǎn):"+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

///接收已連接的客戶端發(fā)送的消息

////summary

///paramname="socket"/param

publicvoidReceive_Con(Objectsocket)

{

Socketclient=socketasSocket;

while(true)

{

//創(chuàng)建大小為1024*1024的內(nèi)存緩沖區(qū)（1M）

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

//嘗試把接收的字節(jié)存儲(chǔ)到緩沖區(qū)

try

{

intlength=client.Receive(recBytes);

//把機(jī)器接收的字節(jié)數(shù)組轉(zhuǎn)換為string

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

//將服務(wù)器接收到的信息轉(zhuǎn)發(fā)到所有已連接的客戶端

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);

//客戶端斷開(kāi)的異常

Console.WriteLine("[客戶端"+(client.RemoteEndPointasIPEndPoint).Address+"已斷開(kāi)]");

Console.WriteLine("[客戶端終結(jié)點(diǎn)："+client.RemoteEndPoint+"]");

//斷開(kāi)套接字

client.Close();

break;

}

}

}

publicvoidSendToCli(objectobj)

{

SocketcurCliSoc=objasSocket;

while(true)

{

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

try

{

stringMsgToAll=Console.ReadLine();

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

curCliSoc.Send(ByteToAll);

}

catch(Exception)

{

Console.WriteLine("ERROR:"+curCliSoc.RemoteEndPoint+"已與服務(wù)端斷開(kāi)！");

curCliSoc.Close();

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

{

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

}

}

}

}

}

publicclassServerMain

{

staticvoidMain(string[]args)

{

Servers1=newServer();

s1.Connect(8800);

}

}

}

Server端運(yùn)行結(jié)果：

【腳本二：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("無(wú)法連接到服務(wù)端，請(qǐng)重試...");

}

}

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("已與服務(wù)端斷開(kāi)連接...");

break;

}

}

}

publicvoidSendToSer()

{

while(true)

{