使用JavaSpring Boot Framework订阅STOMP消息

Question

我正在尝试编写一个Spring服务，它订阅一个外部只读STOMP代理，并读取/处理它发布的消息。

铁路公司将消息推送到主题“/topic/TRAIN\u MVT\u ALL\u TOC”。我可以成功地连接到主题，但似乎无法将侦听器实例化为其消息。

我已经设置了一个Spring@Configuration类来连接它，在运行应用程序之后，它似乎连接正确。

我还创建了消息处理例程，使用@Message映射注释来收听我感兴趣的特定主题（TRAIN_MVT_ALL_TOC）。问题是它似乎从来没有被调用。

配置类代码：`

@Configuration
@EnableWebSocketMessageBroker
public class StompConfig implements WebSocketMessageBrokerConfigurer {
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/TRAIN_MVT_ALL_TOC").withSockJS();
    }
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app");
        registry.enableStompBrokerRelay("/topic")
                .setRelayHost("datafeeds.networkrail.co.uk")
                .setRelayPort(61618)
                .setSystemLogin("MYEMAIL")
                .setSystemPasscode("MYPASSWORD")
        ;
    }
}

消息处理程序代码：

@MessageMapping("/TRAIN_MVT_ALL_TOC")
public void onMessage(@Payload String message) throws Exception {
    System.out.println(message);
}

以下日志条目输出到控制台，表示连接成功。

o. s. w. s. c.WebSocketMessageBrokerStats： WebSocketsession[0当前WS（0）-HttpStream（0）-HttpPoll（0），0总计，0异常关闭（0连接失败，0发送限制，0传输错误）]，StumpSubProtocol[已处理CONNECT（0）-CONNECTED（0）-DISCONNECT（0）]，StumpBrokerRelay[1会话，ReactorNettyTcpClient[TcpClient：连接到datafeeds.networkrail.co.uk:61618]（可用），已处理的CONNECT（1）-CONNECTED（1）-DISCONNECT（0）]，在边界通道[池大小=0，活动线程=0，排队任务=0，已完成任务=0]，在边界通道大小=0，活动线程=0，排队任务=0，已完成[池大小=1，活动线程=1，排队任务=0，已完成任务=0]

然而，这条消息从未被打印出来。几天来，我一直在努力弄清这件事的真相，所以我非常感谢您的帮助。

Answer 1

铁路公司将消息推送到主题“/topic/TRAIN\u MVT\u ALL\u TOC”。我可以成功地连接到主题，但似乎无法将侦听器实例化为其消息。

您是指客户端的侦听器，例如sockjs客户端？

@MessageMapping("/TRAIN_MVT_ALL_TOC")
public void onMessage(@Payload String message) throws Exception {
    System.out.println(message);
}

您不返回任何东西，您需要将其发送到这样的主题：

@MessageMapping("/TRAIN_MVT_ALL_TOC")
@SendTo("/topic/TRAIN_MVT_ALL_TOC")
public Greeting onMessage(HelloMessage message) throws Exception {
    return new Greeting("hello");
}

或者，如果构造函数的参数中包含SimpMessageSendingOperations（应该由spring boot本身自动连接），则可以向同一主题发送多条消息，如下所示：

@Autowired
public Constructor(SimpMessageSendingOperations messagingTemplate) {
    this.messagingTemplate = messagingTemplate;
}

@MessageMapping(WebSockets.READER_MAPPING)
public void streamOverWebsocket(HelloMessage message) throws Throwable {
    String topicUrl = "/topic/TRAIN_MVT_ALL_TOC";
    messagingTemplate.convertAndSend(topicUrl, new Message("response 1"));
    messagingTemplate.convertAndSend(topicUrl, new Message("response 2"));
    ...
}

最好将传入和传出封装在定义的类中。这样，序列化和反序列化就更容易了。

资料来源：

• https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/messaging/simp/SimpMessageSendingOperations.html
• https://spring.io/guides/gs/messaging-stomp-websocket/