C#实现简易多人聊天室

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

只有一个群聊的功能

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

{

//客户端负责接收服务端发来的数据消息的线程

ThreadthreadClient=null;

//创建客户端套接字，负责连接服务器

SocketsocketClient=null;

publicClient()

{

InitializeComponent();

//关闭对文本框跨线程操作的检查

TextBox.CheckForIllegalCrossThreadCalls=false;

}

privatevoidstart_Click(objectsender,EventArgse)

{

//获得文本框中的IP地址对象

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

//创建包含IP和端口的网络节点对象

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

//创建客户端套接字，负责连接服务器

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

try

{

//客户端连接到服务器

socketClient.Connect(endPoint);

ShowMsg("客户端连接服务器成功");

}

catch(SocketExceptionex)

{

ShowMsg("客户端连接服务器发生异常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客户端连接服务器发生异常："+ex.Message);

}

threadClient=newThread(ReceiveMsg);

threadClient.IsBackground=true;

threadClient.Start();

}

privatevoidbtnSend_Click(objectsender,EventArgse)

{

stringstrMsg=txtMsg.Text.Trim();

//将字符串转成方便网络传送的二进制数组

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

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

arrMsgSend[0]=0;//设置标识位，0代表发送的是文字

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

try

{

socketClient.Send(arrMsgSend);

//清空发送消息文本框中的消息

this.txtMsg.Text="";

}

catch(SocketExceptionex)

{

ShowMsg("客户端发送消息时发生异常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客户端发送消息时发生异常："+ex.Message);

}

}

privatevoidShowMsg(stringmsg)

{

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

}

privatevoidReceiveMsg()

{

while(true)

{

//定义一个接收消息用的字节数组缓冲区（2M大小）

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

//将接收到的数据存入arrMsgRev,并返回真正接收到数据的长度

intlength=-1;

try

{

length=socketClient.Receive(arrMsgRev);

}

catch(SocketExceptionex)

{

ShowMsg("客户端接收消息时发生异常："+ex.Message);

break;

}

catch(Exceptionex)

{

MessageBox.Show("客户端接收消息时发生异常："+ex.Message);

break;

}

//此时是将数组的所有元素（每个字节）都转成字符串，而真正接收到只有服务端发来的几个字符

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

{

//客户端负责接收服务端发来的数据消息的线程

ThreadthreadClient=null;

//创建客户端套接字，负责连接服务器

SocketsocketClient=null;

publicClient()

{

InitializeComponent();

//关闭对文本框跨线程操作的检查

TextBox.CheckForIllegalCrossThreadCalls=false;

}

privatevoidstart_Click(objectsender,EventArgse)

{

//获得文本框中的IP地址对象

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

//创建包含IP和端口的网络节点对象

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

//创建客户端套接字，负责连接服务器

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

try

{

//客户端连接到服务器

socketClient.Connect(endPoint);

ShowMsg("客户端连接服务器成功");

}

catch(SocketExceptionex)

{

ShowMsg("客户端连接服务器发生异常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客户端连接服务器发生异常："+ex.Message);

}

threadClient=newThread(ReceiveMsg);

threadClient.IsBackground=true;

threadClient.Start();

}

privatevoidbtnSend_Click(objectsender,EventArgse)

{

stringstrMsg=txtMsg.Text.Trim();

//将字符串转成方便网络传送的二进制数组

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

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

arrMsgSend[0]=0;//设置标识位，0代表发送的是文字

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

try

{

socketClient.Send(arrMsgSend);

//清空发送消息文本框中的消息

this.txtMsg.Text="";

}

catch(SocketExceptionex)

{

ShowMsg("客户端发送消息时发生异常："+ex.Message);

}

catch(Exceptionex)

{

ShowMsg("客户端发送消息时发生异常："+ex.Message);

}

}

privatevoidShowMsg(stringmsg)

{

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

}

privatevoidReceiveMsg()

{

while(true)

{

//定义一个接收消息用的字节数组缓冲区（2M大小）

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

//将接收到的数据存入arrMsgRev,并返回真正接收到数据的长度

intlength=-1;

try

{