SockJS从SpringWebSocket接收stomp消息时出错

Question

我正在尝试使用Springframework SimpMessageTemplate（默认Stomp实现）来流式传输时间序列数据，以将消息广播到SockJS客户端订阅的主题。但是，这些消息是按顺序接收的。服务器是单线程的，消息按时间戳升序发送。客户端以某种方式接收到了顺序错误的消息。

我使用的是stompjs和springframework的最新版本（4.1.6版本）。

Answer 1

看起来有一个内置的条纹执行器，所以只需启用它：

@Override
protected void configureMessageBroker(MessageBrokerRegistry registry) {
    // ...
    registry.setPreservePublishOrder(true);
}

https://docs.spring.io/spring/docs/current/spring-framework-reference/web.html#websocket-stomp-ordered-messages

Answer 2

这是SpringWeb套接字的设计问题。要按有效顺序接收消息，必须将websocket客户端的corePoolSize设置为1。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketMessageBrokerConfiguration extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureClientOutboundChannel(ChannelRegistration registration) {
        registration.taskExecutor().corePoolSize(1);
    }

    @Override
    public void configureClientInboundChannel(ChannelRegistration registration) {
        registration.taskExecutor().corePoolSize(1);
    }
}

Answer 3

找到了此问题的根本原因。从应用程序实现的角度来看，消息以“正确”的顺序发送（即convertAndSend（）以一个线程或至少线程安全的方式调用））但是，Springframework web套接字使用reactor tcp实现，该实现将处理来自线程池的clientOutboundChannel上的消息。因此，消息可以按照到达的不同顺序写入tcp套接字。当我将web套接字配置为clientOutboundChannel限制1个线程时，该顺序将保留。

这个问题不在SocketJS中，而是当前Spring Web套接字设计的一个限制。