MQTT 订阅者能否同时接收同一主题的多条消息?
Can a MQTT Subscriber be able to take concurrently multiple messages of the Same Topic?
我正在尝试在我的 Spring 引导应用程序中创建订阅者。我的 objective 是发布者将向一个主题发送多条消息,我必须获取这些消息并处理它们。我注意到 Paho 和 Apache ActiveMq 的 "handleMessage" 将一次处理 1 条消息.是否可以并发?
我试过以下
- 用 ActiveMq 替换了 Paho
- 在我的 listenercontainer 中提供并发性
- 在我的订阅中提供预取 URL
如果有任何方法可以让我的 MQTT 订阅者同时接收多条消息,请告诉我。
谢谢
如果您提供自己的线程池,您可以让 handleMessage
方法将传入消息传递给线程池进行处理,然后将下一条消息传递给线程池。
我正在尝试在我的 Spring 引导应用程序中创建订阅者。我的 objective 是发布者将向一个主题发送多条消息,我必须获取这些消息并处理它们。我注意到 Paho 和 Apache ActiveMq 的 "handleMessage" 将一次处理 1 条消息.是否可以并发?
我试过以下
- 用 ActiveMq 替换了 Paho
- 在我的 listenercontainer 中提供并发性
- 在我的订阅中提供预取 URL
如果有任何方法可以让我的 MQTT 订阅者同时接收多条消息,请告诉我。
谢谢
如果您提供自己的线程池,您可以让 handleMessage
方法将传入消息传递给线程池进行处理,然后将下一条消息传递给线程池。