掌握 WebSocketMessageBrokerConfigurer，提升 Spring Boot 中的实时通信能力

2024-01-13 10:35:12

WebSocketMessageBrokerConfigurer：配置 WebSocket 实时通信

WebSocket：开启实时交互

在现代 Web 应用程序中，WebSocket 已成为实现客户端和服务器之间实时双向通信的热门选择。它打破了传统 HTTP 请求-响应模式的局限，建立在 TCP 之上的特殊 WebSocket 协议之上，保持持久连接，实现即时消息传递。

WebSocketMessageBrokerConfigurer：消息代理配置

Spring Boot 提供了对 WebSocket 的支持，并通过 WebSocketMessageBrokerConfigurer 接口配置 WebSocket 消息代理。WebSocketMessageBrokerConfigurer 是一个配置类，让你控制消息代理的各个方面，包括目的地、消息转换器等。

WebSocketMessageBrokerConfigurer 原理

WebSocketMessageBrokerConfigurer 的原理并不复杂。它主要通过几个关键配置方法来配置消息代理：

configureMessageBroker()： 设置消息代理的目的地和应用程序目的地前缀。目的地是消息发送和接收的端点。
configureWebSocketTransport()： 指定 WebSocket 的传输方式，例如 SockJS、WebSocket 等。
configureStompEndpoints()： 配置 STOMP 端点。STOMP 是一种基于 WebSocket 的消息传输协议，提供更简单的消息格式和语义。

使用 WebSocketMessageBrokerConfigurer

要使用 WebSocketMessageBrokerConfigurer，你需要创建一个实现该接口的配置类。在配置类中，使用提供的配置方法来调整消息代理的属性。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void configureWebSocketTransport(WebSocketTransportRegistration registry) {
        registry.addDecoratorFactory(new SockJsWebSocketServerSockJsDecoratorFactory());
    }

    @Override
    public void configureStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/websocket").withSockJS();
    }

}