問題タブ [stomp]

PHP Stomp クライアントを使用して、stomp メッセージを送信しています。

バックグラウンドで永続的な接続を開いたままにして、時々メッセージを送信したいと思います。

ただし、(send() で) 接続を開いた後に接続エラーが発生した場合、接続エラーを処理する方法が見つかりません。

たとえば、実行時:

出力：send successful

で接続が切断されてもsleep()、send()常に true を返します。

ドキュメントはあまり役に立ちませんでした。また、戻ってきてもStomp::error()あまり役に立ちません。stomp_connect_error()false

一時的な解決策として、毎回の前に再接続していsend()ます。

接続エラーをキャッチするより良い方法はありますか?

私は、ストンプ サーバー/ブローカーとしてアクティブな mq 実装を使用して、ストンプ プロトコルを使用しています。クライアントがオフラインである間にいっぱいになることができるストンプクライアント用のメッセージキューが欲しいです。

私が読んだように、これは単純なサブスクリプションまたは永続的なサブスクリプションで実現できます。定期購読を決めました。これは正しい方法ですか？

次に、クライアント側で使用するメッセージとヘッダーを考えていました。実際に私は以下を使用しています

接続

• ログインする：
• パスコード:
• クライアント ID: some_mac_adr

申し込む

• 宛先: /queue/some_mac_adr
• 領収書: 領収書メッセージ
• 永続サブスクライバー名: デフォルト

今、メッセージを待っています

タイムアウト -->

切断する

このメッセージ シーケンスは正しいですか? さらに、購読解除コマンドを使用していません。これも正しいですか？

フェールオーバーも実装している python stomp ライブラリを探しましたが、誰も見つかりませんでした。また、1000 台のマシン (消費者プログラムを実行するためのクライアント) では、pyactivemq のセットアップ (これはフェイルオーバーをサポートしていると記載されています) は非常に困難です。ブローカーに障害が発生した場合にクライアントがメッセージを受信できるように、既存の Python ストンプ ライブラリの上にラッパーを作成したいと考えていました。

1 つのブローカーが失敗したときに 2 つのブローカーのいずれかからメッセージを取得する方が簡単です。単一の try catch を使用してから、他のブローカーへの接続を試みるだけです。しかし、フェールオーバー中にフェッチされたメッセージをマスターがどのように知るかはわかりません。マスターが起動すると、クライアントはそれらのメッセージを再び見るからです。

このためのブローカー構成で行うことができる提案はありますか?

Python ストンプ コンシューマーが (activemq ブローカーから) メッセージをサブスクライブして受信する実際の例を見つけることができました。python stomp API を確認しましたが、 のようなものはサポートしていないようconn.receiveです。とにかく私は同じ効果を達成することができますか？

Stomp ActiveMQ は初めてです。Android クライアントからログインを作成したいのですが、ActiveMq の使用方法がわかりません。アクティブな mq をインストールし、stomp を構成して、stompexample を実行しました。1. 次の行を activemq.xml に追加すると、コマンド ラインから activemq を実行するとエラーが発生します。

1. 誰かが tx1 と tx2 とは何かを説明できますか? キューでメッセージを特定のクライアントに送信する方法はありますか? どうやって？

   connection.connect("システム", "マネージャー");

   /li>

2. ユーザー名、パスワードを含むテキストをキューに送信し、登録が成功した場合に応答を受け取るアプリケーションの作成方法を教えてください。

ストンプメッセージを取得するコードがありますが、これは機能します。次に、stompメッセージからxmlを取得して、何かを実行したいと思います。これは、コードがあり、機能します。

課題は、メッセージから断片を取り除き、xmlのみを取得することです。

ストンプメッセージのサンプルを次に示します（はい、データは同じですが、ここでは関係ありません）。

私がやりたいのは、「MESSAGE」から始まり、xmlで始まる各行の前の改行までのメッセージ内のすべての行を削除することです。これにより、xmlパーサーを使用して解析するために必要な結果が得られます。

私は試した：

ただし、これにより、最初の行の「MESSAGE」の最初の出現からxmlの最後の出現までのすべてが削除されます。つまり、最初の「MESSAGE」と最後の「xml」の間のすべての行が削除されます。

何か案は？私は次のようなさまざまなトリックを使ってみました。正規表現、implode / explode、ファイルへの書き込み/読み取りなど。ただし、上記のpreg_replaceコードは機能していると思います。必要なのは、すべての出現箇所を認識できることだけです。「while」ループまたは「foreach」ループのいずれかが含まれることはわかっていますが、すてきでクリーンなソリューションを楽しみにしています。どんな助けでも大歓迎です。

Windows Server2008R2で実行されているApollo1.3に問題があります。Webアプリケーション（stomp-phpを使用するPHP）からSTOMPメッセージを送信しています。このメッセージは、Windowsサービスとして実行されているアプリケーションで処理されます。これはしばらくの間は正常に機能しますが、メッセージをApolloにプッシュすると、突然、「仮想ホストが停止しました」というエラーが発生します。

Apolloはまだ実行中であり、Webインターフェイスから仮想ホストにアクセスすることもできます。（これまでに見つけた）サービスを再度実行する唯一の方法は、サービスを停止して、ブローカーのデータフォルダー内のすべてを削除し、サービスを再開することです。サービスを再起動するだけでは機能しません。

apollo.logのスニペットは次のとおりです。

これらは私が見つけることができる唯一の例外です。

コードの問題というよりは構成エラーだと思いますが、関連するコードスニペットは次のとおりです。

これは、仮想ホストが一定時間非アクティブ（つまり、メッセージや接続を受信しない）のときにトリガーされると思います。したがって、これがトリガーされないように、時々apollo-brokerを再起動することを考えていましたが、これが実際に仮想ホストを停止するトリガーになるかどうかはわかりません。

仮想ホストが突然停止する理由と、これを防ぐために必要な構成の変更を誰かに教えてもらえますか？ドキュメントを検索しましたが、仮想ホストの存続期間などについては何も見つかりませんでした。

プロジェクトの 1 つで ActiveMQ (STOMP) を使用する予定です。要件の 1 つは、ユーザーが不適切であることが判明した場合、そのユーザーを追放/禁止することです。STOMPでこれをどのように達成できますか? IRC の KICK のようなもの。

ObjectMessage インスタンスに整数メッセージを生成する Java ActiveMQ プロデューサーがあります。

Python 側では、キューでリッスンするために stomp python を使用します。ただし、すべてのヘッダーが正しく受信されているにもかかわらず、空のメッセージ本文を受信します。

さらに、Java側でメッセージタイプをTextMessageに変更すると、python-consumer側で正しいメッセージが得られます。

PyactiveMQ でも試しましたが、同じ効果がありました

任意の提案をいただければ幸いです!!!

編集：これは、Pythonでストンプをテストするために書いたボイラープレートのJavaプロデューサーコードとPythonサブスクライバーコードです

および Python Stomp リスナー

ノードサーバーでstomp-jsを使用して、同じコンシューマーへのメッセージをキューに入れようとしていました.

プロデューサー：

消費者：

同じ JMSXGroupID を使用して 2 つのメッセージを送信していましたが、クライアントは両方のメッセージを並行して処理しているように見えます。「correlation-id」を使用してみましたが、どちらも機能していないようです。誰かがより良い方法を提案できますか? よろしくお願いします、チャンドラ。