Stomp over WebSocket客户端无法接收消息问题求助

1. 订阅路径与发送路径不匹配 #

这是最常见的核心问题：

• 服务端通过SimpMessagingTemplate发送的目标是/topic/notification，但客户端订阅的是user/topic/notification，两者路径完全不匹配
• 客户端订阅路径缺少开头的斜杠/，WebSocket目的地必须以/开头
• 若服务端未使用用户专属消息（如@SendToUser），不需要在订阅路径前加user前缀

修正方案：

• 广播场景：客户端订阅/topic/notification，和服务端发送路径保持一致
• 单用户场景：服务端改用convertAndSendToUser方法发送，客户端订阅/user/topic/notification

2. 检查消息代理配置 #

确保WebSocketConfig中正确启用了包含/topic的消息代理：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 必须包含/topic前缀，否则消息代理不会处理该路径的消息
        config.enableSimpleBroker("/topic", "/queue");
        config.setApplicationDestinationPrefixes("/app");
    }

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

3. 客户端订阅代码正确性 #

检查客户端是否正确发起订阅，示例代码：

import { Client } from '@stomp/stompjs';

const client = new Client({
    brokerURL: 'ws://localhost:8088/ws',
    onConnect: () => {
        // 广播消息订阅路径
        client.subscribe('/topic/notification', (message) => {
            console.log('收到消息:', message.body);
        });
    },
    onStompError: (frame) => {
        console.error('STOMP错误:', frame.headers['message']);
    }
});

client.activate();

注意：订阅路径必须以/开头，且与服务端发送路径完全一致。

4. 跨域配置验证 #

虽然连接成功，但不完整的跨域配置可能导致消息接收失败：

• 避免使用setAllowedOrigins("*")，改用setAllowedOriginPatterns("*")适配SockJS的跨域要求
• 生产环境建议指定具体允许域名，而非通配符

5. 服务端消息发送方式检查 #

如果是单用户消息场景，服务端需使用用户专属发送方法：

// 给指定用户发送消息，username为用户标识
simpMessagingTemplate.convertAndSendToUser(username, "/topic/notification", "消息内容");

此时客户端订阅路径应为/user/topic/notification，Spring会自动处理用户路由。

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