C#搭建高效、便捷的WebSocket服务器和客户端

一、概述

1.1 什么是WebSocket??

WebSocket是一种在单个TCP连接上进行全双工通信的协议。WebSocket通信协议于2011年被IETF定为标准RFC 6455,并由RFC7936补充规范。WebSocket API也被W3C定为标准。

WebSocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。在WebSocket API中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。

1.2 TouchSocket特性

性能卓越,和同类产品相比,性能提升20%左右,这得益于强大的RRQMSocket。

封装优雅,从TCP继承封装,能够发送不分包的大数据,也能发送分片的小数据。

解析简单,在收到消息后,已经将数据帧转换为数据对象,可通过枚举值判断数据类型,通过布尔值判断FIN,RSV1-3等数据。

能够直接发送二进制数据,也能直接发送文本。

支持Ssl。

二、程序集源码、Demo下载

2.1 源码位置

Gitee

Github

2.2 详细说明文档

文档首页

三、安装

Nuget安装TouchSocket即可,具体步骤详看链接博客。

VS、Unity安装和使用Nuget包

四、创建WebSocket服务器

var service = new HttpService();

service.AddPlugin<WebSocketServerPlugin>().//添加WebSocket功能

SetWSUrl("/ws").//设定只有特定url能连接。

SetCallback(WSCallback);//WSCallback回调函数是在WS收到数据时触发回调的。

var config = new RRQMConfig();

config.UsePlugin()

.SetListenIPHosts(new IPHost[] { new IPHost(7789) });

service.Setup(config).Start();

Console.WriteLine("Http服务器已启动");

Console.WriteLine("WS访问:ws://127.0.0.1:7789/ws");

static void WSCallback(ITcpClientBase client, WSDataFrameEventArgs e)

{

switch (e.DataFrame.Opcode)

{

case WSDataType.Cont:

Console.WriteLine($"收到中间数据,长度为:{e.DataFrame.PayloadLength}");

break;

case WSDataType.Text:

Console.WriteLine(e.DataFrame.ToText());

break;

case WSDataType.Binary:

if (e.DataFrame.FIN)

{

Console.WriteLine($"收到二进制数据,长度为:{e.DataFrame.PayloadLength}");

}

else

{

Console.WriteLine($"收到未结束的二进制数据,长度为:{e.DataFrame.PayloadLength}");

}

break;

case WSDataType.Close:

{

Console.WriteLine("远程请求断开");

client.Close("断开");

}

break;

case WSDataType.Ping:

break;

case WSDataType.Pong:

break;

default:

break;

}

}

【WSs服务器】

创建WSs服务器时,其他配置不变,只需要在config中加入以下代码即可。

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

var config = new RRQMConfig();

config.UsePlugin()

.SetReceiveType(ReceiveType.Auto)

.SetListenIPHosts(new IPHost[] { new IPHost(7789) })

.SetServiceSslOption(new ServiceSslOption() //Ssl配置,当为null的时候,相当于创建了ws服务器,当赋值的时候,相当于wss服务器。

{

Certificate = new X509Certificate2("RRQMSocket.pfx", "RRQMSocket"),

SslProtocols = SslProtocols.Tls12

});

五、创建WebSocket客户端

【WS客户端】

WebSocketClient myWSClient = new WebSocketClient();

myWSClient.Setup(new RRQMConfig()

.SetRemoteIPHost("ws://127.0.0.1:7789/ws")

.SetSingletonLogger(new LoggerGroup(new ConsoleLogger(), new FileLogger())));

myWSClient.Connect();

//myWSClient.Received += this.MyWSClient_Received; 客户端接收

myWSClient.Logger.Message("连接成功");

六、发送数据

6.1 直接发送

6.2 分片发送

WebSocket是支持分片发送的,这是为了解决大数据的传输而设计的,因为像浏览器这种接收缓存不足的组件,没办法一次性接收一个大数据包,所以必须分片。但是在RRQM中,并没有设计自动分片的功能,而是让发送者决定要不要分片,每个数据包应该多大等。

分片的函数也已经封装,以第一个函数为例,前三个参数是定位发送数据,最后一个数据则决定每个数据包应当多少尺寸。

以下列代码为例,则会把data数据,从索引1-8的数据发送,且每个数据包最大长度为4,刚好发送两个包。

6.3 发送数据帧

RRQM已经重载了数据帧的发送,这意味着您可以发送任意数据类型的数据。

数据帧的类型是WSDataFrame,它是一个完全开放的数据结构。

当然为方便赋值,RRQM内部已经封装了扩展方法。例如:

一直追加文本。

WSDataFrame wSDataFrame = new WSDataFrame();

wSDataFrame.AppendText("I");

wSDataFrame.AppendText("love");

wSDataFrame.AppendText("you");

一直追加二进制。

WSDataFrame wSDataFrame = new WSDataFrame();

wSDataFrame.AppendBinary(new byte[] { 1 }, 0, 1);

wSDataFrame.AppendBinary(new byte[] { 2 }, 0, 1);

wSDataFrame.AppendBinary(new byte[] { 3 }, 0, 1);

相关新闻

QQ渠道

技术支持:QQ2854399

关注公众号
关注公众号
微信客服
返回顶部