問題タブ [stomp]

ActiveMQ で次のシナリオをテストしようとしています。

1. ActiveMQ との接続を確立/開く
2. 「Queue_name」が ActiveMQ で使用可能かどうかを検証します
3. 見つかった場合は、「キュー」で利用可能なエンティティの数を出力します
4. 「キュー」からのメッセージを検証して出力します

データがどのように公開されるかは気にしません。キューにアクセスし、stomp ruby​​ クライアントを使用してそこからデータを読み取る方法を探しましたが、明確な答えが見つかりませんでした。私がオンラインで見つけた例のほとんどは、イベントの公開と購読に関するものでした。

これを解決するための助けを本当に感謝します。

EventMachine でチャット サーバーを作成しようとしています。スレッドセーフな方法で、ある EventMachine 接続から別の EventMachine 接続にメッセージを渡すにはどうすればよいですか?

メッセージング プロトコル (Stomp) がサポートされているようですが、その使用方法がわかりません。どんな助けでも大歓迎です。

EventMachine で Stomp - http://eventmachine.rubyforge.org/EventMachine/Protocols/Stomp.html

クライアントからSTOMP over WebSocketメッセージを受信するWebSocketサーバーがあります。実際のクライアントはこれを行うために JavaScript を使用しています。しかし、Java でテスト クライアントを作成したいと考えています (JavaScript はよくわかりません)。問題は、私が見つけた Java 用の STOMP クライアント ライブラリ (ActiveMQ や stompj のものなど) が、WebSocket の使用をサポートしていないように見えることです。私は STOMP と STOMP over WebSockets の概念にまったく慣れていないので、何かが足りないのか、これを行うための公的サポートが本当にないのか疑問に思っていました。ありがとう。

Stomp を使用して AMQ から 1 つのメッセージを読み取ると、3 つまたは 4 つのメッセージがキューから取り出されます。理由はわかりません。

AMQ を入力するためのコード:

AMQ を読み取るためのコード:

readFrame() コードをストンプします。

コードが 1 回だけ実行されていることは 100% 確信していますが、結果は次のようになります。

Var_dumped メッセージ:

この動作の原因を知っている人はいますか?

注意事項:

• メッセージの ACK がないため、メッセージを 1 つでもデキューする必要はありません :|
• ACK はクライアント モードです
• プリフェッチ サイズは 1 に設定されます

Stomp を介して Web クライアントを ActiveMQ メッセージング サーバーに登録しています。クライアントにはユーザー名があり、セレクターを設定して共通のトピックに登録します。

クライアントは、ヘッダーに「to」属性を設定してメッセージを送信します。より複雑なセレクターでブロードキャスト メッセージを受信することは可能ですか? 私は次のようなものを探しています

すべてのユーザー宛てのメッセージを受信します。

メッセージング ミドルウェアとプロトコルのベンチマークを行っています。
テストしている各プロトコルの概要を書きたいと思います。ライセンスを除いて、STOMPに関する情報は見つかりませんでした。公式ウェブサイトは非常にまばらで、ウィキペディアの用語はスタブであり、オンライン検索でも何も出てきません。

プロトコルを所有し維持しているのは誰ですか? 仕様を公開するのは誰ですか? あると嬉しいのは、プロトコルの進化に関する歴史的事実です。

STOMPプロトコルを介していくつかのActiveMQトピックとキューに接続するiOSクライアントがあります。サーバーに接続すると、次のメッセージが送信されます。

次に、次のメッセージを使用していくつかのトピックをサブスクライブします。

ActiveMQサーバーで2つの問題に直面しています。接続するたびにNumber of Consumers、Webインターフェイスの列がインクリメントされるため、実際のコンシューマーは1つだけですが、コンシューマーの数は約50です。しかし、最も問題のある問題は、メッセージング環境をテストするために別のiOSデバイスをラップトップに接続すると、ActiveMQに接続するときに次のエラーが発生することです。

これは、他のデバイスがアプリを実行していないときにこのロギングの試行が行われるため、STOMPを介したActiveMQからの切断が適切に機能していないようです。この問題を解決するために、次のことを試しました。

• トピックをサブスクライブしようとするときは、常にログオフしてください。
• 申し込む

現在、ラップトップでサーバーを実行しているv5.6.0を使用しています。

node.jsをjmsトピックへのクライアントとして使用しています。トピックで接続を確立するために使用できるプロトコルは2つあります。これらはStompとAMQPです。http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol およびhttp://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocolでそれらについて簡単に読んでいます。どちらも有線レベルのプロトコル、つまりオクテットのストリームとしてネットワークを介して送信されるデータのようです。どちらを優先すべきか具体的な理由はわかりません。誰かがそれに光を当てることができれば、それは役に立ちます。

もう1つのポイントは、両方のプロトコルが相互運用可能であると述べることに誇りを持っていることです。相互運用可能な用語は、誰かが特定のメッセージブローカーの実装を削除してapache active MQを実行し、代わりにWebsphere MQをプラグインしたい場合、移行がスムーズになることを意味しますか（AMQP / STOMPまたはその他のワイヤーレベルプロトコルの両方をサポートしている場合）？

WebSockets https://github.com/jmesnil/stomp-websocketを介して ActiveMQ を Stomp で動作させることができましたが、同じ IP/ルーターを共有する複数のコンシューマー/サブスクライバーに関連する奇妙な問題が発生しています。

ActiveMQ サーバーはオフィスの外にあります。オフィスの 2 人のサブスクライバーがキューに接続すると、キューにディスパッチされたメッセージは一度に 1 つのサブスクライバーにのみ送信され、両方のコンシューマーに同時に送信されることはありません。

ActiveMQ 管理パネルの [接続] タブを見ると、次のように表示されます。

ID:ip-10-32-59-175-56297-1352930853863-2:199 StompSocket_565594188 true false

ID:ip-10-32-59-175-56297-1352930853863-2:370 StompSocket_350506451 真偽

ActiveMq 構成に関して何か不足していますか?これは Stomp JS ライブラリに関連していますか、それとも何か他のものですか?

ありがとう。

ActiveMQ Stompサーバーで宛先（キューまたはトピック、関係ありません）をリッスンし、受信したメッセージをコンソールに記録する次のコンソールプログラムがあります。

私がそれを始めるとき、私がメッセージを送り続ける限り、それはうまく働きます。しかし、30秒間非アクティブになると、例外が発生します。これは、キューにメッセージを送信しなくても発生します。

グーグルで調べて、Apache.NMSソースコードを読んだところ、「InactivityMonitor」で何かをしなければならないことがわかりtransport.useInactivityMonitor=falseました。接続文字列でパラメータを指定しても、例外は発生しません。正常に動作します。

しかし、私がすべてを理解していると思う限り、そのinactivityMonitorには、「デッド」接続が検出され、適切にクリーンアップされていることを確認するという目的があります。

だから何か他の問題があるに違いない！上記のコードに単純なコンソールトレーサーを追加しました。これは、transport.useInactivityMonitor=falseパラメーターなしで接続した場合の出力です。

ですから、私のクライアントは、あまりにも長い間非アクティブであったために、ブローカーによって「キック」されていると思います。しかし、上記のログから、クライアントが実際に「キープアライブ」メッセージを送信している理由がよくわかりません。したがって、非アクティブであってはなりません。

この問題をどのように進めるかについては、選択肢がありません。誰かがこれについて何らかの洞察を持っているなら、それは大抵感謝されるでしょう！

更新：
バージョン番号：

• ライブラリ：Apache.NMS.Stomp v1.5.3
• ブローカー：Apache ActiveMQ 5.6.0