C#實(shí)現(xiàn)簡易多人聊天室

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

只有一個群聊的功能

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ù)責(zé)接收服務(wù)端發(fā)來的數(shù)據(jù)消息的線程

ThreadthreadClient=null;

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

SocketsocketClient=null;

publicClient()

{

InitializeComponent();

//關(guān)閉對文本框跨線程操作的檢查

TextBox.CheckForIllegalCrossThreadCalls=false;

}

privatevoidstart_Click(objectsender,EventArgse)

{

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

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

//創(chuàng)建包含IP和端口的網(wǎng)絡(luò)節(jié)點(diǎn)對象

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

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

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

try

{

//客戶端連接到服務(wù)器

socketClient.Connect(endPoint);

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

}

catch(SocketExceptionex)

{

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

}

catch(Exceptionex)

{

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

}

threadClient=newThread(ReceiveMsg);

threadClient.IsBackground=true;

threadClient.Start();

}

privatevoidbtnSend_Click(objectsender,EventArgse)

{

stringstrMsg=txtMsg.Text.Trim();

//將字符串轉(zhuǎn)成方便網(wǎng)絡(luò)傳送的二進(jìn)制數(shù)組

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

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

arrMsgSend[0]=0;//設(shè)置標(biāo)識位，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ù)據(jù)存入arrMsgRev,并返回真正接收到數(shù)據(jù)的長度

intlength=-1;

try

{

length=socketClient.Receive(arrMsgRev);

}

catch(SocketExceptionex)

{

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

break;

}

catch(Exceptionex)

{

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

break;

}

//此時是將數(shù)組的所有元素（每個字節(jié)）都轉(zhuǎn)成字符串，而真正接收到只有服務(wù)端發(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ù)責(zé)接收服務(wù)端發(fā)來的數(shù)據(jù)消息的線程

ThreadthreadClient=null;

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

SocketsocketClient=null;

publicClient()

{

InitializeComponent();

//關(guān)閉對文本框跨線程操作的檢查

TextBox.CheckForIllegalCrossThreadCalls=false;

}

privatevoidstart_Click(objectsender,EventArgse)

{

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

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

//創(chuàng)建包含IP和端口的網(wǎng)絡(luò)節(jié)點(diǎn)對象

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

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

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

try

{

//客戶端連接到服務(wù)器

socketClient.Connect(endPoint);

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

}

catch(SocketExceptionex)

{

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

}

catch(Exceptionex)

{

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

}

threadClient=newThread(ReceiveMsg);

threadClient.IsBackground=true;

threadClient.Start();

}

privatevoidbtnSend_Click(objectsender,EventArgse)

{

stringstrMsg=txtMsg.Text.Trim();

//將字符串轉(zhuǎn)成方便網(wǎng)絡(luò)傳送的二進(jìn)制數(shù)組

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

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

arrMsgSend[0]=0;//設(shè)置標(biāo)識位，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ù)據(jù)存入arrMsgRev,并返回真正接收到數(shù)據(jù)的長度

intlength=-1;

try

{