C#基于Socket实现多人聊天功能

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace ChatRoomService
{
    class Service
    {
        Socket socketSevice ;
        List<Socket> userList;//用户组
        public Service()
        {
           socketSevice = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
           userList = new List<Socket>();
        }

        public void  Start()
        {
            socketSevice.Bind(new IPEndPoint(IPAddress.Any,5566));
            socketSevice.Listen(10);
            Console.WriteLine("服务器启动成功");

            //开启接受连接,用多线程
            Thread accThread = new Thread(Accept);
            accThread.IsBackground = true;
            accThread.Start();
        }

        private void Accept()
        {
            //接受连接
            Socket clientSocket = socketSevice.Accept();
            userList.Add(clientSocket);
            //打印已经连接IP地址
            Console.WriteLine(IPToAddress(clientSocket)+"连接进来了");

            //
            Thread RecvThread = new Thread(ReceMessage);
            RecvThread.IsBackground = true;
            RecvThread.Start(clientSocket);

            Accept();//递归
        }
        //接收客户端信息
        private void ReceMessage(Object obj)
        {
            Socket client = obj as Socket;
            byte[] strByte = new byte[1024 * 1024];//设定接受字符的长度
            string str = "";
            try
            {
              int len = client.Receive(strByte);//接受用户发送的内容
              str = Encoding.Default.GetString(strByte, 0, len);
              Broadcast(str,client);//广播给用户
              Console.WriteLine(str);
             }
             catch (Exception e)
             {
                Console.WriteLine(IPToAddress(client)+"退出");
                userList.Remove(client);
                Thread.CurrentThread.Abort();//退出时掐死线程，不然递归反弹
            }
           ReceMessage(client); //使用递归
        }

        /// <summary>
        /// 广播信息
        /// </summary>
        /// <param name="useStr">传入收到的传输的内容</param>
        /// <param name="obj">传送信息的客户</param>
        private void Broadcast(string userStr,object obj)
        {
            Socket clientSend = obj as Socket; //当前发送信息的客户
            foreach (Socket client in userList)
            {
                if (client != clientSend)//将信息广播给其他用户
                {
                    client.Send(Encoding.Default.GetBytes(IPToAddress(clientSend)+":"+userStr));
                }
            }
        }        //转换出连来客户的IP地址
        private string IPToAddress(Socket soket)
        {
            return (soket.RemoteEndPoint as IPEndPoint).Address.ToString();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ChatRoomService
{
    class Program
    {
        static void Main(string[] args)
        {
            Service ss = new Service();
            ss.Start();
            Console.ReadLine();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ChatRoom
{
    class ClientRoom
    {
        Socket clientSocket;

        public ClientRoom()
        {
            clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//初始化服务器
        }
        /// <summary>
        /// 连接服务器
        /// </summary>
        /// <param name="Ip"></param>
        /// <param name="port"></param>
        public void Connected(string Ip,int port)
        {
            clientSocket.Connect(Ip,port);
            Console.WriteLine("连接成功");
            // ClientSocket.Bind(new IPEndPoint());

            Thread RecvThread = new Thread(RecvMessage);
            RecvThread.IsBackground = true;
            RecvThread.Start();
        }

       public void Send(String str)
        {
            clientSocket.Send(Encoding.Default.GetBytes(str));
        }

        /// <summary>
        /// 接受信息
        /// </summary>
        private void RecvMessage()
        {
            try
            {
                byte[] strByte = new byte[500 * 1024];
                int len = clientSocket.Receive(strByte);
                Console.WriteLine(Encoding.Default.GetString(strByte, 0, len));
            }
            catch (Exception e) //服务器关闭
            {
                Console.WriteLine("服务器关闭");
                Thread.CurrentThread.Abort();//关闭时切断进程
            }
            RecvMessage();
        }        
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ChatRoom
{
    class Program
    {
        static void Main(string[] args)
        {
            ClientRoom client = new ClientRoom();
            client.Connected("127.0.0.1", 5566);
            string str = Console.ReadLine();
            while (!str.Equals("q"))
            {
                client.Send(str);
                str = Console.ReadLine();
            }
            Console.ReadLine();
        }
    }
}