C#使用Socket实现本地多人聊天室

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
 
namespace ConsoleApp1
{
    public class Server
    {
        Socket mySocket = null;
        Dictionary<IPAddress, Socket> cliDic = new Dictionary<IPAddress, Socket>();
 
        public void Connect(int port)
        {
            string IP = "127.0.0.1";
            //IPAddress IPAddress = IPAddress.Parse("127.0.0.1");
            IPAddress address = IPAddress.Any;
            //创建IP终结点，把IP地址与端口绑定到网络终结点上
            IPEndPoint endPoint = new IPEndPoint(address, port);
            //创建客户端套接字
            mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            ///监听套接字终结点
            mySocket.Bind(endPoint);
            //服务端可接收客户端连接数量为无限个
            mySocket.Listen(0);
            //开启线程监听客户端
            Thread myThread = new Thread(Listen_Con);
            myThread.Start();
            Console.WriteLine("开始监听...");
        }
 
        /// <summary>
        /// 接收连接的客户端并存储客户端的信息
        /// </summary>
        /// <param name="obj"></param>
        public void Listen_Con(Object obj)
        {
            Socket cliSocket = null;
            //持续监听客户端的请求
            while (true)
            {
                try
                {
                    cliSocket = mySocket.Accept();
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.Message);
                }
                string cliEndPoint = cliSocket.RemoteEndPoint.ToString();
                IPAddress cliAddress = (cliSocket.RemoteEndPoint as IPEndPoint).Address;
                int cliPort = (cliSocket.RemoteEndPoint as IPEndPoint).Port;
                cliDic.Add(cliAddress, cliSocket);
                string MsgStr = "[客户端结点:" + cliEndPoint + "\n+客户端IP：" + cliAddress.ToString() + "\n客户端端口:" +
                    cliPort.ToString() + "\n已连接]";
                byte[] MsgBytes = Encoding.UTF8.GetBytes(MsgStr);
                cliSocket.Send(MsgBytes);
 
                Thread rec_Cli = new Thread(Receive_Con);
                rec_Cli.Start(cliSocket);
                Thread sed_Cli = new Thread(SendToCli);
                sed_Cli.Start(cliSocket);
            }
        }
 
        /// <summary>
        /// 接收已连接的客户端发送的消息
        /// </summary>
        /// <param name="socket"></param>
        public void Receive_Con(Object socket)
        {
            Socket client = socket as Socket;
            while (true)
            {
                //创建大小为1024*1024的内存缓冲区（1M）
                byte[] recBytes = new byte[1024 * 1024];
                //尝试把接收的字节存储到缓冲区
                try
                {
                    int length = client.Receive(recBytes);
                    //把机器接收的字节数组转换为string
                    string recMsg = Encoding.UTF8.GetString(recBytes, 0, length);
                    //将服务器接收到的信息转发到所有已连接的客户端
                    if (cliDic.Count > 0)
                    {
                        foreach (var soc in cliDic)
                        {
                            soc.Value.Send(Encoding.UTF8.GetBytes("[" + soc.Value.RemoteEndPoint + "]:" + recMsg));
                        }
                    }
                    Console.WriteLine("[" + client.RemoteEndPoint + "]:" + recMsg);
                }
                catch (Exception)
                {
                    cliDic.Remove((client.RemoteEndPoint as IPEndPoint).Address);
                    //客户端断开的异常
                    Console.WriteLine("[客户端" + (client.RemoteEndPoint as IPEndPoint).Address + "已断开]");
                    Console.WriteLine("[客户端终结点：" + client.RemoteEndPoint+"]");
                    //断开套接字
                    client.Close();
                    break;
                }
            }
        }
 
        public void SendToCli(object obj)
        {
            Socket curCliSoc = obj as Socket;
            while (true)
            {
                byte[] ByteToAll = new byte[1024 * 1024];
                try
                {
                    string MsgToAll = Console.ReadLine();
                    ByteToAll = Encoding.UTF8.GetBytes("[服务端]:"+MsgToAll);
                    curCliSoc.Send(ByteToAll);
                }
                catch(Exception)
                {
                    Console.WriteLine("ERROR:" + curCliSoc.RemoteEndPoint + "已与服务端断开！");
                    curCliSoc.Close();
                    if(cliDic.ContainsKey((curCliSoc.RemoteEndPoint as IPEndPoint).Address))
                    {
                        cliDic.Remove((curCliSoc.RemoteEndPoint as IPEndPoint).Address);
                    }
                }
            }
        }
    }
 
    public class ServerMain
    {
        static void Main(string[] args)
        {
            Server s1 = new Server();
            s1.Connect(8800);
        }
    }
}

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
 
namespace ConsoleApp1
{
    public class Client
    {
        string SerIP = "127.0.0.1";
        Socket myClient = null;
        Thread ConnectThread = null;
        IPAddress SerAdd;
        IPEndPoint SerEP;
        public void Connect_To_Ser(int port)
        {
            myClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            SerAdd = IPAddress.Parse(SerIP);
            SerEP = new IPEndPoint(SerAdd, port);
            while (true)
            {
                try
                {
                    myClient.Connect(SerEP);
                    break;
                }
                catch
                {
                    Console.WriteLine("无法连接到服务端，请重试...");
                }
            }
            ConnectThread = new Thread(Receive_Ser);
            ConnectThread.Start();
        }
 
        public void Receive_Ser()
        {
            while (true)
            {
                byte[] SerBytes = new byte[1024 * 1024];
                try
                {
                    int length = myClient.Receive(SerBytes);
                    string Msg = Encoding.UTF8.GetString(SerBytes, 0, length);
                    Console.WriteLine(Msg);
                }
                catch (Exception)
                {
                    Console.WriteLine("已与服务端断开连接...");
                    break;
                }
            }
        }
 
        public void SendToSer()
        {
            while (true)
            {
                try
                {
                    string SendMsg = Console.ReadLine();
                    myClient.Send(Encoding.UTF8.GetBytes(SendMsg));
                }
                catch (Exception)
                {
                    Console.WriteLine("[SendToSer]已断开连接");
                    break;
                }
            }
        }
    }
 
    public class ClienMain
    {
        static void Main(string[] Args)
        {
            Client c1 = new Client();
            c1.Connect_To_Ser(8800);
            c1.SendToSer();
        }
    }
}