MQTT后端缩放

Question

我目前正在开发一个典型的IoT服务。目前，多个设备连接到一个MQTT代理(MQTT)，我的java后端也连接到代理(Paho)。

我看到的问题如下:当我要拥有我的java后端的多个实例时，每个后端将接收和处理接收到的每条消息。这是个大问题。我只想向一个java后端传递一条消息。有谁知道如何处理这个问题吗？

顺便说一句: Java后端将根据负载添加或删除。

Answer 1

有几种选择

1. 在应用程序和MQTT代理之间放置一个排队系统，可能类似于Apache Kafka。
2. HiveMQ和IBM MessageSight代理支持(不同的实现)共享订阅。这允许在多个客户端之间共享消息。共享订阅很可能正式添加到MQTTv5规范中，这意味着它将被添加到更多的代理中，并有一个标准的实现。