MQTTバックエンドスケーリング

Question

現在、一般的なIoTサービスを開発中です。現時点では、複数のデバイスが1つのMQTTブローカー（mosquitto）に接続し、Javaバックエンドもブローカー（Paho）に接続します。

私が見ている問題は次のとおりです。 私は、バックエンドごとに複数のJavaバックエンドインスタンスを受け取り、受け取ったすべてのメッセージを処理します。それは大きな問題です。私はちょうど1つのJavaバックエンドにメッセージを配信したい。誰でもこの問題に対処するアイデアですか？

Btw：Javaバックエンドは、負荷に応じて追加または削除されます。

Answer 1

おそらくオプションのカップル

1. 置き、アプリケーションとMQTTブローカー間のキューイング・システム、Apacheのカフカのようなもの
2. 共有と呼ばれるもののHiveMQとIBM MessageSightブローカーのサポートは、（異なる実装）がありますサブスクリプション。これにより、複数のクライアント間でメッセージを共有することができます。共有サブスクリプションは、MQTTv5仕様に正式に追加される可能性があります。これは、それがより多くのブローカーに追加され、標準実装を持つことを意味するはずです。