Spring Boot+WebSocket+嵌入式ActiveMQ多会话消息无法同时接收问题求助

你遇到的这个情况很典型——当同一个用户在多个浏览器会话订阅同一路径时，消息交替被接收，这说明当前的消息代理是按照**点对点队列（Queue）的逻辑在分发消息，而不是你期望的发布订阅主题（Topic）**模式。下面是具体的排查和解决步骤：

1. 调整WebSocket消息代理配置 #

Spring Boot结合Stomp和ActiveMQ时，默认/user/前缀的目标会被映射到用户专属的队列（每个会话对应一个队列），所以消息会轮询发送给不同的会话。要实现所有会话同时接收，需要修改配置支持主题广播：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 启用Stomp代理中继，同时支持主题和队列前缀
        config.enableStompBrokerRelay("/topic/", "/queue/")
              .setRelayHost("localhost")
              .setRelayPort(61613) // ActiveMQ默认STOMP端口
              .setClientLogin("admin")
              .setClientPasscode("admin");
        // 设置应用级消息前缀
        config.setApplicationDestinationPrefixes("/app");
        // 保留/user/前缀，后续通过广播配置实现多会话接收
        config.setUserDestinationPrefix("/user/");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws-connect").withSockJS();
    }
}

2. 发送消息时启用用户广播 #

如果需要给用户的所有会话发送消息，使用SimpMessagingTemplate时要添加广播头，强制消息分发到用户的所有订阅会话：

@Service
public class MessageService {

    private final SimpMessagingTemplate messagingTemplate;

    public MessageService(SimpMessagingTemplate messagingTemplate) {
        this.messagingTemplate = messagingTemplate;
    }

    public void sendToUserAllSessions(String username, String destination, Object payload) {
        // 添加广播头，让消息发送到用户的所有订阅会话
        SimpMessageHeaderAccessor headerAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
        headerAccessor.setHeader(SimpMessageHeaderAccessor.BROADCAST_HEADER, true);
        headerAccessor.setLeaveMutable(true);

        messagingTemplate.convertAndSendToUser(
                username,
                destination,
                payload,
                headerAccessor.getMessageHeaders()
        );
    }
}

3. 确保嵌入式ActiveMQ支持主题 #

在application.properties中添加配置，保证嵌入式ActiveMQ允许创建和使用主题：

# 配置嵌入式ActiveMQ支持主题，关闭持久化（按需调整）
spring.activemq.broker-url=vm://localhost?broker.persistent=false&broker.supportTopics=true
spring.activemq.user=admin
spring.activemq.password=admin

4. 客户端订阅路径验证 #

确保客户端订阅的路径和后端配置匹配，比如使用/user/TestUser/reply时，后端已经启用了用户广播：

// 客户端Stomp订阅示例
const stompClient = Stomp.client('ws://localhost:8080/ws-connect');
stompClient.connect({}, function(frame) {
    stompClient.subscribe('/user/TestUser/reply', function(message) {
        console.log('收到消息:', JSON.parse(message.body));
    });
});

关键原理总结 #

默认情况下，Spring的/user/前缀会为用户的每个会话创建独立的队列，消息采用轮询方式分发（这就是你看到交替接收的原因）。通过启用广播头或者将目标改为主题，就能让消息同时发送到用户的所有订阅会话，实现你期望的效果。

内容的提问来源于stack exchange，提问作者user1122