我们来做一个头为6位报文总长度，并且长度不包含长度域自身的例子。比如这样的Socket报文000006123456。
添加SuperSocket.Engine，直接使用Nuget搜索SuperSocket.Engine安装即可，依赖项为SuperSocket和log4net。
这里注意，SuperSocket 2.0以后没有SuperSocket.Engine了，直接使用SuperSocket即可，但是由于我这次是在.net framework 4.7的环境下使用，SuperSocket 2.0最低支持.net standard 2.1即只能支持.net core已经.net 5 6了，所以这里没法使用。
创建一个ReceiveFilter。
public class LengthReceiveFilter: FixedHeaderReceiveFilter<StringRequestInfo>
{
public LengthReceiveFilter() : base(6)
{
}
protected override int GetBodyLengthFromHeader(byte[] header, int offset, int length)
{
return int.Parse(Encoding.Default.GetString(header, offset, length));
}
protected override StringRequestInfo ResolveRequestInfo(ArraySegment<byte> header, byte[] bodyBuffer, int offset, int length)
{
return new StringRequestInfo("", Encoding.UTF8.GetString(bodyBuffer, offset, length), null);
}
}这里我们需要重写两个方法，以及调用一下父类的构造方法。
public LengthReceiveFilter() : base(6)这里的6代表头长度为6位。
在protected override int GetBodyLengthFromHeader(byte[] header, int offset, int length)方法中，header即为截取到的6位报文头的byte数组，offset是偏移量，length是长度，返回值为报文的总长度。
由于我们报文格式中前六位为数字格式的报文长度，所以我们可以直接用int.Parse(Encoding.Default.GetString(header, offset, length))来获取报文长度，如果长度包含长度本身，那要在-6，这里返回的是报文体的长度，如果返回的长度过长，则会不断的等待后续包。
protected override StringRequestInfo ResolveRequestInfo(ArraySegment<byte> header, byte[] bodyBuffer, int offset, int length)是真正的解析方法，
把我们的报文转换成RequestInfo。这里我们直接用StringRequestInfo，就是把报文简单粗暴的直接转换成字符串。其中header就是我们的报文头的数据，如果这里还需要报文头就从header中拿，bodyBuffer就是我们的报文内容，offset是偏移量，length是长度。
如果我们在GetBodyLengthFromHeader方法中返回的长度比报文体还要长，那么就一直不会走到ResolveRequestInfo这个方法中。
新建一个
MyAppServer继承AppServer
public class MyAppServer : AppServer
{
public MyAppServer() : base(new DefaultReceiveFilterFactory<LengthReceiveFilter,StringRequestInfo>())
{
}
}这里我们直接用DefaultReceiveFilterFactory这个内置的工厂来绑定我们的Filter。
启动服务器
private void button1_Click(object sender, EventArgs e)
{
AppServer appServer = new MyAppServer();
appServer.NewSessionConnected += session =>
{
};
appServer.NewRequestReceived += (session, info) =>
{
MessageBox.Show(info.Body);
session.Send("hello");
session.Close();
};
if (!appServer.Setup(1234))
{
MessageBox.Show("服务器设置失败");
return;
}
if (!appServer.Start())
{
MessageBox.Show("服务器启动失败");
return;
}
}我们可以直接new MyAppServer来创建服务器。Setup方法的参数是端口号，我们使用appServer.Setup(1234)即把SocketServer监听的端口号设置为1234，appServer.Start()正式开启服务器。
appServer.NewSessionConnected是有新客户端连接上来的事件，这时候我们可以给客户端发送欢迎信息，或者执行一些其他操作。
appServer.NewRequestReceived是接收到新消息的事件，我们在这里可以拿到RequestInfo，从而获取到对应的信息。并且可以直接通过Send方法来返回消息。
这里需要注意的是如果Send直接使用字符串重载，那么会使用默认的编码格式，如果报文时UTF-8的，那么建议先用Encoding.UTF8.GetBytes转成byte数组，然后用Send的数组重载来发送内容。
关闭服务器
appServer.Stop();即可关闭服务器。
SuperSocket 1.6 创建一个简易的报文长度在头部的Socket服务器的更多相关文章
- 依赖注入[5]: 创建一个简易版的DI框架[下篇]
为了让读者朋友们能够对.NET Core DI框架的实现原理具有一个深刻而认识,我们采用与之类似的设计构架了一个名为Cat的DI框架.在<依赖注入[4]: 创建一个简易版的DI框架[上篇]> ...
- 依赖注入[4]: 创建一个简易版的DI框架[上篇]
本系列文章旨在剖析.NET Core的依赖注入框架的实现原理,到目前为止我们通过三篇文章(<控制反转>.<基于IoC的设计模式>和< 依赖注入模式>)从纯理论的角度 ...
- .NET CORE学习笔记系列(2)——依赖注入[4]: 创建一个简易版的DI框架[上篇]
原文https://www.cnblogs.com/artech/p/net-core-di-04.html 本系列文章旨在剖析.NET Core的依赖注入框架的实现原理,到目前为止我们通过三篇文章从 ...
- 使用Python创建一个简易的Web Server
Python 2.x中自带了SimpleHTTPServer模块,到Python3.x中,该模块被合并到了http.server模块中.使用该模块,可以快速创建一个简易的Web服务器. 我们在C:\U ...
- 如何使用Java AWT 创建一个简易计算器
摘要:手把手教你使用 Java AWT 创建一个简易计算器. 本文分享自华为云社区<手把手教你使用 Java AWT 创建一个简易计算器>,作者:海拥 . 关于AWT AWT (抽象窗口工 ...
- 用three.js创建一个简易的天空盒
本文创建的天空盒是用六张图片来创建的.笔者会论述两种方法来创建,都是最简单基本的方法,不涉及着色器的使用.一种是创建一个盒子,然后将图片作为盒子6个面的纹理贴上来创建.另一种则是简单的将纹理作为场景的 ...
- .NET CORE学习笔记系列(2)——依赖注入[5]: 创建一个简易版的DI框架[下篇]
为了让读者朋友们能够对.NET Core DI框架的实现原理具有一个深刻而认识,我们采用与之类似的设计构架了一个名为Cat的DI框架.在上篇中我们介绍了Cat的基本编程模式,接下来我们就来聊聊Cat的 ...
- Unity创建一个简易的弹簧(弹动)效果
参考文章:http://www.cnblogs.com/SkyD/archive/2008/09/05/1284778.html 主要依据胡克公式F=-k·x.这里k是倔度系数,可以理解为k值越大弹性 ...
- python基础[18]——使用django创建一个简易的博客网站
一.页面实现 index.html base.html post.html header.html footer.html <!-- index.html--> {% extends 'b ...
- TCP/TP编程 - 一个简单的Linux下C写的socket服务器客户端程序
服务端: hello_server.c #include <stdio.h> #include <stdlib.h> #include <string.h> #in ...
随机推荐
- Struts2 Action与Servlet API耦合
单元测试在开发中是非常重要的一个环节程序员在写完代码时,相应的单元测试也应写完整,否则你的代码就是不能让人信服的Struts2将Action与Servlet的API进行解耦之后,就使得单元测试变得非常 ...
- 【转】struct和typedef struct
原文:http://www.cnblogs.com/qyaizs/articles/2039101.html 分三块来讲述: 1 首先://注意在C和C++里不同 在C中定义一个结构体类型要用type ...
- Nginx - Core Module Directives
The following is the list of directives made available by the Core module. Most of these directives ...
- gcc链接g++编译生成的静态库和动态库的makefile示例
使用c++开发程序或者库时,将库提供给其他人使用. 然而使用者是使用c开发的程序,链接g++编译生成的库时,于链接gcc生成的库,有所不同. 首先是静态库,以链接g++编译生成的libmylib.a为 ...
- Python -- OOP高级 -- __slots__、@property
__slots__属性可以设置 允许被设置的属性 class Student: __slots__ = ("name", "age") >>> ...
- Spark环境搭建（四）-----------数据仓库Hive环境搭建
Hive产生背景 1)MapReduce的编程不便,需通过Java语言等编写程序 2) HDFS上的文缺失Schema(在数据库中的表名列名等),方便开发者通过SQL的方式处理结构化的数据,而不需要J ...
- LoadRunner Vuser接口测试脚本 Post举例
发送内容为JSON的POST请求需要加入"EncType=application/json",表单参数不需要.(JAVA API) // POST接口调用 web.custom_r ...
- HDU 1573 X问题（中国剩余定理标准解法）
X问题 Time Limit: 1000/1000 MS (Java/Others) Memory Limit: 32768/32768 K (Java/Others) Total Submis ...
- MySQL中char、varchar和nvarchar的区别
一.char和varchar的区别char是固定长度的,而varchar会根据具体的长度来使用存储空间,另外varchar需要用额外的1-2个字节存储字符串长度.1). 当字符串长度小于255时,用额 ...
- Microsoft.Net 版本
Date Framework Visual Studio C# CLR 2002.2 1.0 Visual Studio 2002 1.0 1.0 2003.4 1.1 Visual Studio 2 ...
![Explain in detail the matrix normalization function normalize() of OpenCV [norm or value range of the scoped matrix (normalization)], and attach norm_ Example code in the case of minmax](/img/87/3fee9e6f687b0c3efe7208a25f07f1.png)
