同步操作将从 若汝棋茗/TouchSocket 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
合抱之木,生于毫末;九层之台,起于垒土。
名称 | 地址 | 描述 |
---|---|---|
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。 |
RRQMSocket的IOCP和传统也不一样,就以微软官方示例为例,使用MemoryBuffer开辟一块内存,均分,然后给每个会话分配一个区接收,等收到数据后,再复制源数据,然后把复制的数据进行处理。而RRQMSocket是每次接收之前,从内存池拿一个可用内存块,然后直接用于接收,等收到数据以后,直接就把这个内存块抛出处理,这样就避免了复制操作,虽然只是细小的设计,但是在传输1000w次64kb的数据时,性能相差了10倍。
相信大家都使用过其他的Socket产品,例如HPSocket,SuperSocket等,那么RRQMSocket在设计时也是借鉴了其他产品的优秀设计理念,数据处理适配器就是其中之一,但和其他产品的设计不同的是,RRQMSocket的适配器功能更加强大,它不仅可以提前解析数据包,还可以解析数据对象。例如:可以使用固定包头对数据进行预处理,从而解决数据分包、粘包的问题。也可以直接解析HTTP数据协议、WebSocket数据协议等。
RRQMSocket提供多种框架模型,能够完全兼容基于TCP、UDP协议的所有协议。例如:TcpService与TcpClient,其基础功能和Socket一模一样,只是增强了框架的坚固性和并发性,将连接和接收数据通过事件的形式抛出,让使用者能够更加友好的使用。
更多配置请查看API文档的配置说明文档,一下仅以最简方式创建实例。
【TcpService】
TcpService service = new TcpService();
service.Connecting += (client, e) =>{};//有客户端正在连接
service.Connected += (client, e) =>{};//有客户端连接
service.Disconnected += (client, e) =>{};//有客户端断开连接
service.Received += (client, byteBlock, obj) =>
{
//从客户端收到信息
string mes = Encoding.UTF8.GetString(byteBlock.Buffer, 0, byteBlock.Len);
Console.WriteLine($"已从{client.Name}接收到信息:{mes}");//Name即IP+Port
};
//声明配置
var config = new TcpServiceConfig();
config.ListenIPHosts = new IPHost[] { new IPHost("127.0.0.1:7789"), new IPHost(7790) };//同时监听两个地址
//载入配置
service.Setup(config);
//启动
service.Start();
【TcpClient】
SimpleTcpClient tcpClient = new SimpleTcpClient();
tcpClient.Connected += (client, e) =>{};//成功连接到服务器
tcpClient.Disconnected += (client, e) =>{};//从服务器断开连接,当连接不成功时不会触发。
//载入配置
tcpClient.Setup("127.0.0.1:7789");
tcpClient.Connect();
tcpClient.Send(Encoding.UTF8.GetBytes("RRQM"));
【TcpClient 断线重连】
tcpClient.UseReconnection(tryCount:5,printLog:true);
【FixedHeaderPackageAdapter包模式】
该适配器主要解决TCP粘分包问题,数据格式采用简单而高效的“包头+数据体”的模式,其中包头支持:
以上数据头均采用RRQMBitConverter的默认端模式(小端模式),使用者可以根据需求切换默认端模式。
RRQMBitConverter.DefaultEndianType = EndianType.Little;
【CustomFixedHeaderDataHandlingAdapter】
用户自定义固定包头适配器,主要帮助用户解决具有固定包头的数据帧信息。例如:下列数据格式,仅需要实现几个接口,就能完成解析,详细操作请参照API。
|1|1|1|**********|
【CustomUnfixedHeaderDataHandlingAdapter】
用户自定义不固定包头适配器,主要帮助用户解决具有包头不固定的数据帧信息。例如:最典型的HTTP数据包,其数据头和数据体由“\r\n”隔开,而数据头又因为请求者的请求信息的不同,头部数据也不固定,而数据体的长度,也是由数据头的ContentLength的值显式指定的,所以可以考虑使用CustomUnfixedHeaderDataHandlingAdapter解析,也是仅通过简单的开发,就能实现。
【Ssl加密】
在RRQMBox中,放置了一个自制Ssl证书,密码为“RRQMSocket”以供测试。使用配置非常方便。
在服务器中只需设置配置SslOption属性和接收模式(接收模式在Ssl模式下只支持BIO和Select)。
服务器配置
config.SslOption = new ServiceSslOption() { Certificate = new X509Certificate2("RRQMSocket.pfx", "RRQMSocket"), SslProtocols = SslProtocols.Tls12 };
config.ReceiveType = ReceiveType.Select;
客户端配置
config.ReceiveType = ReceiveType.BIO;
config.SslOption = 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; }
};
【WS服务器】
WSService wSService = new WSService();
wSService.Received += WSService_Received;
wSService.Connected += WSService_Connected;
var config = new WSServiceConfig();
config.ListenIPHosts = new IPHost[] { new IPHost("127.0.0.1:7789"), new IPHost(7790) };//同时监听两个地址
config.ReceiveType = ReceiveType.IOCP;
wSService.Setup(config).Start();
Console.WriteLine("WS服务器已启动");
【WSs服务器】
创建WSs服务器时,其他配置不变,只需要在config
中加入以下代码即可。
在RRQMBox中,放置了一个自制Ssl证书,密码为“RRQMSocket”以供测试。使用配置非常方便。
//config.SslOption = new ServiceSslOption() { Certificate = new X509Certificate2("RRQMSocket.pfx", "RRQMSocket"), SslProtocols = SslProtocols.Tls12 };//Ssl配置,当为null的时候,相当于创建了ws服务器,当赋值的时候,相当于wss服务器。
config.ReceiveType = ReceiveType.Select;//在没有ssl配置时,请使用IOCP模式,速度会好些,使用ssl时,可以选择Select和BIO,区别请看API
【WS客户端】
SimpleWSClient client = new SimpleWSClient();
WSClientConfig config = new WSClientConfig();
config.RemoteIPHost = new IPHost("127.0.0.1:7789");
client .Setup(config);
client .Connect();
Console.WriteLine("连接成功");
while (true)
{
client.Send(Console.ReadLine());
}
注意:当使用域名连接时,IPHost中的字符串必须显式指定端口,例如百度地址:IPHost("ws://baidu.com:80")
【WSs客户端】
同样的,在客户端配置中,只需要加入以下代码即可。
注意:当使用域名连接时,TargetHost为域名,例如连接到IPHost("ws://baidu.com:80")时,TargetHost应当填写:baidu.com
config.SslOption = 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; }
};
config.ReceiveType = ReceiveType.BIO;
【WS 接收数据(服务器、客户端均可用)】
private static void MyWSClient_Received(IWSClientBase client, WSDataFrame dataFrame)
{
switch (dataFrame.Opcode)
{
case WSDataType.Cont:
Console.WriteLine($"收到中间数据,长度为:{dataFrame.PayloadLength}");
break;
case WSDataType.Text:
Console.WriteLine(dataFrame.GetMessage());
break;
case WSDataType.Binary:
if (dataFrame.FIN)
{
Console.WriteLine($"收到二进制数据,长度为:{dataFrame.PayloadLength}");
}
else
{
Console.WriteLine($"收到未结束的二进制数据,长度为:{dataFrame.PayloadLength}");
}
break;
case WSDataType.Close:
break;
case WSDataType.Ping:
break;
case WSDataType.Pong:
break;
default:
break;
}
}
谢谢大家对我的支持,如果还有其他问题,请加群QQ:234762506讨论。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。