在开发 Web 应用程序时，我们有时需要将服务器事件向下推送到连接的客户端。但是，HTTP 并未设计为允许这样做。客户端打开与服务器的连接并请求数据。服务器不会打开与客户端的连接并推送数据。
为了解决这个限制，建立了一种轮询模式，网页会间歇性地轮询服务器以查找任何新事件。这种模式并不理想，因为它增加了 HTTP 开销，速度仅与轮询速率一样快，并且会在服务器上造成不必要的负载。
幸运的是，随着 HTML5 的出现，出现了 WebSocket。 WebSocket 协议以较低的开销实现浏览器和 Web 服务器之间的交互。在这篇博客中，我们将介绍 Websockets API 并展示如何使用 Spring Boot 实现 Websockets。
HTML5 来拯救！
WebSockets 通过浏览器和服务器之间的单一连接提供全双工通信。它没有 HTTP 的开销，并允许服务器实时向客户端推送消息。
WebSocket API 实际上非常简单。创建一个 WebSocket 对象，附加事件侦听器并发送消息。
这是一个例子：
var socket = new WebSocket('ws://' + window.location.host + '/my-websocket-endpoint');
// Add an event listener for when a connection is open
socket.onopen = function() {
console.log('WebSocket connection opened. Ready to send messages.');
// Send a message to the server
socket.send('Hello, from WebSocket client!');
};
// Add an event listener for when a message is received from the server
socket.onmessage = function(message) {
console.log('Message received from server: ' + message);
};
Spring靴
Spring 对与 WebSockets 的接口有很好的支持。
首先，我们需要创建一个扩展 Spring 类 TextWebSocketHandler 的类。
public class MyMessageHandler extends TextWebSocketHandler {
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
// The WebSocket has been closed
}
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
// The WebSocket has been opened
// I might save this session object so that I can send messages to it outside of this method
// Let's send the first message
session.sendMessage(new TextMessage("You are now connected to the server. This is the first message."));
}
@Override
protected void handleTextMessage(WebSocketSession session, TextMessage textMessage) throws Exception {
// A message has been received
System.out.println("Message received: " + textMessage.getPayload());
}
}
接下来，我们需要配置我们的 WebSocket 端点。
@Configuration
@EnableWebSocket
public class WebsocketConfig implements WebSocketConfigurer {
@Bean
public WebSocketHandler myMessageHandler() {
return new MyMessageHandler();
}
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(myMessageHandler(), "/my-websocket-endpoint");
}
}
由于 WebSockets API 是纯 JavaScript，您应该能够在大多数前端框架中使用它。这包括 Angular，因为您可以在 TypeScript 中直接包含 JavaScript。
最后的想法
很简单，它解决了服务器和客户端之间同时传输数据的一个大问题。 Spring Boot 使它更容易。
想看看 Websockets 的实际应用吗？在 Keyhole，我们构建了一个开源工具 Trouble Maker，它将故障注入我们的平台，以便我们可以练习和测试使平台具有弹性的恢复机制。 Trouble Maker 有一个 Angular 前端，并利用 WebSockets 进行一些实时通信。查看 Github Repo 进行实际操作。
标签2： Java教程地址：https://www.cundage.com/article/jcg-real-time-communication-implementing-websockets-spring-boot.html
相关阅读
