网络套接字上STOMP的延迟

Question

我用的是SpringMVC 4 Tomcat。我的应用程序用@ Autowired SimpMessagingTemplate得到了2个类(A和B)。每个类都有一个调用“convertAndSend”的线程。

A类发送一条由8个双字段和3个长字段组成的消息。它向大约500个主题发送消息，例如“/主题/价格. X”（其中X-一些随机字符串）。频率-在单个循环中每秒最多4次（每个主题）。

B 类发送一条消息，该消息由 8 个双精度字段、4 个长字段和 4 个字符串字段组成。它将消息发送到单个主题，如“/主题/dma事件”。频率 - 每秒几次（最多20次）。

对于我的应用程序来说，保持消息顺序非常重要，因此我应用了这里描述的解决方案:

SockJS收到来自Spring网站盗贼的踩踏消息

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

我们有大约10-20个客户端同时连接并订阅所有主题。客户端应用程序。Net使用“websocket-sharp”库和自定义的STOMP协议实现。服务器在纽约，客户在芝加哥和伦敦。

在我们的UAT环境中一切正常，但在产品中，一位用户抱怨以下问题：

< li >在某些情况下，来自B类的消息传送到客户端会有大约30-40秒的延迟。同时，来自A类的消息被无延迟地传送。当来自类别A的消息以最大频率发送时(每个主题每秒4次=每秒2000条消息)，会出现这种情况。当频率降低时，延迟消失。

我用equenceId标记了每条消息，并注意到来自ClassB的消息无论如何都以错误的顺序传递。例如，服务器发送：

• 消息1 -

客户收到：

• 消息1 -

问题1：这是一种预期行为吗？

问题2：延迟的原因是什么？我是否应该放弃registration.taskExecutor（）. corePoolSize（1）的解决方案；并实现一个逻辑来保护客户端的消息顺序？

谢谢你。

Answer 1

我遇到了类似的问题，STOMP消息的延迟/缓慢传递，结果证明是由Spring使用的Reactor库引起的。

更新到更高版本后，为我修复了它：

runtime("io.projectreactor:reactor-core:2.0.6.RELEASE")
runtime("io.projectreactor:reactor-net:2.0.6.RELEASE")
runtime("io.netty:netty-all:4.0.33.Final")