SpringBoot 中什么是 WebSockets?

WebSockets 是一种在客户端和服务器之间实现双向通信的协议。它允许服务器主动向客户端推送数据，而不需要客户端显式地请求。在 Spring Boot 中，可以使用 Spring Framework 提供的 spring-websocket 模块来实现 WebSockets 功能。

以下是 Spring Boot 中 WebSockets 的主要概念和组件：

1. Stomp：
   • Stomp（Simple Text Oriented Messaging Protocol）是一个简单的文本导向消息协议，它在 WebSocket 之上提供了一个消息传递框架。Spring 框架提供了对 Stomp 协议的支持，使得在 Spring 应用程序中使用 WebSockets 变得更加容易。
2. WebSocket 支持：
   • Spring 框架提供了对 WebSocket 的支持，包括服务器端的配置和客户端的支持。通过在应用程序中使用 @EnableWebSocket 注解，可以启用 WebSocket 支持。

   import org.springframework.context.annotation.Configuration;
   import org.springframework.web.socket.config.annotation.EnableWebSocket;
   import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
   import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
   
   @Configuration
   @EnableWebSocket
   public class WebSocketConfig implements WebSocketConfigurer {
   
       @Override
       public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
           registry.addHandler(new MyWebSocketHandler(), "/my-websocket");
       }
   }
   

3. WebSocketHandler：
   • WebSocketHandler 接口用于处理 WebSocket 连接的生命周期和消息处理。你可以实现自定义的 WebSocketHandler 来处理不同的 WebSocket 事件。

   import org.springframework.web.socket.CloseStatus;
   import org.springframework.web.socket.TextMessage;
   import org.springframework.web.socket.WebSocketSession;
   import org.springframework.web.socket.handler.TextWebSocketHandler;
   
   public class MyWebSocketHandler extends TextWebSocketHandler {
   
       @Override
       protected void handleTextMessage(WebSocketSession session, TextMessage message) {
           // 处理收到的文本消息
       }
   
       @Override
       public void afterConnectionEstablished(WebSocketSession session) {
           // 连接建立时的处理逻辑
       }
   
       @Override
       public void afterConnectionClosed(WebSocketSession session, CloseStatus status) {
           // 连接关闭时的处理逻辑
       }
   }
   

4. 使用 Stomp：
   • 如果使用 Stomp 协议，可以在应用程序中使用 @EnableWebSocketMessageBroker 注解启用 WebSocket 消息代理。这样，就可以使用 @MessageMapping 注解处理特定消息的映射。

   import org.springframework.context.annotation.Configuration;
   import org.springframework.messaging.simp.config.MessageBrokerRegistry;
   import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
   import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
   import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
   
   @Configuration
   @EnableWebSocketMessageBroker
   public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
   
       @Override
       public void registerStompEndpoints(StompEndpointRegistry registry) {
           registry.addEndpoint("/my-websocket").withSockJS();
       }
   
       @Override
       public void configureMessageBroker(MessageBrokerRegistry registry) {
           registry.enableSimpleBroker("/topic");
           registry.setApplicationDestinationPrefixes("/app");
       }
   }
   

上述示例中，/my-websocket 是 WebSocket 的端点，而 /topic 和 /app 是 Stomp 协议的消息代理配置。使用 Stomp 协议可以更方便地处理消息的订阅和发送。