rabbitMQのキューメッセージについて

rabbitMQを使用してメッセージの送受信を行っています。

PublisherとSubscriberを作成してメッセージの送受信は出来たのですが、
Subscriberが接続している時だけで、Subscriberが接続していない時に送信すると
メッセージがMQサーバ上に残らないように見えます。
特にログ上でもエラーは出ていませんので、正常に送信完了しているようです。

MQサーバは送信されたメッセージを貯めておき、読み込む側(Subscriber)が取りに来た時に
出してあげるシステムだと思っていたのですが、そもそもその認識自体が
間違っているのでしょうか。

Subscriberが一時的な障害等によってセッションが切れてしまう状況はあり得ると思うのですが…

行動規範の内容に同意します

回答1件

ベストアンサー

読み込む側(Subscriber)が取りに来た時に出してあげるシステム

この認識が違っています。
http://itdoc.hitachi.co.jp/manuals/link/cosmi_v0870/APKC/EU070377.HTM
このあたりが参考になるかと思いますが、サブスクライバが興味があるトピックに配信依頼をしておく必要があります。

パブリッシャーとサブスクライバーが処理を実行するタイミングには依存性があります。トピックに登録されたメッセージは，メッセージが登録される前に開始されていたサブスクライバーだけに配信されます。

Subscriberが一時的な障害等によってセッションが切れてしまう状況

このような場合、MQTTサーバ実装では、セッションを保存しておき、サブスクライバが最接続した際にQoS設定により切れている間のメッセージを送付したりしなかったりするようです。
http://public.dhe.ibm.com/software/dw/jp/websphere/wmq/mqtt31_spec/mqtt-v3r1_ja.pdf

投稿2020/04/01 04:55

t_obara

総合スコア5488

mugichon

2020/04/01 10:20

ご回答ありがとうございます。なるほど、認識自体が間違っていましたか… ページ見させていただきました！永続化サブスクライバーとして登録すれば良さそうですね！ rabbitMQでやってみると、通常のキューで登録するとなぜかメッセージが蓄積できるのにTOPICで登録すると消えてしまうということが今日分かり、なんでだろー…という感じです。。不思議な所ではありますが、確認してみたいと思います。ありがとうございました！