tcp通信服务器

【实例简介】tcp通信服务器实现
【实例截图】

【核心代码】

        Socket socketSend;
        //存放客户端的ip port和对应的socket
        Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();
        /// <summary>
        /// 等待客户端的连接，并且创建与之通信的Socket
        /// </summary>
        void Listen(object o)
        {
            //线程中的参数只能是object
            Socket socketWatch = o as Socket;
            while (true)
            {
                try
                {
                    //等待连接，连接成功返回一个用于数据收发得socket，while循环可以让不同得客户端连接
                    socketSend = socketWatch.Accept();
                    //将远程客户端的ip port和对应的socket存放到键值对中
                    dicSocket.Add(socketSend.RemoteEndPoint.ToString(), socketSend);
                    //将远程客户端的ip port和对应的socket存放到下拉菜单供选择
                    comboBoxUser.Items.Add(socketSend.RemoteEndPoint.ToString());
                    //连接成功后，返回每一个客户端的 IP和port
                    ShowMsg(socketSend.RemoteEndPoint.ToString() ":" " 连接成功" "\r\n");
                    //开启新线程不停的接收客户端发来的消息
                    Thread th = new Thread(DataReceive);
                    th.IsBackground = true;
                    th.Start(socketSend);
                }
                catch (SocketException e)
                {
                    ShowMsg(e.ToString());
                    break;
                }
            }
        }

        void DataReceive(object o)
        {
            Socket socketSend = o as Socket;
            //不停得接收消息
            while (true)
            {
                try
                {
                    //定义接收缓存
                    byte[] bufferReceive = new byte[1024 * 1024 * 2];
                    //接收的字节数，当客户端下线时，receiveNumber=0
                    int receiveNumber = socketSend.Receive(bufferReceive);

                    //判断客户端是否下线，防止客户端下线时，服务端一直接收空消息
                    if (receiveNumber == 0)
                    {
                        break;
                    }
                    //字节转换成字符串
                    string str = Encoding.UTF8.GetString(bufferReceive, 0, receiveNumber);
                    //打印到窗体
                    ShowMsg(socketSend.RemoteEndPoint ": " str);
                }
                catch (SocketException e)
                {
                    ShowMsg(e.ToString());
                    break;
                }
            }
        }