1

私は Apache Apollo サーバーを使用しており、amqp を使用して Java クライアントを介してトピック メッセージを正常に生成および消費しています。

ここで、websocket (stomp-websocket ライブラリ) を介して、stomp を使用してこれらの同じトピックに接続したいと考えています。サンプルのチャット ページをセットアップし、Java クライアントと Stomp クライアントを使用して同じトピックに正常に接続しました (apollo 管理ページには 3 つのコンシューマーがリストされています - 1 つの Java クライアントと 2 つの Stomp クライアントが異なるタブに表示されます)。

ストンプ クライアントでメッセージを送信すると、他のストンプ クライアントはメッセージを受信しますが、Java のクライアントは受信しません (プロデューサー カウントが 1 に増えます)。Java プロデューサーを介してメッセージを送信すると、すべてのクライアントが接続表示に従ってメッセージを受け取りますが、メッセージはストンプ クライアントに表示されません。

以下は、stomp クライアントからのメッセージです。

<<< MESSAGE サブスクリプション:sub-0 メッセージ ID:bad_santa-82a4 宛先: /topic/chat.general

asfdae

以下は、stomp クライアントのデバッグ領域に表示される Java クライアントからのメッセージです。

<<< MESSAGE サブスクリプション:sub-0 宛先: content-length:174 content-type:protocol/amqp-1.0 message-id:bad_santa-82a5

SpÀBPSrÁ£ x-opt-to-type¡topicSsÀM $bd28666a-d496-4ccb-82a9-bbc3c2782b02@¡topic://chat.general@@@@@@B¸ëìåStÁSw¡postman messageSxÁ£origin¡bad_santa-82c

何が起こっている?

4

0 に答える 0