SuperSocket 是一个轻量级, 跨平台而且可扩展的 .Net/Mono Socket 服务器程序框架。你无须了解如何使用 Socket, 如何维护 Socket 连接和 Socket 如何工作，我们可以有更多的时间用在业务逻辑上，SuperSocket有效的利用自己的协议解决粘包及各种事件通知机制。

        GitHub地址：https://github.com/kerryjiang/SuperSocket

一、实现功能

• 心跳检测
• 断线重连
• 粘包组包

二、粘包

        一般所谓的TCP粘包是在一次接收数据不能完全地体现一个完整的消息数据。TCP通讯存在粘包的主要原因是TCP是以流的方式来处理数据，所以就会引发一次接收的数据无法满足消息的需要，导致粘包的存在。处理粘包的唯一方法就是制定应用层的数据通讯协议，通过协议来规范现有接收的数据是否满足消息数据的需要。

        解决办法：

1. 消息定长：报文大小固定长度，不够空格补全，发送和接收方遵循相同的约定，这样即使粘包了通过接收方编程实现获取定长报文也能区分。
2. 包尾添加特殊分隔符：例如每条报文结束都添加回车换行符（例如FTP协议）或者指定特殊字符作为报文分隔符，接收方通过特殊分隔符切分报文区分。
3. 将消息分为消息头和消息体：消息头中包含表示信息的总长度（或者消息体长度）的字段

        SuperSocket中的常用内置协议：

• TerminatorReceiveFilter：结束符协议
• CountSpliterReceiveFilter：固定数量分隔符协议
• FixedSizeReceiveFilter：固定请求大小的协议
• BeginEndMarkReceiveFilter：带起止符的协议
• FixedHeaderReceiveFilter：头部格式固定并且包含内容长度的协议

三、SuperSocket解决粘包说明

1、FixedHeaderReceiveFilter 将消息分为消息头和消息体来解决粘包问题

//数据格式：
//  -------+----------+------------------------------------------------------+
//  0001   | 0010     |  5412 0234 0001 0543 06215 04312 06542               |
//  请求名  | 数据长度  |  数据                                                |
//  -------+----------+------------------------------------------------------+

实现自定义的FixedHeaderReceiveFilter需要实现GetBodyLengthFromHeader与ResolveRequestInfo方法

2、BeginEndMarkReceiveFilter即为带起止符的协议

//数据格式：
//  -------+----------+------------------------------------------------------+
//  8787   |   4C36 3150 2D43 4D2B 4C30 3643 5055 2D43 4D2B 4C 4A   |  8989  |
//  固定头  |   数据                                                 |  固定尾 |
//  -------+----------+------------------------------------------------------+

public class AlgReceiveFilter : BeginEndMarkReceiveFilter<StringRequestInfo>
    {
        //开始和结束标记也可以是两个或两个以上的字节
        private readonly static byte[] BeginMark = new byte[] { (byte)'#' };
        private readonly static byte[] EndMark = new byte[] { (byte)'@' };

        public AlgReceiveFilter()
        : base(BeginMark, EndMark) //传入开始标记和结束标记
        {

        }

        protected override StringRequestInfo ProcessMatchedRequest(byte[] readBuffer, int offset, int length)
        {
            //通过解析到的数据来构造请求实例，并返回
            var totalBuffer = readBuffer.Skip(offset).Take(length).ToArray();
            var str = System.Text.Encoding.UTF8.GetString(totalBuffer);
            var body = str.Trim('#', '@');
            return new StringRequestInfo("", body, null);
        }
    }

SuperSocketDemo - 编程乐园 (errornoerror.com)