이 글에서는 주로 일반적인 프로토콜 구현 템플릿과 FixSizeReceiveFilter 예제를 소개합니다. 매우 좋은 참조 값을 가지고 있으므로 아래 편집기로 살펴보겠습니다
소켓의 프로토콜 분석은 소켓 통신 프로그래밍에서 가장 복잡한 부분입니다. 애플리케이션 계층 프로토콜이 잘못 설계되거나 구현된 경우 소켓 통신에서는 고정 패킷이 일반적이므로 하위 패키징은 불가피합니다. Super소켓에는 명령줄 형식 프로토콜 CommandLineProtocol이 내장되어 있습니다. 다른 형식의 프로토콜을 사용하는 경우 사용자 정의 프로토콜 CustomProtocol을 직접 구현해야 합니다. 문서를 읽은 후 SuperSocket을 사용하여 사용자 정의 프로토콜을 구현하는 것이 간단하지 않다고 느낄 수 있습니다. 이를 더 쉽게 하기 위해 SuperSocket은 몇 가지 일반 프로토콜 구문 분석 도구를 제공하며, 이를 사용하여 자신의 통신 프로토콜을 간단하고 빠르게 구현할 수 있습니다.
TerminatorReceiveFilter (SuperSocket.SocketBase .Protocol.TerminatorReceiveFilter, SuperSocket.SocketBase) --- 터미네이터 프로토콜
CountSpliterReceiveFilter (SuperSocket.Facility.Protocol.CountSpliterReceiveFilter, SuperSocket.Facility)---수정됨 숫자 구분 기호 프로토콜
FixedSizeReceiveFilter (SuperSocket.Facility.Protocol.FixedSizeReceiveFilter, SuperSocket.Facility)---고정 요청 크기 프로토콜
BeginEndMarkReceiveFilter (SuperSocket.Facility.Protocol.BeginEndMarkReceiveFilter, SuperSocket.Facility)---시작 및 끝 문자가 있는 프로토콜
FixedHeaderReceiveFilter (SuperSocket.Facility.Protocol.FixedHeaderReceiveFilter, SuperSocket.Facility)---헤더 형식은 고정되어 있으며 콘텐츠 길이 프로토콜을 포함합니다
1. TerminatorReceiveFilter 터미네이터 프로토콜
터미네이터 프로토콜은 명령줄 프로토콜과 유사합니다. 일부 프로토콜은 요청을 결정하기 위해 터미네이터를 사용합니다. 예를 들어 프로토콜은 두 문자 "##"을 터미네이터로 사용하므로 클래스를 사용할 수 있습니다. "TerminatorReceiveFilterFactory":
Terminator 프로토콜 TerminatorProtocolServer:
public class TerminatorProtocolServer : AppServer
{
public TerminatorProtocolServer()
: base(new TerminatorReceiveFilterFactory("##"))
{
}
}TerminatorReceiveFilterFilter(ReceiveFilter):
public class YourReceiveFilter : TerminatorReceiveFilter<YourRequestInfo>
{
//More code
}수신 필터 팩토리를 구현합니다. (ReceiveFilterFactory) 허용 필터 인스턴스 생성:
public class YourReceiveFilterFactory : IReceiveFilterFactory<YourRequestInfo>
{
//More code
}2. CountSpliterReceiveFilter 고정 숫자 구분 프로토콜
일부 프로토콜 정의 "#part1#part2#part3 형식의 요청 #part4#part5#part6#part7#". 각 요청은 '#'으로 구분된 7개의 부분으로 구성됩니다. 이 프로토콜의 구현은 매우 간단합니다:
/// <summary>
/// 请求格式：#part1#part2#part3#part4#part5#part6#part7#
/// </summary>
public class CountSpliterAppServer : AppServer
{
public CountSpliterAppServer()
: base(new CountSpliterReceiveFilterFactory((byte)'#', 8)) //8个分隔符，7个参数。除使用默认的过滤工厂，还可以参照上一个实例定制协议
{
}
}3. FixedSizeReceiveFilter 고정 요청 크기 프로토콜
이 프로토콜에서는 모든 요청의 크기가 동일합니다. 각 요청이 "HUANG LI"와 같은 8자 문자열 인 경우 다음 코드를 사용하여 수신 필터(ReceiveFilter)를 구현해야 합니다.
class MyReceiveFilter : FixedSizeReceiveFilter<StringRequestInfo>
{
public MyReceiveFilter()
: base(8) //传入固定的请求大小
{
}
protected override StringRequestInfo ProcessMatchedRequest(byte[] buffer, int offset, int length, bool toBeCopied)
{
//TODO: 通过解析到的数据来构造请求实例，并返回
}
}그런 다음 AppServer 클래스에서 다음 허용 필터(ReceiveFilter)를 사용하세요.
public class MyAppServer : AppServer
{
public MyAppServer()
: base(new DefaultReceiveFilterFactory<MyReceiveFilter, StringRequestInfo>()) //使用默认的接受过滤器工厂 (DefaultReceiveFilterFactory)
{
}
}4. 시작 및 끝 문자가 있는 BeginEndMarkReceiveFilter 프로토콜
이 유형에서는 프로토콜의 각 요청에 고정된 시작 및 끝 태그. 예를 들어, 모든 메시지가 "&xxxxxxxxxxxxxx#" 형식을 따르는 프로토콜이 있습니다. 따라서 이 경우 "&"는 여는 태그이고 "#"은 닫는 태그이므로 수락 필터는
class MyReceiveFilter : BeginEndMarkReceiveFilter<StringRequestInfo>
{
//开始和结束标记也可以是两个或两个以上的字节
private readonly static byte[] BeginMark = new byte[] { (byte)'&' };
private readonly static byte[] EndMark = new byte[] { (byte)'#' };
public MyReceiveFilter()
: base(BeginMark, EndMark) //传入开始标记和结束标记
{
}
protected override StringRequestInfo ProcessMatchedRequest(byte[] readBuffer, int offset, int length)
{
//TODO: 通过解析到的数据来构造请求实例，并返回
}
}와 같이 정의할 수 있으며 AppServer 클래스 필터( ReceiverFilter):
public class MyAppServer : AppServer
{
public MyAppServer()
: base(new DefaultReceiveFilterFactory<MyReceiveFilter, StringRequestInfo>()) //使用默认的接受过滤器工厂 (DefaultReceiveFilterFactory)
{
}
}5. FixHeaderReceiveFilter 헤더 형식은 고정되어 있으며 콘텐츠 길이 프로토콜을 포함합니다.
이 프로토콜은 요청을 두 부분으로 정의합니다. 첫 번째 부분은 기본을 정의합니다. 우리는 일반적으로 첫 번째 부분을 헤더라고 부릅니다.
예를 들어 다음과 같은 프로토콜이 있습니다. 헤더에는 6바이트가 포함되고 처음 4바이트는 저장하는 데 사용됩니다. 요청 이름, 마지막 2바이트는 요청 본문의 길이를 나타내는 데 사용됩니다.
/// +-------+---+-------------------------------+ /// |request| l | | /// | name | e | request body | /// | (4) | n | | /// | |(2)| | /// +-------+---+-------------------------------+
SuperSocket을 사용하면 이 프로토콜을 매우 편리하게 구현할 수 있습니다.
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));
}
}FixedHeaderReceiveFilter 클래스는 자신의 수신 필터를 구현합니다.
상위 클래스 생성자 를 전달합니다. 6은 헤더의 길이를 나타냅니다. >
이제 다섯 가지 프로토콜의 템플릿에 대해 배웠고 관련 형식 처리를 알았습니다. 다음으로 네트워크 예를 살펴보겠습니다.
통신 프로토콜 형식:
在看到上图协议是在纠结客户端发送16进制，服务器怎么接收，16进制的报文如下：
26 01 00 19 4E 4A 30 31 31 01 44 41 31 31 32 00 07 00 00 00 00 00 00 34 23
16进制也好，10进制也好，其他的进制也好，最终都是转换成byte[]，其实在处理数据时，发送过去的数据都是可以转换成为byte[]的，所以服务的只要解析byte[]数组就行了。按照协议来解析就能得到想要的数据。下面使用FixedSizeReceiveFilter的例子，代码如下：
根据上面的通讯协议，开始来实现解析：
第一步、定义一个和协议合适的数据结构
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-23 21:12:30
* 2017
* 描述说明：协议数据包
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
public class HLData
{
/// <summary>
/// 开始符号
/// </summary>
public char Head { get; set; }
/// <summary>
/// 协议包数据
/// </summary>
public byte Ping { get; set; }
/// <summary>
/// 数据长度
/// </summary>
public ushort Lenght { get; set; }
/// <summary>
/// 终端ID
/// </summary>
public uint FID { get; set; }
/// <summary>
/// 目标类型
/// </summary>
public byte Type { get; set; }
/// <summary>
/// 转发终端ID
/// </summary>
public uint SID { get; set; }
/// <summary>
/// 发送计数
/// </summary>
public ushort SendCount { get; set; }
/// <summary>
/// 保留字段
/// </summary>
public byte[] Retain { get; set; }
/// <summary>
/// 异或校验
/// </summary>
public byte Check { get; set; }
/// <summary>
/// 结束符号
/// </summary>
public char End { get; set; }
public override string ToString()
{
return string.Format("开始符号:{0},包数据:{1},数据长度:{2},终端ID:{3},目标类型:{4},转发终端ID:{5},发送包计数：{6},保留字段:{7},异或校验:{8},结束符号:{9}",
Head, Ping, Lenght, FID, Type, SID, SendCount, Retain, Check, End);
}
}
}
HLData第二步、建立一个RequestInfo来给server数据接收
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SuperSocket.SocketBase.Protocol;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-22 21:03:31
* 2017
* 描述说明：数据请求
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
public class HLProtocolRequestInfo : RequestInfo<HLData>
{
public HLProtocolRequestInfo(HLData hlData)
{
//如果需要使用命令行协议的话，那么命令类名称HLData相同
Initialize("HLData", hlData);
}
}
}
HLProtocolRequestInfo 类第三步、FixedSize协议解析
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SuperSocket.SocketBase.Protocol;
using SuperSocket.Facility.Protocol;
using SuperSocket.Common;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-22 21:06:01
* 2017
* 描述说明：协议解析类，固定请求大小的协议
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
/// <summary>
/// 固定请求大小的协议,(帧格式为HLProtocolRequestInfo)
/// </summary>
public class HLProtocolReceiveFilter : FixedSizeReceiveFilter<HLProtocolRequestInfo>
{
public HLProtocolReceiveFilter() : base(25)//总的字节长度 1+1+2+5+1+5+2+6+1+1 = 25
{
}
protected override HLProtocolRequestInfo ProcessMatchedRequest(byte[] buffer, int offset, int length, bool toBeCopied)
{
var HLData = new HLData();
HLData.Head = (char)buffer[offset];//开始标识的解析，1个字节
HLData.Ping = buffer[offset + 1];//数据，从第2位起，只有1个字节
HLData.Lenght = BitConverter.ToUInt16(buffer, offset + 2);//数据长度，从第3位开始，2个字节
HLData.FID = BitConverter.ToUInt32(buffer, offset + 4);//本终端ID，从第5位开始，5个字节
HLData.Type = buffer[offset + 9];//目标类型，从第10位开始，1个字节
HLData.SID = BitConverter.ToUInt32(buffer, offset + 10);//转发终端ID，从第11位开始，5个字节
HLData.SendCount = BitConverter.ToUInt16(buffer, offset + 15);//发送包计数，从第16位开始，2个字节
HLData.Retain = buffer.CloneRange(offset + 17, 6);//保留字段，从18位开始，6个字节
HLData.Check = buffer[offset + 23];//异或校验，从24位开始，1个字节
HLData.End = (char)buffer[offset + 24];//结束符号，从第25位开始，一个字节
return new HLProtocolRequestInfo(HLData);
}
}
}
HLProtocolReceiveFilter类第四步、建立协议工厂HLReceiveFilterFactory
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System.Net;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-23 :22:01:25
* 2017
* 描述说明：协议工厂
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
public class HLReceiveFilterFactory: IReceiveFilterFactory<HLProtocolRequestInfo>
{
public IReceiveFilter<HLProtocolRequestInfo> CreateFilter(IAppServer appServer, IAppSession appSession, IPEndPoint remoteEndPoint)
{
return new HLBeginEndMarkReceiveFilter();
}
}
}
HLReceiveFilterFactory类第五步、自定义HLProtocolSession继承AppSession
using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-22 21:15:11
* 2017
* 描述说明：自定义HLProtocolSession
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
public class HLProtocolSession : AppSession<HLProtocolSession, HLProtocolRequestInfo>
{
protected override void HandleException(Exception e)
{
}
}
}
HLProtocolSession类第六步、自定义HLProtocolServer继承AppServer
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-22 21:16:57
* 2017
* 描述说明：自定义server
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
public class HLProtocolServer : AppServer<HLProtocolSession, HLProtocolRequestInfo>
{
/// <summary>
/// 使用自定义协议工厂
/// </summary>
public HLProtocolServer()
: base(new HLReceiveFilterFactory())
{
}
}
}
HLProtocolServer类第七步、加上起止符协议HLBeginEndMarkReceiveFilter
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SuperSocket.Common;
using SuperSocket.Facility.Protocol;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-23 22:07:03
* 2017
* 描述说明：带起止符的协议， "&" 是开始标记， "#" 是结束标记，开始结束标记由自己定义
*
* 修改历史：
*
*
*****************************************************************/
namespace SuperSocketDemo
{
public class HLBeginEndMarkReceiveFilter : BeginEndMarkReceiveFilter<HLProtocolRequestInfo>
{
private readonly static char strBegin = '&';
private readonly static char strEnd = '#';
//开始和结束标记也可以是两个或两个以上的字节
private readonly static byte[] BeginMark = new byte[] { (byte)strBegin };
private readonly static byte[] EndMark = new byte[] { (byte)strEnd };
public HLBeginEndMarkReceiveFilter() : base(BeginMark, EndMark)
{
}
/// <summary>
/// 这里解析的到的数据是会把头和尾部都给去掉的
/// </summary>
/// <param name="readBuffer"></param>
/// <param name="offset"></param>
/// <param name="length"></param>
/// <returns></returns>
protected override HLProtocolRequestInfo ProcessMatchedRequest(byte[] readBuffer, int offset, int length)
{
var HLData = new HLData();
HLData.Head = strBegin;//自己定义开始符号
HLData.Ping = readBuffer[offset];//数据，从第1位起，只有1个字节
HLData.Lenght = BitConverter.ToUInt16(readBuffer, offset + 1);//数据长度，从第2位开始，2个字节
HLData.FID = BitConverter.ToUInt32(readBuffer, offset + 3);//本终端ID，从第4位开始，5个字节
HLData.Type = readBuffer[offset + 8];//目标类型，从第9位开始，1个字节
HLData.SID = BitConverter.ToUInt32(readBuffer, offset + 9);//转发终端ID，从第10位开始，5个字节
HLData.SendCount = BitConverter.ToUInt16(readBuffer, offset + 14);//发送包计数，从第15位开始，2个字节
HLData.Retain = readBuffer.CloneRange(offset + 16, 6);//保留字段，从17位开始，6个字节
HLData.Check = readBuffer[offset + 22];//异或校验，从23位开始，1个字节
HLData.End = strEnd;//结束符号，自己定义
return new HLProtocolRequestInfo(HLData);
}
}
}
HLBeginEndMarkReceiveFilter类第八步、服务启动和停止
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using SuperSocket.SocketEngine;
/****************************************************************
* 作者:黄昏前黎明后
* CLR版本：4.0.30319.42000
* 创建时间：2017-01-19 00:02:17
* 2017
* 描述说明：服务启动和停止入口
*
* 修改历史： 2017 -01-19 调整自定义mysession和myserver
* 2017 -01-23 通讯协议解析，直接使用入口注册事件
*
*****************************************************************/
namespace SuperSocketDemo
{
class Program
{
/// <summary>
/// SuperSocket服务启动或停止
/// </summary>
/// <param name="args"></param>
static void Main(string[] args)
{
Console.WriteLine("请按任何键进行启动SuperSocket服务!");
Console.ReadKey();
Console.WriteLine();
var HLProtocolServer = new HLProtocolServer();
// 设置端口号
int port = 2017;
//启动应用服务端口
if (!HLProtocolServer.Setup(port)) //启动时监听端口2017
{
Console.WriteLine("服务端口启动失败!");
Console.ReadKey();
return;
}
Console.WriteLine();
//注册连接事件
HLProtocolServer.NewSessionConnected += HLProtocolServer_NewSessionConnected;
//注册请求事件
HLProtocolServer.NewRequestReceived += HLProtocolServer_NewRequestReceived;
//注册Session关闭事件
HLProtocolServer.SessionClosed += HLProtocolServer_SessionClosed;
//尝试启动应用服务
if (!HLProtocolServer.Start())
{
Console.WriteLine("服务启动失败!");
Console.ReadKey();
return;
}
Console.WriteLine("服务器状态:" + HLProtocolServer.State.ToString());
Console.WriteLine("服务启动成功，请按'E'停止服务!");
while (Console.ReadKey().KeyChar != 'E')
{
Console.WriteLine();
continue;
}
//停止服务
HLProtocolServer.Stop();
Console.WriteLine("服务已停止!");
Console.ReadKey();
}
static void HLProtocolServer_SessionClosed(HLProtocolSession session, SuperSocket.SocketBase.CloseReason value)
{
Console.WriteLine(session.RemoteEndPoint.ToString() + "连接断开. 断开原因:" + value);
}
static void HLProtocolServer_NewSessionConnected(HLProtocolSession session)
{
Console.WriteLine(session.RemoteEndPoint.ToString() + " 已连接.");
}
/// <summary>
/// 协议并没有什么太多复杂逻辑，不需要用到命令模式，直接用这种方式就可以了
/// </summary>
/// <param name="session"></param>
/// <param name="requestInfo"></param>
private static void HLProtocolServer_NewRequestReceived(HLProtocolSession session, HLProtocolRequestInfo requestInfo)
{
Console.WriteLine();
Console.WriteLine("数据来源: " + session.RemoteEndPoint.ToString());
Console.WriteLine("接收数据内容："+requestInfo.Body);
}
}
}
Program类通讯协议需要使用小工具进行调试，本人使用的是TCP/UDP端口调试工具SocketTool V2.大家可以直接进行下载。使用HEX模式进行发送16进制报文，服务器输出结果：
위 내용은 C# 공통 프로토콜 구현 템플릿과 FixedSizeReceiveFilter의 샘플 코드에 대한 자세한 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
