Spring Boot中如何确保@MessageMapping对应WebSocket主题而非JMS队列？

看起来你遇到的核心问题是JMS和WebSocket的消息处理注解在类路径下产生了歧义，加上缺少必要的WebSocket STOMP配置，导致Spring没有正确将@MessageMapping绑定到WebSocket消息处理器上。下面一步步拆解问题并给出解决方案：

一、核心原因分析 #

1. 缺少WebSocket STOMP消息代理配置：你只添加了@EnableWebSocket，但这个注解仅启用基础WebSocket功能，无法支持@MessageMapping对应的STOMP协议消息处理。要处理STOMP消息，必须启用消息代理并配置端点。
2. 注解使用场景误解：@MessageMapping是用来处理客户端发送到服务器的应用消息（默认路径前缀为/app），而非监听代理上的/topic消息。你用SimpMessagingTemplate.convertAndSend()发送到topic的消息，只会被订阅该topic的客户端接收，不会触发@MessageMapping方法。
3. Controller注解冲突：你的Controller同时导入了@Component和@Controller，虽然@Controller本身包含@Component语义，但多余的@Component可能导致JMS组件扫描优先级高于WebSocket，引发注解识别错误。

二、分步解决方案 #

1. 添加WebSocket STOMP核心配置 #

创建专门的WebSocket配置类，启用消息代理并配置端点：

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 // 关键：启用STOMP消息代理和@MessageMapping支持
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 启用内置消息代理，处理/topic和/queue前缀的广播/点对点消息
        config.enableSimpleBroker("/topic", "/queue");
        // 设置客户端发送到服务器的消息前缀：客户端需发送到/app/{mapping}才能触发@MessageMapping
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 注册WebSocket连接端点，客户端通过该路径建立连接，启用SockJS兼容低版本浏览器
        registry.addEndpoint("/ws-stomp").withSockJS();
    }
}

2. 修正Controller类和方法 #

确保Controller仅使用@Controller注解，并明确@MessageMapping的处理逻辑：

@Slf4j
@Controller // 仅保留此注解，移除@Component
public class CommandController {

    @Autowired
    private SimpMessagingTemplate simpMessagingTemplate;

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    // 处理客户端发送到/app/${my.topic}的WebSocket消息
    @MessageMapping("${my.topic}")
    public void receiveCommand(Message<String> content) {
        log.info("Received WebSocket command: {}", content.getPayload());
        // 如果需要将消息转发到topic供客户端订阅，可添加以下代码
        simpMessagingTemplate.convertAndSend("/topic/" + content.getPayload());
    }

    // JMS监听保持不变，正常工作
    @JmsListener(destination = "${my.destination}")
    public void receiveMessage(String content) {
        System.out.println("Jms message: " + content);
    }
}

3. 修正单元测试逻辑 #

要触发@MessageMapping方法，需要发送消息到/app/${my.topic}路径，而非直接发送到topic：

@SpringBootTest
@AutoConfigureMockMvc
public class WebSocketCommandTest {

    @Autowired
    private SimpMessageSendingOperations simpMessagingTemplate;

    @Value("${my.topic}")
    private String topic;

    @Test
    public void shouldReceiveCommandMessages() throws IOException {
        URL url = Resources.getResource("command.json");
        String json = Resources.toString(url, Charsets.UTF_8);
        // 发送到/app前缀路径，触发@MessageMapping方法
        simpMessagingTemplate.convertAndSend("/app/" + topic, json);
    }
}

4. 验证依赖完整性 #

确保你的项目已引入WebSocket starter依赖（Maven示例）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

三、关键验证点 #

• 启动应用后，检查日志是否输出类似Mapping message handler method 'receiveCommand' to destination '/app/xxx'的内容，说明@MessageMapping已被正确注册为WebSocket处理器。
• 用STOMP客户端（如Postman、stompjs）连接/ws-stomp端点，发送消息到/app/${my.topic}，查看控制台是否打印接收日志。

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