本文源代码下载
上一章我们讲到了如何用TcpListener侦听连接以及如何使用TcpClient建立一个连接并发送消息。
这一章我们将深入讲解如何定义网络通迅协议及如何使用这个协议进行通迅。
首先我们先重构一下前章提到的网络通迅组件。
我们知道在服务器端和客户端都要侦听是否对方发来消息，如果只在主线程中运行，那我们就没法进行其它如UI等方面的工作了。我们将Listen这个方法提出来放到一个基类中。
新建一个类SocketBase。让Server和Client两个类都继承自这个类。将Server类中的Connections属性放到这个类中（因为Client中也可能有多个连接），由于客户端也要侦听
服务器发来的消息，因此我们将_listenningthread和Listenning函数也放到类中。并把private型的变量改为protected以便于继承类可以使用。将Listening函数改为virtual型
以便于子类中可以重写。
下面我们定义网络协议如下：
一个消息体包含消息头和消息体两部分。消息体为字符串型。
消息头包含3部分，前4个字节为消息的总长度，第5个字节表示命令，第6、7两个字节表示协议版本号。按此协议，我们定义Message类，源代码如下：
2
3
4
我们在Message中增加一个Connection类型的变量是用于存放是要发送的目的或从哪个连接收到的消息。
由于我们在向网络流写入的时候需要写入的是byte数组。我们给Message类增加一个ToBytes方法。返回一个字节数组。
我们再写一个继承自CollectionBase的类MessageCollection。用于存放消息队列。
2
3
4
好了。协议制定完了，下面我们修改SocketBase的Listenning函数。当网络流可读时，我们就读出一个message格式的消息。并且在SocketBase中定义ConnectionClose、MessageReceived事件。
并且在SocketBase的Listenning中根据情况触发。
再在SocketBase中增加一个MessageConnection型的属性。表示要发送的消息队列。
我们需要再启动一个线程。用于从消息队列中取出要发送的消息并发送。
最后源代码如下。在这个源代码中在停止时我们没有关闭网络连接。请自行关闭。
在最后的优化中，上面提到的源代码做了一定的修改，请从本文顶端下载源代码查看