1

我尝试使用 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。

我还需要做其他事情吗?

谢谢,拉菲克

4

1 回答 1

0

好的,有问题

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

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

StompBrokerRelayRegistration StompBrokerRelayRegistration = config.enableStompBrokerRelay("/topic", "/queue", "/amq/");
于 2014-02-18T07:19:17.757 回答