如何使用WebSocket

Posted 2023-05-16

　这里WebSocketServer对象通过Setup方式对要侦听的IP及端口进行了设置。然后使用Start方法启动侦听。

　　Setup方法有4种重载，但是我们通常用到的只有设置IP和端口，IP为string类型，如果传入的字符串无法被转换为支持的IP格式，Setup方法会返回false表示设置失败。

　　WebSocketServer还提供了4个事件用以管理与客户端的连接、断开、和接受消息动作。新版本的WebSocket支持传送的数据格式有 “文本” 和 “二进制”两种，NewMessageReceived事件用于处理文本类型的消息，NewDataReceived事件用于处理二进制类型的消息。

　　

　　到这里 我们已经成功的搭建了一个实现了WebSocket协议的服务端了。至于服务端的寄宿方式有很多，SuperWebSocket框架支持以 控制台、Winform、IIS以及Windows服务的形式寄宿服务，不过网上很多资料都不建议在IIS中寄宿服务，据说是因为寄宿在IIS中性能比较低。

　　WebSocket既然是双工通信，那么我们就不能光等着接收来自客户端的消息， 我们也需要从服务端向客户端“推送”消息，现在我们来看如何由服务端向客户端发送消息。

　　SuperWebSocket框架中，服务端与客户端创建的连接对象为WebSocketSession类型，也就是说它将每一个客户端的实例视为一个会话，在客户端创建连接的时候，产生这个会话，在客户端断开连接的时候，销毁这个会话，而客户端与服务端进行消息通信的时候，也依赖这个会话进行传递。我们要实现服务器端向客户端的广播，就要获取到当前正在活动的所有会话，我们通过代码来看如何获取所有的会话

　　

wsServer.Get www.hbbz08.com AllSessions() //获取所有的会话 已断开的会话不会出现在集合中
　　很简单吧，在获取到活动的会话之后 我们就可以向客户端发送消息了，这里我们让服务器向客户端定时发送服务器时间

复制代码
Timer timer = new Timer((data) =>

var msg = string.Format("服务器当前时间：0:HH:MM:ss", DateTime.Now);

//对当前已连接的所有会话进行广播
foreach (var session in wsServer.GetAllSessions())

session.Send(msg);


, null, 1000, 1000);
复制代码
　　这样 所有与服务端保持连接的客户端就都可以接受到来自服务器端的消息了。

　　在这个例子里 我们看到了所有的消息都是由会话对象发出的，会话对象Send的消息 也支持“文本”与“二进制两种形式，同时会话对象还提供一个SendCloseHandshakeResponse()方法向客户端发送一个强制断开连接的指令。

　　WebSocketSession对象包含了服务端和客户端的所有信息，以及WebSocketServer对象本身，我们可以利用它做很多事情，下边我们就来实现一个简单的聊天室。至于聊天室的原理 就是一个人将要说的话发送到服务器，再由服务器广播给在这个聊天室里的所有人看到。恩 就这么简单。我们来上代码，多了不解释，相当简单。

　　

View Code
　　关与SuperWebSocket的基本使用就介绍到这里了……顶着老板不时窥屏的压力，可能文章有点语无伦次，希望大家多多体谅，也希望大家提出宝贵意见 共同学习。下一篇我会考虑介绍“子协议”和SuperWebSocket提供的Json字符串类型数据的处理 参考技术A 这里WebSocketServer对象通过Setup方式对要侦听的IP及端口进行了设置。然后使用Start方法

WebSocket原理及如何使用

WebSocket原理及如何使用

 

它有很多名字; WebSocket，WebSocket协议和WebSocket API。从首选的消息传递应用程序到流行的在线多人游戏，WebSocket在当今最常用的Web应用程序中是至关重要的。

 

根据定义，WebSocket是通过单个TCP连接提供全双工（双向通信）通信信道的计算机通信协议。此WebSocket API可在用户的浏览器和服务器之间进行双向通信。用户可以向服务器发送消息并接收事件驱动的响应，而无需轮询服务器。 它可以让多个用户连接到同一个实时服务器，并通过API进行通信并立即获得响应。

WebSockets允许用户和服务器之间的流连接，并允许即时信息交换。在聊天应用程序的示例中，通过套接字汇集消息，可以实时与一个或多个用户交换，具体取决于谁在服务器上“监听”（连接）。

 

WebSockets不仅限于聊天/消息传递应用程序。它们适用于需要实时更新和即时信息交换的任何应用程序。一些示例包括但不限于：现场体育更新，股票行情，多人游戏，聊天应用，社交媒体等等。

 

WebSockets还会考虑代理和防火墙等危险，使得任何连接都可以进行流式传输。它支持单个连接的上游和下游通信。 它还减轻了服务器的负担，允许现有机器支持同时连接。

 

这是现代Web应用程序中的示例实现WebSockets。在下面的示例中，我使用WebSockets作为带有Rails 5 API后端和React.js前端的即时消息应用程序。这绝不是一个指南，而是一个如何使用它的例子。我使用了Action Cable，它是Rails的包装器，可以无缝地集成Ruby中WebSockets的主要功能，并允许在整个域模型中轻松实现。 它内置于Rails 5.2中，因此无需安装/执行任何外部库或gem。

 

它的工作原理是Pub-Sub（发布和订阅）。它适用于发送者将数据（发布者）发送给抽象数量的收件人（订阅者），而无需指定他们是谁。

 

第一步是将服务器挂载到路由文件中，这样前端就可以从流中得到endpoint：

在第5行，我设置了ActionCable服务器端点

 

下一步是在后端创建一个通道，以便在实时创建消息时对消息进行流式处理。

这是管理消息创建以及广播消息的消息通道

 

这里我们有两种方法，订阅和接收。订阅的第一种方法允许将消息通道流式传输到连接的用户或订户。 接收的第二种方法管理消息创建和广播消息。我实现了JWT用户身份验证，以便可以将消息追溯到用户，只有具有有效用户帐户的消息才能创建消息。

 

对于我的应用程序的前端，我使用它们npm package actioncable从客户端到服务器端连接到WebSocket API。 这个包直接来自于Rails的团队。 使用此库，我实例化了一个cableApp实例，并将其作为props传递给需要访问WebSocket连接的组件。

导入actionCable并创建了一个cableApp实例，然后将cableApp连接到我的后端端点“/ cable”并将其传递给需要连接的组件

 

然后，我通过React.js生命周期方法componentDidMount（）连接到WebSocket的连接，并在每次将组件安装到DOM时建立连接。

在componentDidMount（）中，我建立了客户端以连接到WebSocket协议，该协议从我的Rails API中的“messagesChannel”流式传输。

 

现在，每次创建消息并将其发送到接收方法时，订阅（d）用户将立即接收并能够实时查看消息。此实现支持订阅同一频道的多个用户。因此，如果多个用户签名并订阅了相同的频道，他们可以发送所有订阅者都能看到的消息以及从其他订阅者接收消息。当然，你可以限制为两个人，并使它成为p2p，但是那样还有什么乐趣呢？

 

我希望通过阅读本文，可以看到WebSockets的潜力。它使自己成为一个宝贵的资源，在这个时代，信息交换需要很快完成。 希望读者将在自己的项目中实现它们。