C#聊天程序服务端与客户端完整实例代码

using System;using System.Drawing;using System.Collections;using System.ComponentModel;using System.Windows.Forms;using System.Data;using System.Net;using System.Net.Sockets;using System.Threading;namespace 多人聊天程序Server端{ /// <summary> /// 应用程序的主入口点。 /// </summary> [STAThread] static void Main() {  Application.Run(new Form1()); } // 启动服务按钮 private void button2_Click(object sender, System.EventArgs e) {  try  {  // 必须填写端口  if(txtPort.Text == "")  {   MessageBox.Show("请先填写服务端口号!", "提示");   return;  }  Int32 port = Int32.Parse(txtPort.Text); // 获得端口号  // 创建侦听的Socket  mainSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  IPEndPoint localEP = new IPEndPoint(IPAddress.Any, port);  // 将 Socket 绑定到本地的终结点上  mainSocket.Bind(localEP);  // 开始侦听，最大的连接数是 5  mainSocket.Listen(5);  // 开始一个异步操作接受客户的连接请求  mainSocket.BeginAccept(new AsyncCallback(OnClientConnect), null);  // 启动服务按钮不可用，停止服务按钮可用  UpdateControls(true);  }  catch(SocketException se)  {  MessageBox.Show(se.Message, "提示");  } } // 更新“启动服务按钮”和“停止服务”按钮的状态：是否可用； // 注意：两个按钮的状态是互斥的 private void UpdateControls(bool onServe) {  button2.Enabled = !onServe;  button3.Enabled = onServe;  if(onServe)  {  status.Text = "已启动服务";  }  else  {  status.Text = "未启动服务";  } } // 回调函数，当客户连接上时，将会被调用 public void OnClientConnect(IAsyncResult asyn) {  try  {  // 调用EndAccept完成BeginAccept异步调用，返回一个新的Socket处理与客户的通信  Socket workerSocket = mainSocket.EndAccept(asyn);  // 增加客户数目  Interlocked.Increment(ref clientNum);  // 将 workerSocket Socket加入到 ArrayList 中  workerSocketList.Add(workerSocket);  // 发送欢迎信息给连接上服务器的客户  string msg = "欢迎客户 " + clientNum + " 登录服务器/n";  SendWelcomeToClient(msg, clientNum);  // 在线客户数目改变，必须更新客户列表  UpdateClientListControl();  // 连接上的客户接收数据  WaitForData(workerSocket, clientNum);  // 主 Socket 返回，继续等待其它的连接请求  mainSocket.BeginAccept(new AsyncCallback(OnClientConnect), null);  }  catch(ObjectDisposedException)  {  System.Diagnostics.Debugger.Log(0,"1","/n OnClientConnection: Socket已经关闭!/n");  }  catch(SocketException se)  {  MessageBox.Show(se.Message, "提示");  } } // 发送欢迎信息给客户 void SendWelcomeToClient(string msg, int clientNumber) {  // 用UTF8格式来将string信息转化成byte数组形式  byte[] byData = System.Text.Encoding.UTF8.GetBytes(msg);  // 获得客户clientNumber对应的Socket  Socket workerSocket = (Socket)workerSocketList[clientNumber - 1];  // 将数据发给客户  workerSocket.Send(byData); } // 该类保存当前的socket，它的客户号还有发送给服务器的数据 public class SocketPacket {  public System.Net.Sockets.Socket currentSocket; // 当前的Socket  public int clientNumber; // 客户号  public byte[] dataBuffer = new byte[1024]; // 发给服务器的数据  // 构造函数  public SocketPacket(System.Net.Sockets.Socket socket, int clientNumber)  {  currentSocket = socket;  this.clientNumber = clientNumber;  } } // 开始等待客户发送数据 public void WaitForData(System.Net.Sockets.Socket socket, int clientNumber) {  try  {  if(pfnWorkerCallBack == null)  {   // 当连接上的客户有写的操作的时候，调用回调函数   pfnWorkerCallBack = new AsyncCallback(OnDataReceived);  }  SocketPacket socketPacket = new SocketPacket(socket, clientNumber);  socket.BeginReceive(socketPacket.dataBuffer, 0, socketPacket.dataBuffer.Length,            SocketFlags.None, pfnWorkerCallBack, socketPacket);  }  catch(SocketException se)  {  MessageBox.Show (se.Message, "提示");  } } // 当客户写数据时，调用以下方法 public void OnDataReceived(IAsyncResult asyn) {  SocketPacket socketData = (SocketPacket)asyn.AsyncState ;  try  {  // EndReceive完成BeginReceive异步调用，返回客户写入流的字节数  int iRx = socketData.currentSocket.EndReceive(asyn);  // 加 1 是因为字符串以 '/0' 作为结束标志符  char[] chars = new char[iRx + 1];  // 对客户发来的信息进行UTF8解码，存入chars字符数组中  System.Text.Decoder decoder = System.Text.Encoding.UTF8.GetDecoder();  int charLen = decoder.GetChars(socketData.dataBuffer, 0, iRx, chars, 0);  System.String szData = new System.String(chars);  string msg = "客户 " + socketData.clientNumber + " 发的信息:" + szData;  // 将客户发的数据加入到信息列表中  AppendToRichEditControl(msg);  // 等待数据  WaitForData(socketData.currentSocket, socketData.clientNumber);  }  catch (ObjectDisposedException )  {  System.Diagnostics.Debugger.Log(0,"1","/nOnDataReceived: Socket已经关闭!/n");  }  catch(SocketException se)  {  if(se.ErrorCode == 10054)  {   // 将客户断开连接的信息写入信息列表中   string msg = "客户 " + socketData.clientNumber + " 已断开了连接!" + "/n";   AppendToRichEditControl(msg);   // 移走已关闭的socket   workerSocketList[socketData.clientNumber - 1] = null;   // 更新客户列表   UpdateClientListControl();  }  else  {   MessageBox.Show (se.Message, "提示");  }  } } // 更新信息列表，该方法可由主线程或其他工作线程所调用 private void AppendToRichEditControl(string msg) {  // 测试看是哪个线程调用了该方法  if (InvokeRequired)  {  // We cannot update the GUI on this thread.  // All GUI controls are to be updated by the main (GUI) thread.  // Hence we will use the invoke method on the control which will  // be called when the Main thread is free  // Do UI update on UI thread  object[] pList = {msg};  txtRecvMsg.BeginInvoke(new UpdateRichEditCallback(OnUpdateRichEdit), pList);  }  else  {  // 创建该控件的主线程直接更新信息列表  OnUpdateRichEdit(msg);  } } // 添加信息到 txtRecvMsg 中 private void OnUpdateRichEdit(string msg) { // txtRecvMsg.AppendText(msg);  txtRecvMsg.Text = txtRecvMsg.Text + msg; } // 更新客户列表 private void UpdateClientListControl() {  if (InvokeRequired) // Is this called from a thread other than the one created  // the control  {  clientList.BeginInvoke(new UpdateClientListCallback(UpdateClientList), null);  }  else  {  // 创建该控件的主线程直接更新信息列表  UpdateClientList();  } } // 更新客户列表 void UpdateClientList() {  clientList.Items.Clear(); // 清空客户列表  for(int i = 0; i < workerSocketList.Count; i++)  {  // 加1，是因为数组从下标0开始，而我们的客户标号是从1开始  string clientKey = Convert.ToString(i + 1);  Socket workerSocket = (Socket)workerSocketList[i];  if(workerSocket != null)  {   // 将连接着服务器的客户添加到客户列表中   if(workerSocket.Connected)   {   clientList.Items.Add(clientKey);   }  }  } } // 停止服务按钮 private void button3_Click(object sender, System.EventArgs e) {  CloseSockets();  UpdateControls(false);  // 更新客户列表  UpdateClientListControl(); } // 发送信息按钮 private void button1_Click(object sender, System.EventArgs e) {  // 如果在线客户列表不为空，则允许发送信息  if (clientList.Items.Count != 0 )  {  try  {   string msg = txtSendMsg.Text;   msg = "服务器信息: " + msg + "/n";   byte[] byData = System.Text.Encoding.UTF8.GetBytes(msg);   Socket workerSocket = null;   for(int i = 0; i < workerSocketList.Count; i++)   {   workerSocket = (Socket)workerSocketList[i];   if(workerSocket!= null)   {    // 发给所有连接上服务器的客户    if(workerSocket.Connected)    {    workerSocket.Send(byData);    }   }   }  }  catch(SocketException se)  {   MessageBox.Show(se.Message, "提示");  }  }  else  {  MessageBox.Show("没有在线客户,不能发送信息!", "提示");  } } // 清空信息按钮 private void button4_Click(object sender, System.EventArgs e) {  txtRecvMsg.Clear(); // 清空从客户发来的信息 } // 关闭窗体按钮 private void button5_Click(object sender, System.EventArgs e) {  CloseSockets();  Close(); } // 关闭Socket void CloseSockets() {  // 关闭主Socket  if(mainSocket != null)  {  mainSocket.Close();  }  Socket workerSocket = null;  // 关闭客户 Socket 数组  for(int i = 0; i < workerSocketList.Count; i++)  {  workerSocket = (Socket)workerSocketList[i];  if(workerSocket != null)  {   workerSocket.Close();   workerSocket = null;  }  } } private void Form1_Load(object sender, System.EventArgs e) {  try  {  // 获得本机的IP地址  txtIP.Text = Dns.Resolve(Dns.GetHostName()).AddressList[0].ToString();  // 启动时，启动服务按钮可用，停止服务按钮不可用  UpdateControls(false);  }  catch(Exception exc)  {  MessageBox.Show(exc.Message, "提示");  } } }}

using System;using System.Drawing;using System.Collections;using System.ComponentModel;using System.Windows.Forms;using System.Data;using System.Net;using System.Net.Sockets;namespace 多人聊天程序Client端{ public class Form1 : System.Windows.Forms.Form { private System.Windows.Forms.Label label1; private System.Windows.Forms.TextBox txtIP; private System.Windows.Forms.Label label2; private System.Windows.Forms.Label label3; private System.Windows.Forms.RichTextBox txtSendMsg; private System.Windows.Forms.Label label4; private System.Windows.Forms.Button button1; private System.Windows.Forms.Button button2; private System.Windows.Forms.Button button3; private System.Windows.Forms.Button button4; private System.Windows.Forms.RichTextBox txtRecvMsg; private System.Windows.Forms.TextBox txtPort; private System.Windows.Forms.Button button5; private System.ComponentModel.Container components = null; byte[] m_dataBuffer = new byte[10]; IAsyncResult result; public AsyncCallback pfnCallBack ; private System.Windows.Forms.Label status; private System.Windows.Forms.Label label5; public Socket clientSocket; public Form1() {  InitializeComponent(); } private void InitializeComponent() {  this.label1 = new System.Windows.Forms.Label();  this.txtIP = new System.Windows.Forms.TextBox();  this.label2 = new System.Windows.Forms.Label();  this.txtPort = new System.Windows.Forms.TextBox();  this.label3 = new System.Windows.Forms.Label();  this.txtSendMsg = new System.Windows.Forms.RichTextBox();  this.label4 = new System.Windows.Forms.Label();  this.status = new System.Windows.Forms.Label();  this.txtRecvMsg = new System.Windows.Forms.RichTextBox();  this.button1 = new System.Windows.Forms.Button();  this.button2 = new System.Windows.Forms.Button();  this.button3 = new System.Windows.Forms.Button();  this.button4 = new System.Windows.Forms.Button();  this.label5 = new System.Windows.Forms.Label();  this.button5 = new System.Windows.Forms.Button();  this.SuspendLayout();  // label1  this.label1.AutoSize = true;  this.label1.Location = new System.Drawing.Point(16, 24);  this.label1.Name = "label1";  this.label1.Size = new System.Drawing.Size(60, 17);  this.label1.TabIndex = 0;  this.label1.Text = "服务器IP:";  // txtIP  this.txtIP.Location = new System.Drawing.Point(80, 24);  this.txtIP.Name = "txtIP";  this.txtIP.Size = new System.Drawing.Size(160, 21);  this.txtIP.TabIndex = 1;  this.txtIP.Text = "";  // label2  this.label2.AutoSize = true;  this.label2.Location = new System.Drawing.Point(16, 56);  this.label2.Name = "label2";  this.label2.Size = new System.Drawing.Size(35, 17);  this.label2.TabIndex = 2;  this.label2.Text = "端口:";  // txtPort  this.txtPort.Location = new System.Drawing.Point(80, 56);  this.txtPort.Name = "txtPort";  this.txtPort.Size = new System.Drawing.Size(40, 21);  this.txtPort.TabIndex = 3;  this.txtPort.Text = "";  // label3  this.label3.AutoSize = true;  this.label3.Location = new System.Drawing.Point(16, 96);  this.label3.Name = "label3";  this.label3.Size = new System.Drawing.Size(110, 17);  this.label3.TabIndex = 4;  this.label3.Text = "发送信息给服务器:";  // txtSendMsg  this.txtSendMsg.Location = new System.Drawing.Point(16, 120);  this.txtSendMsg.Name = "txtSendMsg";  this.txtSendMsg.Size = new System.Drawing.Size(224, 88);  this.txtSendMsg.TabIndex = 5;  this.txtSendMsg.Text = "";  // label4  this.label4.AutoSize = true;  this.label4.Location = new System.Drawing.Point(16, 248);  this.label4.Name = "label4";  this.label4.Size = new System.Drawing.Size(60, 17);  this.label4.TabIndex = 6;  this.label4.Text = "连接状态:";  // status  this.status.Location = new System.Drawing.Point(80, 248);  this.status.Name = "status";  this.status.Size = new System.Drawing.Size(192, 23);  this.status.TabIndex = 7;  // txtRecvMsg  this.txtRecvMsg.Location = new System.Drawing.Point(264, 80);  this.txtRecvMsg.Name = "txtRecvMsg";  this.txtRecvMsg.ReadOnly = true;  this.txtRecvMsg.Size = new System.Drawing.Size(224, 144);  this.txtRecvMsg.TabIndex = 8;  this.txtRecvMsg.Text = "";  // button1  this.button1.Location = new System.Drawing.Point(280, 16);  this.button1.Name = "button1";  this.button1.Size = new System.Drawing.Size(88, 32);  this.button1.TabIndex = 9;  this.button1.Text = "连接";  this.button1.Click += new System.EventHandler(this.button1_Click);  // button2  this.button2.Location = new System.Drawing.Point(384, 16);  this.button2.Name = "button2";  this.button2.Size = new System.Drawing.Size(88, 32);  this.button2.TabIndex = 10;  this.button2.Text = "断开";  this.button2.Click += new System.EventHandler(this.button2_Click);  // button3  this.button3.Location = new System.Drawing.Point(280, 232);  this.button3.Name = "button3";  this.button3.Size = new System.Drawing.Size(88, 32);  this.button3.TabIndex = 11;  this.button3.Text = "清空信息";  this.button3.Click += new System.EventHandler(this.button3_Click);  // button4  this.button4.Location = new System.Drawing.Point(384, 232);  this.button4.Name = "button4";  this.button4.Size = new System.Drawing.Size(88, 32);  this.button4.TabIndex = 12;  this.button4.Text = "关闭";  this.button4.Click += new System.EventHandler(this.button4_Click);  // label5  this.label5.AutoSize = true;  this.label5.Location = new System.Drawing.Point(264, 64);  this.label5.Name = "label5";  this.label5.Size = new System.Drawing.Size(134, 17);  this.label5.TabIndex = 13;  this.label5.Text = "收到服务器发来的信息:";  // button5  this.button5.Location = new System.Drawing.Point(16, 208);  this.button5.Name = "button5";  this.button5.Size = new System.Drawing.Size(224, 32);  this.button5.TabIndex = 14;  this.button5.Text = "发送信息";  this.button5.Click += new System.EventHandler(this.button5_Click);  // Form1  this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);  this.ClientSize = new System.Drawing.Size(512, 277);  this.Controls.Add(this.button5);  this.Controls.Add(this.label5);  this.Controls.Add(this.button4);  this.Controls.Add(this.button3);  this.Controls.Add(this.button2);  this.Controls.Add(this.button1);  this.Controls.Add(this.txtRecvMsg);  this.Controls.Add(this.status);  this.Controls.Add(this.label4);  this.Controls.Add(this.txtSendMsg);  this.Controls.Add(this.label3);  this.Controls.Add(this.txtPort);  this.Controls.Add(this.label2);  this.Controls.Add(this.txtIP);  this.Controls.Add(this.label1);  this.Name = "Form1";  this.Text = "多人聊天程序Client端";  this.Load += new System.EventHandler(this.Form1_Load);  this.ResumeLayout(false); } #endregion [STAThread] static void Main() {  Application.Run(new Form1()); } // 连接按钮 private void button1_Click(object sender, System.EventArgs e) {  // IP地址和端口号不能为空  if(txtIP.Text == "" || txtPort.Text == "")  {  MessageBox.Show("请先完整填写服务器IP地址和端口号!", "提示");  return;  }  try  {  // 创建Socket实例  clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  // 得到服务器的IP地址  IPAddress ipAddress = IPAddress.Parse(txtIP.Text);  Int32 port = Int32.Parse(txtPort.Text);  // 创建远程终结点  IPEndPoint remoteEP = new IPEndPoint(ipAddress, port);  // 连接到远程服务器  clientSocket.Connect(remoteEP);  if(clientSocket.Connected)  {   UpdateControls(true);   WaitForData(); // 异步等待数据  }  }  catch(SocketException se)  {  MessageBox.Show (se.Message, "提示");  UpdateControls(false);  } } // 等待数据 public void WaitForData() {  try  {  if(pfnCallBack == null)  {   // 当连接上的客户有写的操作的时候，调用回调函数   pfnCallBack = new AsyncCallback(OnDataReceived);  }  SocketPacket socketPacket = new SocketPacket();  socketPacket.thisSocket = clientSocket;  result = clientSocket.BeginReceive(socketPacket.dataBuffer, 0, socketPacket.dataBuffer.Length,   SocketFlags.None, pfnCallBack, socketPacket);  }  catch(SocketException se)  {  MessageBox.Show(se.Message, "提示");  } } // 该类保存Socket以及发送给服务器的数据 public class SocketPacket {  public System.Net.Sockets.Socket thisSocket;  public byte[] dataBuffer = new byte[1024]; // 发给服务器的数据 } // 接收数据 public void OnDataReceived(IAsyncResult asyn) {  try  {  SocketPacket theSockId = (SocketPacket)asyn.AsyncState ;  // EndReceive完成BeginReceive异步调用，返回服务器写入流的字节数  int iRx = theSockId.thisSocket.EndReceive(asyn);  // 加 1 是因为字符串以 '/0' 作为结束标志符  char[] chars = new char[iRx + 1];  // 用UTF8格式来将string信息转化成byte数组形式  System.Text.Decoder decoder = System.Text.Encoding.UTF8.GetDecoder();  int charLen = decoder.GetChars(theSockId.dataBuffer, 0, iRx, chars, 0);  System.String szData = new System.String(chars);  // 将收到的信息显示在信息列表中  txtRecvMsg.Text = txtRecvMsg.Text + szData;  // 等待数据  WaitForData();  }  catch (ObjectDisposedException)  {  System.Diagnostics.Debugger.Log(0,"1","/nOnDataReceived: Socket已经关闭!/n");  }  catch(SocketException se)  {  if(se.ErrorCode == 10054)  {   string msg = "服务器" + "停止服务!" + "/n";   txtRecvMsg.Text = txtRecvMsg.Text + msg;   clientSocket.Close();   clientSocket = null;   UpdateControls(false);  }  else  {   MessageBox.Show(se.Message, "提示");  }  } } // 更新控件。连接和断开（发送信息）按钮的状态是互斥的 private void UpdateControls(bool connected) {  button1.Enabled = !connected;  button2.Enabled = connected;  button5.Enabled = connected;  if(connected)  {  status.Text = "已连接";  }  else  {  status.Text = "无连接";  } } // 断开按钮 private void button2_Click(object sender, System.EventArgs e) {  // 关闭Socket  if(clientSocket != null)  {  clientSocket.Close();  clientSocket = null;  UpdateControls(false);  } } // 发送信息按钮 private void button5_Click(object sender, System.EventArgs e) {  try  {  // 如果客户与服务器有连接，则允许发送信息  if(clientSocket.Connected)  {   string msg = txtSendMsg.Text + "/n";   // 用UTF8格式来将string信息转化成byte数组形式   byte[] byData = System.Text.Encoding.UTF8.GetBytes(msg);   if(clientSocket != null)   {   // 发送数据   clientSocket.Send(byData);   }  }  }  catch(Exception se)  {  MessageBox.Show(se.Message, "提示");  } } // 清空按钮 private void button3_Click(object sender, System.EventArgs e) {  txtRecvMsg.Clear(); // 清空信息列表 } // 关闭按钮 private void button4_Click(object sender, System.EventArgs e) {  // 关闭Socket  if(clientSocket != null)  {  clientSocket.Close();  clientSocket = null;  }  Close(); // 关闭窗体 } private void Form1_Load(object sender, System.EventArgs e) {  UpdateControls(false); // 初始化时，只有连接按钮可用 } }}