利用TCP传输协议实现基于Socket的聊天程序

利用TCP传输协议实现基于Socket的聊天程序(高级版_多线程)

大家好，上次我写了一个初级版本的聊天程序，程序只是实现简单的连接通信，基于控制台实现，运用了TCP和UDP两种传输协议。今天我写了一个基于窗体的聊天程序，使用了多线程，实现的功能类似于QQ的聊天，不同的是只有一个服务器端，但可以有多个客户端与其通信，只能实现简单的文字信息交流。。。

同样，这个聊天程序也需要一个服务器端，和N个客户端来模拟实现，首先我们来搭建服务器端

首先贴上服务器端的界面图：

界面很简单，左边一个客户端在线的列表，一个显示消息的文本框和一个发送消息的文本框，为了演示简单，我把IP和Port都固定为127.0.0.1 和8888

首先我们来看看【启动服务器】按钮的代码：

启动服务器

这里的代码其实和初级版聊天程序中的服务器代码并没有多大差别，只是在这里我们使用了线程来专门负责监听客户端的请求，但是我们这里为什么要使用多线程呢？？这就需要对多线程的概念及作用去做一个了解了，这里我简单的说下，我们的程序运行是由一个主线程在执行着，而Socket的Accept()方法执行的时候会阻断线程，如果我们没有使用多线程的话也就是说我们的主线程被阻断了，这是就会出现一个现象就是程序卡死来那里了，只有等到某个客户端连接到该服务器，Accept()方法接受到了客户端的请求了主线程才会被释放出来，为了避免这种情况，所以我们这里用过了另外一个线程专门来负责监听客户端的请求，使得主线程仍然可以自由执行(个人理解)。线程的本质就是一个委托，所以在实例化的时候要求传入的是一个方法作为参数，所以我们传入WatchConnection负责监听的方法，贴上该方法的代码，如下：

WatchConnection方法

其实这个方法里的内容很多，首先就我们要实现的效果，我们来思考一个问题，我们要实现的效果是一个服务器可以和多个客户端进行交流，那服务器怎么知道是哪个客户端发过来的呢？Socket的Accept()方法都会返回一个新的Socket对象，那当我们在不同的客户端向服务器端发送数据时我们该用哪个返回的Socket对象呢？？说说我的想法吧。。我的想法是把每个返回的Socket对象都存放起来，用的时候再对应的去拿就可以了，这时我就想到了字典(Dictionary)集合，好，一个问题解决了，但还有一个问题，就是我们根据什么去拿对应的Socket对象呢？？字典就是一个键值对，我们已经解决了这个值，我们该用干什么键去拿呢？？所谓键，就是要唯一能标识的东西，所以这是我们就想到了IP和Port了，这个能唯一标识是那个客户端，所以我们可以通过返回的新的Socket对象的RemoteEndPoint属性来拿到客户端的IP和Port信息，这样，我们两个问题都解决了，这样我们就存储了返回的Socket对象及对应客户端的Ip和Port，然后我们在服务器的“在线列表”上添加上该客户端的IP和Port，用于服务器向客户端发送信息时选择对应的客户端。还有就是，很明显的能看到一个while的死循环，为什么要用死循环呢？因为如果没有用循环，当客户端只有一个的情况下，来连接到服务器，没问题，服务器可以接受到请求，但如果多个呢，，这时就出问题了，之后连接的客户端的请求都接受不到了，所以我们要用一个死循环，来持续的监听请求。最后就是会发现，在这个方法中我又用到了一个线程，这个线程是干嘛的呢？其实，大家可以想想，当客户端给服务器发送信息时，服务器端需要来监听信息，也就是消息过来时要执行Socket的Receive方法来接受消息，当然我们要求务器端要持续的监听接收客户端发来的消息，所以我们就想到线程了，在服务器端用一个线程专门来接收客户端发来的信息，所以我就将返回的Socket对象作为线程的参数传递给对应的方法，线程的参数传递是在Start()方法中实现。

下面贴上此方法中使用了线程的RecMsg方法：

RecMsg方法

可以看到该方法的参数来下是object，这是由于线程传参就是要求参数的类型要是object型的，我们仍然用了一个while死循环来实现持续监听接受数据，至于接受的其他代码就和初级版中的一样了，不多做介绍了，但这里需要注意一点，因为我们在线程的方法中对主线程的控件进行了操作，所以直接运行会报错，解决方法，我们在窗体的构造函数中添加代码，使其不对TextBox进行跨线程检测，代码如下：

窗体构造函数

前面两个方法中都用到了ShowMsg()这个方法了，至于这个方法，很简单了，作用就是在“显示消息”文本框中追加消息而已，为了代码重用就写了个方法，贴上代码：

ShowMsg方法

然后我们来看下【发送按钮】的代码：

发送按钮事件

Send()方法代码：

Send方法

这样我们服务器端就搭建完成了，接下来看看怎么搭建客户端了，，

首先贴上客户端界面的效果：

界面也非常的简单，就是一个【连接服务器】按钮、一个【发送】按钮，一个“显示消息” 框和一个“输入消息” 框。。。

同样我们来看看【连接服务器】按钮的代码：

连接服务器按钮事件

经过了服务器端代码的讲解之后，看客户端的代码应该轻松多了把。。这里同样我们先获取到IP和Port，这里的IP和Port必须和服务器端的一致，当然也有可能服务器的IP是任意IP，这时Port必须和服务器的一致，然后根据IP和Port建立一个网络节点，然后新建一个Socket对象再连接到远程主机，代码和初级版中一样，同样，我们在客户端也利用了线程来持续监听服务器端发来的消息，线程代码一样，不再做赘述，同样是监听RecMsg()方法，那就贴上RecMsg()方法的代码：

RecMsg

代码不多加解释了，和服务器端的一样，差别就是服务器端需要Accetp()方法来监听，然后返回个Socket对象，然后由这个对象来进行通信，客户端就直接用一开始的Socket对象进行通信就可以了，用这个对象首发数据，这里为接收数据，while循环实现，这里也是非主线程操作主线程的控件，所以同样要在窗体构造函数中添加关闭跨线程检测代码：

窗体构造函数

ShowMsg()方法，追加文本：

ShowMsg方法

下面我们要通过点击【发送】按钮实现发送数据，贴上代码：

发送按钮事件

Send()方法代码：

Send方法

发送信息也一样，直接通过SocketClient的Send()方法发送消息就可以了，之前写过几次了，应该都熟悉了吧，，这里就不加叙述了，，，

哈哈，，这样客户端的搭建也完成了，，激动人心的时刻要来了。。。。。。。

下面我们来看看一步一步把整个程序运行起来的效果吧

第一步：开启服务器

点击【启动服务器】按钮：