编程语言
首页 > 编程语言> > C# SuperSocket利用FixedHeaderReceiveFilter或BeginEndMarkReceiveFilter进行通信

C# SuperSocket利用FixedHeaderReceiveFilter或BeginEndMarkReceiveFilter进行通信

作者:互联网

        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)

标签:协议,SuperSocket,C#,报文,FixedHeaderReceiveFilter,粘包,消息,byte
来源: https://blog.csdn.net/ba_wang_mao/article/details/118789926