框架介绍

名称

地址

描述

Gitee

Github

RRQMSocket是一个整合性的、超轻量级的网络通信框架。

包含了TCP、UDP、Ssl、Channel、Protocol、Token、

租户模式等一系列的通信模块。其扩展组件包含：WebSocket、

大文件传输、RPC、WebApi、XmlRpc、JsonRpc等内容

Gitee

Github

RRQMSocketFramework是RRQMSocket系列的增强企业版，

两者在基础功能上没有区别，但是在扩展功能上有一定差异性，

例如RPC中的EventBus、文件传输中的限速功能等，

具体差异请看RRQM商业运营

Gitee

Github

RRQMCore是为RRQM系提供基础服务功能的库，其中包含：

内存池、对象池、等待逻辑池、AppMessenger、3DES加密、

Xml快速存储、运行时间测量器、文件快捷操作、

高性能序列化器、规范日志接口等。

Gitee

Github

RRQMSocket.WebSocket是一个高效，超轻量级的WebSocket框架。

它包含了Service和Client两大组件，支持Ssl，同时定义了文本、二进制或

其他类型数据的快捷发送、分片发送接口，可与js等任意WebSocket组件交互

Gitee

Github

RRQMSocket.Http是一个能够简单解析Http的服务组件，

能够快速响应Http服务请求。

Gitee

Github

RPC是一个超轻量、高性能、可扩展的微服务管理平台框架，

目前已完成开发RRQMRPC、XmlRpc、JsonRpc、WebApi部分。

RRQMRPC部分使用RRQM专属协议，支持客户端异步调用，

服务端异步触发、以及out和ref关键字，函数回调等。

在调用效率上也是非常强悍，在调用空载函数，且返回状态时，

10w次调用仅用时3.8秒，不返回状态用时0.9秒。

其他协议调用性能详看性能评测。

Gitee

Github

XmlRpc是一个扩展于RRQMSocket.RPC的XmlRpc组件，可以通过

该组件创建XmlRpc服务解析器，完美支持XmlRpc数据类型，类型嵌套，

Array等，也能与CookComputing.XmlRpcV2完美对接。

不限Web，Android等平台。

Gitee

Github

JsonRpc是一个扩展于RRQMSocket.RPC的JsonRpc组件，

可以通过该组件创建JsonRpc服务解析器，支持JsonRpc全部功能，可与Web，Android等平台无缝对接。

Gitee

Github

WebApi是一个扩展于RRQMSocket.RPC的WebApi组件，可以通过

该组件创建WebApi服务解析器，让桌面端、Web端、移动端可以

跨语言调用RPC函数。功能支持路由、Get传参、Post传参等。

Gitee

Github

这是一个高性能的C/S架构的文件传输框架，您可以用它传输

任意大小的文件，它可以完美支持上传下载混合式队列传输、

断点续传、 快速上传 、传输限速、获取文件信息、删除文件等。

在实际测试中，它的传输速率可达1000Mb/s。

支持环境.NET Framework4.5及以上。.NET Core3.1及以上。.NET Standard2.0及以上。支持框架WPFWinformBlazorXamarinMonoUnity（在IL2cpp编译时，需要导入源码，Mono则直接加载dll即可）RRQMSocket特点速览传统IOCP和RRQMSocket

RRQMSocket的IOCP和传统也不一样，就以微软官方示例为例，使用MemoryBuffer开辟一块内存，均分，然后给每个会话分配一个区接收，等收到数据后，再复制源数据，然后把复制的数据进行处理。而RRQMSocket是每次接收之前，从内存池拿一个可用内存块，然后直接用于接收，等收到数据以后，直接就把这个内存块抛出处理，这样就避免了复制操作，虽然只是细小的设计，但是在传输1000w次64kb的数据时，性能相差了10倍。

数据处理适配器

相信大家都使用过其他的Socket产品，那么RRQMSocket在设计时也是借鉴了其他产品的优秀设计理念，数据处理适配器就是其中之一，但和其他产品的设计不同的是，RRQMSocket的适配器功能更加强大，它不仅可以提前解析数据包，还可以解析数据对象。例如：可以使用固定包头对数据进行预处理，从而解决数据分包、粘包的问题。也可以直接解析HTTP数据协议、WebSocket数据协议等。

兼容性与适配

RRQMSocket提供多种框架模型，能够完全兼容基于TCP、UDP协议的所有协议。例如：TcpService与TcpClient，其基础功能和Socket一模一样，只是增强了框架的坚固性和并发性，将连接和接收数据通过事件的形式抛出，让使用者能够更加友好的使用。

简单示例

以下仅以最简方式创建示例，更多详情请查看说明文档。

【TcpService】

TcpService service = new TcpService();service.Connecting += (client, e) => { };//有客户端正在连接service.Connected += (client, e) => { };//有客户端连接service.Disconnected += (client, e) => { };//有客户端断开连接service.Received += (client, byteBlock, requestInfo) =>{    //从客户端收到信息    string mes = byteBlock.ToString();    Console.WriteLine($"已从{client.ID}接收到信息：{mes}");    client.Send(mes);//将收到的信息直接返回给发送方    //client.Send("id",mes);//将收到的信息返回给特定ID的客户端    var clients = service.GetClients();    foreach (var targetClient in clients)//将收到的信息返回给在线的所有客户端。    {        if (targetClient.ID != client.ID)        {            targetClient.Send(mes);        }    }};service.Setup(new RRQMConfig()//载入配置         .SetListenIPHosts(new IPHost[] { new IPHost("127.0.0.1:7789"), new IPHost(7790) })//同时监听两个地址    .SetMaxCount(10000)    .SetThreadCount(100))    .Start();//启动

【TcpClient】

TcpClient tcpClient = new TcpClient();tcpClient.Connected += (client, e) => { };//成功连接到服务器tcpClient.Disconnected += (client, e) => { };//从服务器断开连接，当连接不成功时不会触发。tcpClient.Received += (client, byteBlock, requestInfo) =>{    //从服务器收到信息    string mes = Encoding.UTF8.GetString(byteBlock.Buffer, 0, byteBlock.Len);    Console.WriteLine($"接收到信息：{mes}");};//声明配置RRQMConfig config = new RRQMConfig();config.SetRemoteIPHost(new IPHost("127.0.0.1:7789"))    .UsePlugin()    .SetBufferLength(1024 * 10);//载入配置tcpClient.Setup(config);tcpClient.Connect();tcpClient.Send("RRQM");

【TcpClient 断线重连】

tcpClient.UseReconnection(tryCount:5,printLog:true);

【FixedHeaderPackageAdapter包模式】

该适配器主要解决TCP粘分包问题，数据格式采用简单而高效的“包头+数据体”的模式，其中包头支持：

Byte模式（1+n），一次性最大接收255字节的数据。Ushort模式（2+n），一次最大接收65535字节。Int模式（4+n），一次最大接收2G数据。

以上数据头均采用RRQMBitConverter的默认端模式（小端模式），使用者可以根据需求切换默认端模式。

RRQMBitConverter.DefaultEndianType = EndianType.Little;

【CustomFixedHeaderDataHandlingAdapter】

用户自定义固定包头适配器，主要帮助用户解决具有固定包头的数据帧信息。例如：下列数据格式，仅需要实现几个接口，就能完成解析，详细操作请参照API。

|1|1|1|**********|

【CustomUnfixedHeaderDataHandlingAdapter】

用户自定义不固定包头适配器，主要帮助用户解决具有包头不固定的数据帧信息。例如：最典型的HTTP数据包，其数据头和数据体由“\r\n”隔开，而数据头又因为请求者的请求信息的不同，头部数据也不固定，而数据体的长度，也是由数据头的ContentLength的值显式指定的，所以可以考虑使用CustomUnfixedHeaderDataHandlingAdapter解析，也是仅通过简单的开发，就能实现。

【Ssl加密】

在RRQMBox中，放置了一个自制Ssl证书，密码为“RRQMSocket”以供测试。使用配置非常方便。

在服务器中只需设置配置SslOption属性和接收模式。

服务器配置

config.SetServerSslOption(new ServiceSslOption() { Certificate = new X509Certificate2("RRQMSocket.pfx", "RRQMSocket"), SslProtocols = SslProtocols.Tls12 });

客户端配置

config.SetClientSslOption(new ClientSslOption(){    ClientCertificates = new X509CertificateCollection() { new X509Certificate2("RRQMSocket.pfx", "RRQMSocket") },    SslProtocols = SslProtocols.Tls12,    TargetHost = "127.0.0.1",    CertificateValidationCallback = (sender, certificate, chain, sslPolicyErrors) => { return true; }});

【Http服务器】

HttpService支持Https协议、静态页面、WebSocket、JsonRpc、XmlRpc、WebApi插件的挂载。

var service = new HttpService();service.AddPlugin<MyHttpPlug>();service.AddPlugin<HttpStaticPagePlugin>().   AddFolder("../../../../../api");//添加静态页面service.AddPlugin<WebSocketServerPlugin>().//添加WebSocket功能   SetTimeout(10 * 1000).   SetWSUrl("/ws").   SetCallback(WSCallback);service.AddPlugin<MyWebSocketPlugin>();//添加WS事务触发。service.AddPlugin<MyWSCommandLinePlugin>();//添加WS命令行事务。var config = new RRQMConfig();config.UsePlugin()    .SetReceiveType(ReceiveType.Auto)    .SetListenIPHosts(new IPHost[] { new IPHost(7789) });service.Setup(config).Start();Console.WriteLine("Http服务器已启动");Console.WriteLine("浏览器访问：;);Console.WriteLine("WS访问：ws://127.0.0.1:7789/ws");

【WebSocket客户端】

WSClient myWSClient = new WSClient();myWSClient.Setup("ws://127.0.0.1:7789/ws");myWSClient.Connect();Console.WriteLine("连接成功");Console.WriteLine("连接成功");while (true){    myWSClient.SendWithWS(Console.ReadLine());}

【RPC调用】

WebApi：下列服务，可让浏览器通过url/XUnitTestServer/Sum?a=10&b=20来调用，结果可选xml或json。JsonRpc：下列服务，可让普通TCP使用{"jsonrpc":"2.0","method":"Sum","params":[10，20],"id":1}来调用，也能让web通过http/https来调用。xmlRpc：下列服务，可通过http+xml的形式调用。RRQMRPC：使用专有协议调用。

[Route("/[controller]/[action]")]public class XUnitTestServer : ControllerBase{    [XmlRpc]    [JsonRpc]    [Route]    [RRQMRPC]    public int Sum(int a, int b)    {        return a + b;    }}

想要源码，请记得关注+转发+私信

私信回复【c#分布式通信框架】