Socket实现仿QQ聊天（可部署于广域网）附源码（2）

1.前言

     这是本系列的第二篇文章，第一篇文章得到了很多朋友们的支持，在这里表示非常的感谢。对于这一系列文章需要补充的是这只是一篇入门级别的Socket通信文章，对于专业人员来说完全可以跳过。本文只介绍一些基本TCP通信技术并使用该技术实现聊天功能。本篇文章实现聊天服务器搭建，我会把聊天服务器部署到广域网服务器上，到时候大家就可以可以在源码里面打开客户端与我聊天啦！（这只是一个初级版功能简单不支持离线消息，所以聊天的前提是我在线（用户名为张三的就是我，Q我吧）……）。

2.本篇实现功能

1. 聊天室服务器端的创建。

2. 聊天室客户端的创建。

3. 实现客户与服务器的连接通讯。

4. 实现客户之间的私聊。

3.具体实现

（1）客户端搭建

1）运行过程 与服务端建立连接—>首次连接向服务器发送登录用户信息（格式例如 张三| ）—>聊天：先将聊天消息发送到服务器，然后由服务器解析发给好友（发往服务器的消息如下 张三|李四|你好呀李四？),如图

客户端代码实现：

 1 //客户端通信套接字 2   private Socket clientSocket; 3   //新get='_blank'>线程 4   private Thread thread; 5   //当前登录的用户 6   private string userName = ""; 7   public Client() 8    { 9      InitializeComponent(); 10     //防止新线程调用主线程卡死 11     CheckForIllegalCrossThreadCalls = false; 12    } 13  14   //通过IP地址与端口号与服务端建立链接    15   private void btnToServer_Click(object sender, EventArgs e) 16    { 17     //连接服务器前先选择用户 18     if (cmbUser.SelectedItem == null) 19      { 20       MessageBox.Show("请选择登录用户"); 21       return; 22      } 23     userName = cmbUser.SelectedItem.ToString(); 24     this.Text = "当前用户：" + userName; 25     //登录后禁止切换用户 26     cmbUser.Enabled = false; 27     //加载好友列表 28     foreach (object item in cmbUser.Items) 29      { 30       if (item != cmbUser.SelectedItem) 31        { 32          lbFriends.Items.Add(item); 33        } 34      } 35     //新建通信套接字 36     clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 37     //这里的ip地址，端口号都是服务端绑定的相关数据。 38     IPAddress ip = IPAddress.Parse(txtIP.Text); 39     var endpoint = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text)); 40     try 41      { 42     clientSocket.Connect(endpoint); //链接有端口号与IP地址确定服务端. 43     //登录时给服务器发送登录消息例如张三|  44       string str = userName + "|" + " "; 45       byte[] buffer = Encoding.UTF8.GetBytes(str); 46        clientSocket.Send(buffer); 47      } 48     catch 49      { 50       MessageBox.Show("与服务器连接失败"); 51        lbFriends.Items.Clear(); 52      } 53     //客户端在接受服务端发送过来的数据是通过Socket 中的Receive方法，该方**阻断线程，所以我们自己为该方法创建了一个线程 54     thread = new Thread(ReceMsg); 55     thread.IsBackground = true; //设置后台线程 56      thread.Start(); 57    } 58  59   public void ReceMsg() 60    { 61     while (true) 62      { 63  64       try 65        { 66         var buffer = new byte[1024 * 1024 * 2]; 67         int dateLength = clientSocket.Receive(buffer); //接收服务端发送过来的数据 68         //把接收到的字节数组转成字符串显示在文本框中。 69         string ReceiveMsg = Encoding.UTF8.GetString(buffer, 0, dateLength); 70         string[] msgTxt = ReceiveMsg.Split('|'); 71         string newstr ="   "+msgTxt[0] +"：我"+ "\r\n"+"   " + msgTxt[2] + "      ____[" + DateTime.Now +"]" + "\r\n" + "\r\n"; 72          ShowSmsg(newstr); 73        } 74       catch 75        { 76        77        } 78      } 79    } 80  81   private void btnSend_Click(object sender, EventArgs e) 82    { 83     if (lbFriends.SelectedItems.Count != 1) 84      { 85       MessageBox.Show("请选择好友"); 86       return; 87      } 88     string friend = lbFriends.SelectedItem.ToString(); 89     try 90      { 91       //界面显示消息 92       string newstr = "我" + ":" + friend + "\r\n" + txtMsg.Text.Trim() + "      ____[" + DateTime.Now + 93               "]" + "\r\n" + "\r\n"; 94        ShowSmsg(newstr); 95       //发往服务器的消息   格式为 （发送者|接收者|信息） 96       string str = userName + "|" + friend + "|" + txtMsg.Text.Trim(); 97       //将消息转化为字节数据传输 98       byte[] buffer = Encoding.UTF8.GetBytes(str); 99        clientSocket.Send(buffer);100       txtMsg.Text = "";101      }102     catch103      {104       MessageBox.Show("与服务器连接失败");105      }106    }107   //展示消息108   private void ShowSmsg(string newStr)109    {110      txtChat.AppendText(newStr);111    }112   private void btnCloseSer_Click(object sender, EventArgs e)113    {114      clientSocket.Close();115   } 

海外公司注册、海外银行开户、跨境平台代入驻、VAT、EPR等知识和在线办理：https://www.xlkjsw.com

原标题：Socket实现仿QQ聊天（可部署于广域网）附源码（2）

关键词：socket