从Spring SimpleBroker迁移到RabbitMQ STOMP中继时的主题无效问题

问题根源 #

RabbitMQ的STOMP代理要求目的地必须以合法前缀（如/topic/、/queue/）开头，错误日志中的'/be31be41-a373-4aae-81e6-2d29302f9d5d/moves'缺少标准前缀，因此被判定为无效目的地。

关键配置调整 #

1. 明确区分应用与代理的目的地前缀 #

在消息代理配置类中，需通过setApplicationDestinationPrefixes指定路由到@MessageMapping方法的前缀，通过enableStompBrokerRelay指定转发到RabbitMQ的前缀：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        // 客户端发送到/app开头的消息会被路由到@MessageMapping注解的方法
        config.setApplicationDestinationPrefixes("/app");
        // 以/topic/、/queue/开头的消息转发至RabbitMQ STOMP代理
        config.enableStompBrokerRelay("/topic/", "/queue/")
                .setRelayHost("localhost")
                .setRelayPort(61613)
                .setClientLogin("guest")
                .setClientPasscode("guest");
    }

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

2. 确保服务器发布消息的目的地格式正确 #

处理客户端请求后，发布状态更新时必须使用完整的/topic/{matchId}/moves格式，避免遗漏前缀：

@Controller
public class MatchMoveController {
    private final SimpMessagingTemplate simpMessagingTemplate;

    public MatchMoveController(SimpMessagingTemplate simpMessagingTemplate) {
        this.simpMessagingTemplate = simpMessagingTemplate;
    }

    @MessageMapping("/matches/{matchId}/moves")
    public void handleMatchMove(@DestinationVariable String matchId, Move move) {
        // 业务逻辑处理...
        MatchState updatedState = processMove(matchId, move);
        // 发送更新到正确的topic目的地
        simpMessagingTemplate.convertAndSend("/topic/" + matchId + "/moves", updatedState);
    }
}

3. 客户端消息目的地需匹配应用前缀 #

由于配置了/app作为应用前缀，客户端发送请求时的目的地需调整为/app/matches/{matchId}/moves。若客户端未改动，需检查原SimpleBroker配置是否隐含了前缀映射，现在必须显式添加/app前缀。

额外验证项 #

• 确认RabbitMQ已启用STOMP插件：执行rabbitmq-plugins enable rabbitmq_stomp（Docker部署可通过容器命令执行）。
• 验证RabbitMQ的STOMP服务端口61613正常监听，且登录凭证（clientLogin/clientPasscode）与RabbitMQ配置一致。

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