前面有一篇文章写了关于Socket的一些理解，今天小编就用C#来实现以下某聊天软件的多人聊天系统（别问我为啥不用C++，只是因为C#效率高，一个字爽啊）。

我们先来看一下整体的思路：

整体思路是利用线程池达到接收多个聊天请求。先初始化Socket，然后与端口绑定(bind)，对端口进行监听(listen)，调用accept阻塞，等待客户端连接。在这时如果有个客户端初始化一个Socket，然后连接服务器(connect)，如果连接成功，这时请求端与接收端的连接就建立了。客户端发送数据请求，服务器端接收请求并处理请求，然后把回应数据发送给客户端，客户端读取数据

前端页面很简单，一个显示框一个输入框：

具体代码实现：

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Net.Sockets;using System.Net;using System.Threading;namespace WindowsFormsApplication2{ public partial class Form1 : Form { public delegate void CallBack(string str); public Socket socListen = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); public Form1() { InitializeComponent(); CheckForIllegalCrossThreadCalls = false; } private void Form1_Load(object sender, EventArgs e) { string ip_server = string.Empty; //获取主机名 string name = Dns.GetHostName(); //通过主机名获取本地IP（包含所有IP，有几个网卡就有几个IP，IP分IPV4和IPV6，这里要注意我们用IPV4） IPAddress[] ipadrlist = Dns.GetHostAddresses(name);  foreach (IPAddress ipa in ipadrlist) { //筛选出我们要的IP，这里因为我是多个网卡，所以我需要这样筛选，大家可以用自己的特征去筛选 IP我打码了 if (ipa.ToString().Contains("！！！！！！")) ip_server = ipa.ToString(); } //小编自己用，大家可以不理会 ip_server = ipadrlist[3].ToString();  //注意，你要用的端口，这个端口要确保没有被占用 int port = 6000; IPAddress address = IPAddress.Parse(ip_server); //创建网络端口,包括ip和端口 IPEndPoint endPoint = new IPEndPoint(address, port); // 绑定套接字 socListen.Bind(endPoint); socListen.Listen(5); //创建线程，开始接受请求，因为Accept方法会阻塞，所以要用多线程 Thread thread = new Thread(acceptConnect); thread.Start(); } private void button1_Click(object sender, EventArgs e) { //为简单起见，限制聊天消息在1024个字节 string msg = richTextBox2.Text.Trim(); if (msg.Length > 1024) { MessageBox.Show("the message is too long"); return; } byte[] btMsg = Encoding.UTF8.GetBytes(msg); byte[] buffer = new byte[1024]; if (!socListen.Connected) { try { //对方IP IPAddress address_Server = IPAddress.Parse("！！！！！！"); //除了对方IP 你还得知道对方的程序跑在什么端口 IPEndPoint endPoint_Server = new IPEndPoint(address_Server, 6000); //连接对方 socListen.Connect(endPoint_Server); } catch (Exception ex) { MessageBox.Show(ex.Message); } } //发送消息 int len = socListen.Send(btMsg, btMsg.Length, SocketFlags.None); richTextBox2.Clear(); } public void acceptConnect() { while (true) { Socket client = null; client = socListen.Accept(); //利用线程池循环接收多个请求 ThreadPool.QueueUserWorkItem(new WaitCallback(receiveMsg),client); } } //接收聊天消息 public void receiveMsg(object clientObj) { Socket client = clientObj as Socket; while (true) { byte[] bt = new byte[1024]; try { client.Receive(bt, bt.Length, SocketFlags.None); string msg = Encoding.UTF8.GetString(bt);  string clientEndPoint = client.RemoteEndPoint.ToString(); listBox1.Items.Add("from Clinet point:"+ 				 clientEndPoint.Substring(clientEndPoint.IndexOf(":")+1,clientEndPoint.Length-clientEndPoint.IndexOf(":")-1)); listBox1.Items.Add("\t" + msg); } catch (Exception ex) { client.Close(); } } } }}

地址运行效果如下：

注：

1、这里面还有很多细节小编没有去处理，核心功能是实现了的。但这并不是一个OK的工程，如果有这方面的需要的朋友，需要自己去处理细节问题。

2、 需要在Form1的构造函数内加上CheckForIllegalCrossThreadCalls = false;这行代码，不然子线程无法操作主界面的控件。