如果生产者发送速率高于用户处理速率，则使用Solace避免拥塞

Question

我在应用程序中有以下使用模式：

1. 发布者以每条消息5微秒的速度向主题发送消息(即每5微秒发送一条消息)。
2. 使用者订阅该主题并以每条消息10微秒的速度处理消息(即在JAVA中完成onReceive回调需要10微秒)。
3. 使用者只对发布到主题的最后一条消息感兴趣，因此可以删除所有未处理的中间消息。

是否有可能避免消费者端未处理消息队列中的拥塞？

我尝试使用与com.solacesystems.jcsmp.impl.XMLMessageQueue). ( delay=0，文档链接)一起运行，但是，如果消息已经放在使用者端的Solace中的内部队列中(我指的是文档链接)，则不会有帮助。

将延迟设置为某些特定的值很好，但它不能很好地扩展，因为这个数字是动态的，取决于发行者的数量和消费者的性能。

Answer 1

一个可能的解决方案是创建一个LVQ (最后一个值队列)，它订阅了主题。通过将队列配额设置为0 MB来创建LVQ。

然后让订阅应用程序使用来自LVQ的消息。

在设备中，您应该看到与使用直接消息发送时几乎相同的性能，因为它永远不会碰到假脱机。