Socket详细版,客户端和服务端，实现聊天对话

【实例简介】

可以实现Client和Server互通，进行聊天类似QQ聊天~

【实例截图】

 //每一个连接的客户端必须设置一个唯一的用户名，在服务器端是把用户名和套接字保存在Dictionary<userName,ClientSocket>中
        private void btnConnect_Click(object sender, EventArgs e)
        {
            if (String.IsNullOrWhiteSpace(txtName.Text.Trim()))
            {
                MessageBox.Show("请设置个用户名哦亲");
                return;
            }
            if (txtName.Text.Length >= 17 && txtName.Text.ToString().Trim().Substring(0, 17).Equals("Server has closed"))
            {
                MessageBox.Show("该用户名中包含敏感词，请更换用户名后重试");
                return;
            }

            if (clientSocket == null || !clientSocket.Connected)
            {
                try
                {
                    clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                    if (!String.IsNullOrWhiteSpace(txtIP.Text.ToString().Trim()))
                    {
                        try
                        {
                            ipadr = IPAddress.Parse(txtIP.Text.ToString().Trim());
                        }
                        catch
                        {
                            MessageBox.Show("请输入正确的IP后重试");
                            return;
                        }
                    }
                    else
                    {
                        ipadr = IPAddress.Loopback;
                    }

                    //IPAddress ipadr = IPAddress.Parse("192.168.1.100");
                    clientSocket.BeginConnect(ipadr, 8080, (args) =>
                    {
                        if (args.IsCompleted)   //判断该异步操作是否执行完毕
                        {
                            Byte[] bytesSend = new Byte[4096];
                            txtName.BeginInvoke(new Action(() =>
                            {
                                bytesSend = Encoding.UTF8.GetBytes(txtName.Text.Trim() "$");  //用户名，这里是刚刚连接上时需要传过去
                                if (clientSocket != null && clientSocket.Connected)
                                {
                                    clientSocket.Send(bytesSend);
                                    txtName.Enabled = false;    //设置为不能再改名字了
                                    txtSendMsg.Focus();         //将焦点放在
                                    thDataFromServer = new Thread(DataFromServer);
                                    thDataFromServer.IsBackground = true;
                                    thDataFromServer.Start();
                                }
                                else
                                {
                                    MessageBox.Show("服务器已关闭");
                                }

                            }));
                            txtIP.BeginInvoke(new Action(() =>
                            {
                                if (clientSocket != null && clientSocket.Connected)
                                {
                                    txtIP.Enabled = false;
                                }
                            }));
                        }
                    }, null);
                }
                catch (SocketException ex)
                {
                    MessageBox.Show(ex.ToString());
                }
            }
            else
            {
                MessageBox.Show("你已经连接上服务器了");
            }
        }

【核心代码】

private void btnBreak_Click(object sender, EventArgs e)
        {
            if (clientSocket != null && clientSocket.Connected)
            {
                thDataFromServer.Abort();
                clientSocket.Send(Encoding.UTF8.GetBytes("$"));

                clientSocket.Close();
                clientSocket = null;

                txtReceiveMsg.BeginInvoke(new Action(() =>
                {
                    txtReceiveMsg.Text = Environment.NewLine "已断开与服务器的连接";
                }));

                txtName.BeginInvoke(new Action(() =>
                {
                    txtName.Enabled = true;
                }));    //重连当然可以换用户名啦
                txtIP.BeginInvoke(new Action(() =>
                {
                    txtIP.Enabled = true;
                }));
            }
        }