SuperSocket笔记--协议实现模板

一、通信协议实现中 SuperSocket 提供了一些通用的协议解析工具:

TerminatorReceiveFilter 

CountSpliterReceiveFilter 

FixedSizeReceiveFilter 

BeginEndMarkReceiveFilter 

FixedHeaderReceiveFilter 

二、此处主要记录=>FixedHeaderReceiveFilter 

头部格式固定并且包含内容长度的协议,将一个请求定义为两大部分, 第一部分定义了包含第二部分长度等等基础信息。

(1)例1(文档中的例子):

协议: 头部包含 6 个字节, 前 4 个字节用于存储请求的名字, 后两个字节用于代表请求体的长度,最后是传输包。

request name

(4byte)

length

(2byte)

body

实现这种协议代码:

class MyReceiveFilter : FixedHeaderReceiveFilter<BinaryRequestInfo>
{
    public MyReceiveFilter()
        : base(6)
    {

    }

    protected override int GetBodyLengthFromHeader(byte[] header, int offset, int length)
    {
        return (int)header[offset + 4] * 256 + (int)header[offset + 5];
    }

    protected override BinaryRequestInfo ResolveRequestInfo(ArraySegment<byte> header, byte[] bodyBuffer, int offset, int length)
    {
        return new BinaryRequestInfo(Encoding.UTF8.GetString(header.Array, header.Offset, 4), bodyBuffer.CloneRange(offset, length));
    }
}
  • 传入父类构造函数的 6 表示头部的长度;
  • 方法"GetBodyLengthFromHeader(...)" 应该根据接收到的头部返回请求体的长度;
  • 方法 ResolveRequestInfo(....)" 应该根据你接收到的请求头部和请求体返回你的请求类型的实例.

(2)可以根据自己的需求定义相应的头部格式自定义

头部定义并非固定,可以按照需求添加需要的字节存储一些信息表达如:包的一些属性、时间等。

原文地址:https://www.cnblogs.com/machenghu/p/6441839.html