Socket实现仿QQ聊天（可部署于广域网）附源码（1）-简介

时间 2019-11-21

原文原文链接

1.前言html

本次实现的这个聊天工具是我去年c#程序设计课程所写的Socket仿QQ聊天，因为当时候没有本身的服务器，只能在机房局域网内进行测试，最近在腾讯云上买了一台云主机（本人学生党，腾讯云有个学生专享活动一元一个月的云服务器，若是仍是学生的能够试一下，地址http://www.qcloud.com/event/qcloudSchool），通过从新编码实现了广域网聊天的功能。下面开始介绍个人自制聊天软件啦！！！数据库

2.功能c#

1. 聊天室服务器端的建立。数组

2. 聊天室客户端的建立。服务器

3. 实现客户与服务器的链接通信。网络

4. 实现客户之间的私聊（窗口抖动，通常信息，文件）。函数

5. 实现客户端的在线信息显示。工具

6. 实现服务器端当前在线客户信息。测试

7. 保存谈话记录。阿里云

8.实现客户端仿QQ的通常操做（注册，登陆，修改密码，查找好友，更新我的信息，娱乐，切换头像）

3.技术

本程序是设计一个相似QQ的网络即时聊天工具，主要是采用WinForms+ADO.NET+Socket通讯+thread+云服务器技术实现。软件功能主要包括用户注册、用户登陆、用户间聊天、查找/添加好友、我的设置以及服务器的搭建等。客户端经过公共的SQLServer2008数据库交换信息，消息的发送和读取都是经过Socket通讯技术和操做数据库来完成的。在程序中采用定时扫描数据库的方式来查找登陆用户。以及Socket通讯技术实现信息交换。

4.网络通讯简介

博客园上有不少简介我简单引用一下

一、Socket还被称做“套接字”，应用程序一般经过套接字向网络发送请求或者应答网络请求。根据链接启动的方式以及本地套接字要链接的目标，套接字之间的链接过程能够分为三个步骤：服务器监听，客户端请求，链接确认。

二、端口：能够认为是计算机与外界通信交流的出口。

三、Tcp： TCP是一种面向链接（链接导向）的、可靠的、基于字节流的运输层通讯协议。UDP是另外一个重要的传输协议。

四、UDP：用户数据报协议，是一种无链接的传输层协议，提供面向事务的简单不可靠信息传送服务。

本人以为博主张龙豪的这篇Socket文章写得不错，你们能够参考一下。

聊天程序（基于Socket、Thread）

http://www.cnblogs.com/knowledgesea/archive/2012/11/26/2788669.html

这是一幅很是经典的图啊，相信看后你们对Socket就会有必定的了解。

5.简单实现Socket通讯

服务器代码：

public Form1()
       {
           InitializeComponent();
           //防止新线程调用主线程卡死
          CheckForIllegalCrossThreadCalls = false;
       }
       Socket sck = null;
       Thread thread = null;
       //点击开启服务端监听
       private void btnServer_Click(object sender, EventArgs e)
       {
           //建立一个Socket实例
           //第一个参数表示使用ipv4
           //第二个参数表示发送的是数据流
           //第三个参数表示使用的协议是Tcp协议
           sck = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
           //获取ip地址局域网使用 ipv4，广域网使用外网IP
           IPAddress ip = IPAddress.Parse(txtIP.Text);
           //建立一个网络通讯节点，这个通讯节点包含了ip地址，跟端口号。
           //这里的端口咱们设置为1029，这里设置大于1024，为何本身查一下端口号范围使用说明。
           IPEndPoint endPoint = new IPEndPoint(ip, int.Parse(txtPort.Text));
           //Socket绑定网路通讯节点
           sck.Bind(endPoint);
           //设置监听队列
           sck.Listen(10);
           ShowMsg("开启监听！");

           //开启一个新线程，放入Socket服务监听
           Thread thread = new Thread(JtSocket);
           //设置为后台线程
           thread.IsBackground = true;
           thread.Start();
       }
       Socket accSck = null;
       //Socket服务监听函数
       void JtSocket()
       {
           while (true)//注意该循环,服务端要持续监听,要否则一个客户端连接事后就没法连接第二个客户端了。
           {
               //建立一个接收客户端通讯的Socket
               accSck = sck.Accept();
               //若是监听到客户端有连接，则运行到下一部，提示，连接成功！
               ShowMsg("连接成功！");
           }
       }

       //消息框里面数据
       void ShowMsg(string str)
       {
           string Ystr = "";
           if (txtChat.Text != "")
           {
               Ystr = txtChat.Text + "\r\n";
           }
           txtChat.Text = Ystr + str;
       }
           /// <summary>
           /// 向客户端发消息
           /// </summary>
           /// <param name="sender"></param>
           /// <param name="e"></param>
       private void btnSend_Click(object sender, EventArgs e)
       {
           string SendMsg = txtMsg.Text;
           if (SendMsg != "")
           {
               byte[] buffer = System.Text.Encoding.UTF8.GetBytes(SendMsg); //将要发送的数据，生成字节数组。
               accSck.Send(buffer);
               ShowMsg("向客户端发送了:" + SendMsg);
           }
       }

客户端代码：

public Client()
       {
           InitializeComponent();
           //防止新线程调用主线程卡死
           TextBox.CheckForIllegalCrossThreadCalls = false;
       }
       Socket clientSocket = null;
       Thread thread = null;
       //经过IP地址与端口号与服务端创建连接      
       private void btnToServer_Click(object sender, EventArgs e)
       {
           clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
           //这里的ip地址，端口号都是服务端绑定的相关数据。
           IPAddress ip = IPAddress.Parse(txtIP.Text);
           IPEndPoint endpoint = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));
           clientSocket.Connect(endpoint);//连接有端口号与IP地址肯定服务端.

           //客户端在接受服务端发送过来的数据是经过Socket 中的Receive方法，
           //该方法会阻断线程，因此咱们本身为该方法建立了一个线程
           thread = new Thread(ReceMsg);
           thread.IsBackground = true;//设置后台线程
           thread.Start();
       }
       public void ReceMsg()
       {
           while (true)
           {
               byte[] buffer = new byte[1024 * 1024 * 2];
               clientSocket.Receive(buffer);//接收服务端发送过来的数据
               string ReceiveMsg = System.Text.Encoding.UTF8.GetString(buffer);//把接收到的字节数组转成字符串显示在文本框中。
               ShowMsg("接收到数据:" + ReceiveMsg);
           }
       }

       //消息框里面数据
       void ShowMsg(string str)
       {
           string Ystr = "";
           if (txtChat.Text != "")
           {
               Ystr = txtChat.Text + "\r\n";
           }
           txtChat.Text = Ystr + str;
       }

运行效果

小练习源码地址：http://pan.baidu.com/s/1sld12Kt

5.小结

本次只是开了一个头，咱们介绍了一下的Socket仿QQ聊天的基本实现思想，从下次博客开始我要开始写服务器如何监听多个客户端，而且如何实现端对端的通讯，以及对通讯协议的自定义，说了这么多，看一下我实现的效果吧。下次咱们继续聊。

下面这幅图为客户端聊天是发送窗口抖动的效果，好吧有点鬼畜，（上面那个为服务器-*可部署于服务器*，下面为两个客户端）

6源码

下面这个源码基本上是我课程设计时所做，我把它命名为MyChatV1.0,后续的博客中我还会重构个人代码，你们能够先下载的看一下（写的可能比较挫），核心实现代码我还会在我后续的博客中介绍。（APP.config文件中的数据库地址是我使用阿里云免费的数据库，你们能够直接使用但注意只能用于交流，本地数据库文件我也会上传到源码当中）。

这个系列未完，待续。。。。。。。。。。。。。。。。。。。。。，期待您的关注

MyChatV1.0源码：http://pan.baidu.com/s/1pLnEUwV