使用 Spring 4.0 webstocket stomp api 连接到 Rabbitmq 失败

Question

我尝试使用 Spring 4.0 WebSocketMessageBrokerConfigurer 类与 RabbitMQ 建立 STOMP 连接，但失败了？

代码快照在这里。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        StompBrokerRelayRegistration StompBrokerRelayRegistration = config.enableStompBrokerRelay("/");
        StompBrokerRelayRegistration.setApplicationLogin("guest");
        StompBrokerRelayRegistration.setApplicationPasscode("guest");
        StompBrokerRelayRegistration.setAutoStartup(true);
        StompBrokerRelayRegistration.setRelayHost("localhost");
        StompBrokerRelayRegistration.setRelayPort(15674);

注意

• 我正在使用 spring boot 来运行应用程序。事实上，我正在更改现有的 spring 示例“gs-messaging-stomp-websocket”。和换班WebSocketConfig。
• Rabbitmq 在本地安装并启用了 STOMP 插件。
• 添加了所有的 maven 依赖，比如 spring-rabbitmq。

我还需要做其他事情吗？

谢谢， 拉菲克

Answer 1

好的，问题解决了

StompBrokerRelayRegistration StompBrokerRelayRegistration = config.enableStompBrokerRelay("/");

我们需要传递 stomp 支持的 "uri" 而不是 "/" vhost。

StompBrokerRelayRegistration StompBrokerRelayRegistration = config.enableStompBrokerRelay("/topic", "/queue", "/amq/");