本篇内容主要讲解“C#中怎么用websocket实现简易聊天功能”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“C#中怎么用websocket实现简易聊天功能”吧!

使用C#语言进行开发，基于.NET FrameWork4

功能包含群聊，和私聊

界面设计代码

namespacechat_server{partialclassForm1{///<summary>///必需的设计器变量。///</summary>privateSystem.ComponentModel.IContainercomponents=null;///<summary>///清理所有正在使用的资源。///</summary>///<paramname="disposing">如果应释放托管资源，为true；否则为false。</param>protectedoverridevoidDispose(booldisposing){if(disposing&&(components!=null)){components.Dispose();}base.Dispose(disposing);}#regionWindows窗体设计器生成的代码///<summary>///设计器支持所需的方法-不要修改///使用代码编辑器修改此方法的内容。///</summary>privatevoidInitializeComponent(){this.textBoxIP=newSystem.Windows.Forms.TextBox();this.labelIP=newSystem.Windows.Forms.Label();this.labelPort=newSystem.Windows.Forms.Label();this.textBoxPort=newSystem.Windows.Forms.TextBox();this.buttonStart=newSystem.Windows.Forms.Button();this.textBoxLog=newSystem.Windows.Forms.TextBox();this.textBoxMsg=newSystem.Windows.Forms.TextBox();this.buttonSend=newSystem.Windows.Forms.Button();this.SuspendLayout();////textBoxIP//this.textBoxIP.Location=newSystem.Drawing.Point(145,25);this.textBoxIP.Name="textBoxIP";this.textBoxIP.Size=newSystem.Drawing.Size(100,25);this.textBoxIP.TabIndex=0;this.textBoxIP.Text="127.0.0.1";////labelIP//this.labelIP.AutoSize=true;this.labelIP.Location=newSystem.Drawing.Point(90,28);this.labelIP.Name="labelIP";this.labelIP.Size=newSystem.Drawing.Size(31,15);this.labelIP.TabIndex=1;this.labelIP.Text="IP:";////labelPort//this.labelPort.AutoSize=true;this.labelPort.Location=newSystem.Drawing.Point(371,28);this.labelPort.Name="labelPort";this.labelPort.Size=newSystem.Drawing.Size(54,15);this.labelPort.TabIndex=3;this.labelPort.Text="port：";////textBoxPort//this.textBoxPort.Location=newSystem.Drawing.Point(452,25);this.textBoxPort.Name="textBoxPort";this.textBoxPort.Size=newSystem.Drawing.Size(100,25);this.textBoxPort.TabIndex=2;this.textBoxPort.Text="6666";////buttonStart//this.buttonStart.Location=newSystem.Drawing.Point(718,13);this.buttonStart.Name="buttonStart";this.buttonStart.Size=newSystem.Drawing.Size(142,45);this.buttonStart.TabIndex=4;this.buttonStart.Text="开启服务";this.buttonStart.UseVisualStyleBackColor=true;this.buttonStart.Click+=newSystem.EventHandler(this.buttonStart_Click);////textBoxLog//this.textBoxLog.Location=newSystem.Drawing.Point(28,73);this.textBoxLog.Multiline=true;this.textBoxLog.Name="textBoxLog";this.textBoxLog.Size=newSystem.Drawing.Size(832,406);this.textBoxLog.TabIndex=5;////textBoxMsg//this.textBoxMsg.Location=newSystem.Drawing.Point(28,499);this.textBoxMsg.Name="textBoxMsg";this.textBoxMsg.Size=newSystem.Drawing.Size(653,25);this.textBoxMsg.TabIndex=6;////buttonSend//this.buttonSend.Location=newSystem.Drawing.Point(761,499);this.buttonSend.Name="buttonSend";this.buttonSend.Size=newSystem.Drawing.Size(99,43);this.buttonSend.TabIndex=7;this.buttonSend.Text="发送";this.buttonSend.UseVisualStyleBackColor=true;this.buttonSend.Click+=newSystem.EventHandler(this.buttonSend_Click);////Form1//this.AutoScaleDimensions=newSystem.Drawing.SizeF(8F,15F);this.AutoScaleMode=System.Windows.Forms.AutoScaleMode.Font;this.ClientSize=newSystem.Drawing.Size(947,567);this.Controls.Add(this.buttonSend);this.Controls.Add(this.textBoxMsg);this.Controls.Add(this.textBoxLog);this.Controls.Add(this.buttonStart);this.Controls.Add(this.labelPort);this.Controls.Add(this.textBoxPort);this.Controls.Add(this.labelIP);this.Controls.Add(this.textBoxIP);this.Name="Form1";this.Text="服务器";this.Load+=newSystem.EventHandler(this.Form1_Load);this.ResumeLayout(false);this.PerformLayout();}#endregionprivateSystem.Windows.Forms.TextBoxtextBoxIP;privateSystem.Windows.Forms.LabellabelIP;privateSystem.Windows.Forms.LabellabelPort;privateSystem.Windows.Forms.TextBoxtextBoxPort;privateSystem.Windows.Forms.ButtonbuttonStart;privateSystem.Windows.Forms.TextBoxtextBoxLog;privateSystem.Windows.Forms.TextBoxtextBoxMsg;privateSystem.Windows.Forms.ButtonbuttonSend;}}

源代码

usingSystem;usingSystem.Collections.Generic;usingSystem.ComponentModel;usingSystem.Data;usingSystem.Drawing;usingSystem.Linq;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;usingSystem.Threading;usingSystem.Windows.Forms;namespacechat_server{publicpartialclassForm1:Form{publicForm1(){InitializeComponent();}privatevoidForm1_Load(objectsender,EventArgse){}//socket连接容器Dictionary<Socket,String>userContain=newDictionary<Socket,string>();privatevoidbuttonStart_Click(objectsender,EventArgse){try{//1、创建socketSocketsocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);//2、绑定ip和端口Stringip=textBoxIP.Text;intport=Convert.ToInt32(textBoxPort.Text);socket.Bind(newIPEndPoint(IPAddress.Parse(ip),port));//3、开启监听socket.Listen(10);//等待连接队列的最大值//4、开始接受客户端的链接ThreadPool.QueueUserWorkItem(newWaitCallback(connect),socket);}catch{MessageBox.Show("启动服务器失败");}}privatevoidconnect(objectsocket){varserverSockert=socketasSocket;//强制转换showLog("服务器正常启动，开始接受客户端的数据");byte[]data=newbyte[1024];intlen;Stringname;//客户端的用户名while(true){try{varproxSocket=serverSockert.Accept();//接受连接len=proxSocket.Receive(data,0,data.Length,SocketFlags.None);//接受客户端的用户名name=Encoding.Default.GetString(data,0,len);showLog(String.Format("客户端{0}用户名{1}连接服务器",proxSocket.RemoteEndPoint.ToString(),name));Stringmsg=String.Format("用户{0}上线了",name);sendMsg(msg);userContain[proxSocket]=name;//把对象放入集合中//不停的接受当前链接的客户端发送的消息ThreadPool.QueueUserWorkItem(newWaitCallback(this.recevie),proxSocket);}catch{MessageBox.Show("接受异常");break;}}}privatevoidrecevie(objectsocket){varproxSocket=socketasSocket;byte[]data=newbyte[1024*1024];//接受，发送数据缓冲区Stringmsg;intlen=0;//数据长度Stringname=userContain[proxSocket];//客户端名字while(true){try{len=proxSocket.Receive(data,0,data.Length,SocketFlags.None);}catch{msg=String.Format("客户端{0}异常退出",proxSocket.RemoteEndPoint.ToString());showLog(msg);msg=String.Format("用户{0}下线了",name);sendMsg(msg);userContain.Remove(proxSocket);stopConnect(proxSocket);return;}if(len<=0){//客户端正常退出msg=String.Format("客户端{0}正常退出",proxSocket.RemoteEndPoint.ToString());showLog(msg);msg=String.Format("用户{0}下线了",name);sendMsg(msg);userContain.Remove(proxSocket);stopConnect(proxSocket);return;//结束当前接受客户端数据的异步线程}//接受消息msg=Encoding.Default.GetString(data,0,len);//私聊信息格式@name:msg//name为用户名msg为消息boolflag=true;if(msg.StartsWith("@")){intindex=msg.IndexOf(":");StringtargetName=msg.Substring(1,index-1);msg=msg.Substring(index+1);foreach(varuserinuserContain){if(targetName.Equals(user.Value)&&user.Key.Connected){msg=String.Format("用户{0}单独对你说：{1}",name,msg);data=Encoding.Default.GetBytes(msg);user.Key.Send(data,0,data.Length,SocketFlags.None);flag=false;break;}}}if(flag){msg=String.Format("用户{0}：{1}",name,msg);sendMsg(msg);}}}privatevoidstopConnect(Socketsocket){try{if(socket.Connected){socket.Shutdown(SocketShutdown.Both);socket.Close(100);}}catch{}}privatevoidshowLog(Stringmsg){if(textBoxLog.InvokeRequired){//如果是跨线程访问textBoxLog.Invoke(newAction<String>(s=>{this.textBoxLog.Text+=msg+"\r\n";}),msg);}else{this.textBoxLog.Text+=msg;}}privatevoidbuttonSend_Click(objectsender,EventArgse){//发送消息Stringmsg=String.Format("服务器发布通知信息{0}",textBoxMsg.Text);sendMsg(msg);}privatevoidsendMsg(Stringmsg){byte[]data=newbyte[1024*1024];data=Encoding.Default.GetBytes(msg);foreach(varuserinuserContain){if(user.Key.Connected){user.Key.Send(data,0,data.Length,SocketFlags.None);}}}}}

到此，相信大家对“C#中怎么用websocket实现简易聊天功能”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！