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

这篇文章主要介绍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();        }    }}

可以正常对话，测试一下。假装和自己对话

目前还没有解决沾包问题

以上是“C#如何基于Socket实现多人聊天功能”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注编程网精选频道！