我尝试使用 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。
我还需要做其他事情吗?
谢谢,拉菲克