問題タブ [apollo]

私は 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

何が起こっている？

現在、Scala を使用して CONNECT Stomp フレームを ApolloMQ ブローカーに送信しようとしています。私は次のことをしています：

次に接続して書き込もうとすると

と書いているようですが、何も返ってこず、すぐに接続が切れてしまいます。ByteBuffer最初を巻き戻せば

接続が Apollo にヒットしているように見えますが、以下がスローされます

私は周りを検索しましたが、なぜこれが起こっているように見えるのかについての情報を見つけることができません.

私は本番用にRabbitMQでSpring-AMQPライブラリを使用しています。「きれいに」動作するいくつかのテストを書きたかったので、組み込みブローカーを使用して応答をモックすることを考えていました。Rabbit を埋め込むことができないことはわかっていますが、Spring AMQP が Apollo で動作するか、JVM で動作する別のブローカーで動作するかどうか疑問に思っていました。

パブリッシュとサブスクライブのみを行い、必要に応じてキューを設定するためにベンダー固有のコードを使用することは問題ありません。

ありがとう！

*MQ の経験はありませんが、JMS とメッセージ キュー全般に関する知識を構築したいと考えています。このように、私は ActiveMQ から始めるか、それともまったく「無視」して Apollo を独学で始めるかを考えています。Apollo は ActiveMQ と同じくらい機能が充実していますか? JMS 2.0 を実装していますか (ActiveMQ は 1.1 で行き詰まっているようです)? 私は本当に重要なものを見逃すでしょうか？

また、Kafka はこれら 2 つのソリューションと比べてどうですか?