第C#實現(xiàn)簡易多人聊天室本文實例為大家分享了C#實現(xiàn)簡易多人聊天室的具體代碼，供大家參考，具體內容如下

只有一個群聊的功能

usingSystem;

usingSystem.Collections.Generic;

usingSystem.ComponentModel;

usingSystem.Data;

usingSystem.Drawing;

usingSystem.Linq;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

usingSystem.Threading;

usingSystem.Threading.Tasks;

usingSystem.Windows.Forms;

namespaceFinalChatRoomClient

publicpartialclassClient:Form

{

//客戶端負責接收服務端發(fā)來的數(shù)據消息的線程

ThreadthreadClient=null;

//創(chuàng)建客戶端套接字，負責連接服務器

SocketsocketClient=null;

publicClient()

{

InitializeComponent();

//關閉對文本框跨線程操作的檢查

TextBox.CheckForIllegalCrossThreadCalls=false;

}

privatevoidstart_Click(objectsender,EventArgse)

{

//獲得文本框中的IP地址對象

IPAddressaddress=IPAddress.Parse(txtIp.Text.Trim());

//創(chuàng)建包含IP和端口的網絡節(jié)點對象

IPEndPointendPoint=newIPEndPoint(address,int.Parse(txtPort.Text.Trim()));

//創(chuàng)建客戶端套接字，負責連接服務器

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

try

{

//客戶端連接到服務器

socketClient.Connect(endPoint);

ShowMsg("客戶端連接服務器成功");

}

catch(SocketExceptionex)

{

ShowMsg("客戶端連接服務器發(fā)生異常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客戶端連接服務器發(fā)生異常："+ex.Message);

}

threadClient=newThread(ReceiveMsg);

threadClient.IsBackground=true;

threadClient.Start();

}

privatevoidbtnSend_Click(objectsender,EventArgse)

{

stringstrMsg=txtMsg.Text.Trim();

//將字符串轉成方便網絡傳送的二進制數(shù)組

byte[]arrMsg=Encoding.UTF8.GetBytes(strMsg);

byte[]arrMsgSend=newbyte[arrMsg.Length+1];

arrMsgSend[0]=0;//設置標識位，0代表發(fā)送的是文字

Buffer.BlockCopy(arrMsg,0,arrMsgSend,1,arrMsg.Length);

try

{

socketClient.Send(arrMsgSend);

//清空發(fā)送消息文本框中的消息

this.txtMsg.Text="";

}

catch(SocketExceptionex)

{

ShowMsg("客戶端發(fā)送消息時發(fā)生異常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客戶端發(fā)送消息時發(fā)生異常："+ex.Message);

}

}

privatevoidShowMsg(stringmsg)

{

txtRecord.AppendText(msg+"\r\n");

}

privatevoidReceiveMsg()

{

while(true)

{

//定義一個接收消息用的字節(jié)數(shù)組緩沖區(qū)（2M大小）

byte[]arrMsgRev=newbyte[1024*1024*2];

//將接收到的數(shù)據存入arrMsgRev,并返回真正接收到數(shù)據的長度

intlength=-1;

try

{

length=socketClient.Receive(arrMsgRev);

}

catch(SocketExceptionex)

{

ShowMsg("客戶端接收消息時發(fā)生異常："+ex.Message);

break;

}

catch(Exceptionex)

{

MessageBox.Show("客戶端接收消息時發(fā)生異常："+ex.Message);

break;

}

//此時是將數(shù)組的所有元素（每個字節(jié)）都轉成字符串，而真正接收到只有服務端發(fā)來的幾個字符

stringstrMsgReceive=Encoding.UTF8.GetString(arrMsgRev,0,length);

Console.WriteLine(strMsgReceive);

ShowMsg(strMsgReceive);

}

}

}

}

usingSystem;

usingSystem.Collections.Generic;

usingSystem.ComponentModel;

usingSystem.Data;

usingSystem.Drawing;

usingSystem.Linq;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Text;

usingSystem.Threading;

usingSystem.Threading.Tasks;

usingSystem.Windows.Forms;

namespaceFinalChatRoomClient

publicpartialclassClient:Form

{

//客戶端負責接收服務端發(fā)來的數(shù)據消息的線程

ThreadthreadClient=null;

//創(chuàng)建客戶端套接字，負責連接服務器

SocketsocketClient=null;

publicClient()

{

InitializeComponent();

//關閉對文本框跨線程操作的檢查

TextBox.CheckForIllegalCrossThreadCalls=false;

}

privatevoidstart_Click(objectsender,EventArgse)

{

//獲得文本框中的IP地址對象

IPAddressaddress=IPAddress.Parse(txtIp.Text.Trim());

//創(chuàng)建包含IP和端口的網絡節(jié)點對象

IPEndPointendPoint=newIPEndPoint(address,int.Parse(txtPort.Text.Trim()));

//創(chuàng)建客戶端套接字，負責連接服務器

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

try

{

//客戶端連接到服務器

socketClient.Connect(endPoint);

ShowMsg("客戶端連接服務器成功");

}

catch(SocketExceptionex)

{

ShowMsg("客戶端連接服務器發(fā)生異常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客戶端連接服務器發(fā)生異常："+ex.Message);

}

threadClient=newThread(ReceiveMsg);

threadClient.IsBackground=true;

threadClient.Start();

}

privatevoidbtnSend_Click(objectsender,EventArgse)

{

stringstrMsg=txtMsg.Text.Trim();

//將字符串轉成方便網絡傳送的二進制數(shù)組

byte[]arrMsg=Encoding.UTF8.GetBytes(strMsg);

byte[]arrMsgSend=newbyte[arrMsg.Length+1];

arrMsgSend[0]=0;//設置標識位，0代表發(fā)送的是文字

Buffer.BlockCopy(arrMsg,0,arrMsgSend,1,arrMsg.Length);

try

{

socketClient.Send(arrMsgSend);

//清空發(fā)送消息文本框中的消息

this.txtMsg.Text="";

}

catch(SocketExceptionex)

{

ShowMsg("客戶端發(fā)送消息時發(fā)生異常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客戶端發(fā)送消息時發(fā)生異常："+ex.Message);

}

}

privatevoidShowMsg(stringmsg)

{

txtRecord.AppendText(msg+"\r\n");

}

privatevoidReceiveMsg()

{

while(true)

{

//定義一個接收消息用的字節(jié)數(shù)組緩沖區(qū)（2M大?。?/p>

byte[]arrMsgRev=newbyte[1024*1024*2];

//將接收到的數(shù)據存入arrMsgRev,并返回真正接收到數(shù)據的長度

intlength=-1;

try

{