activemq - 一个 MQTT 订阅者可以同时接收同一主题的多条消息吗？

Question

我正在尝试在我的 Spring Boot 应用程序中创建订阅者。我的目标是发布者将向一个主题发送多条消息，我必须获取这些消息并处理它们。我注意到 Paho 和 Apache ActiveMq 的“handleMessage”一次将处理 1 条消息。可以并发吗？？

我试过以下

1. 用 ActiveMq 替换 Paho
2. 在我的 listenercontainer 中提供并发
3. 在我的订阅 URL 中提供预取

请让我知道是否有任何方法可以让我的 MQTT 订阅者同时接收多条消息。

谢谢你

Answer 1

如果您提供自己的线程池，则可以让该handleMessage方法将传入消息传递给线程池进行处理，然后将下一条消息传递给池。