問題タブ [hornetq]

JBoss 5.1 EAP で JMS プロバイダーとして HornetQ を使用しており、通常、HornetQ のパフォーマンスには非常に満足しています。

HornetQ は、2.2.2 でのデータ複製サポートをサイレント モードで削除しました。現在、現在の HornetQ フェイルオーバー戦略は信頼できないため、JBoss と HornetQ を使用して HA ソリューションを作成する際に問題が発生しています。たとえば、マスターがオンラインに戻った後、クライアントが HornetQ に再接続する際に問題が発生します。ラウンド ロビン戦略を使用する場合、メッセージはストア アンド フォワード キューに格納されます。これにより、ノードがシャットダウンした場合にメッセージが配信されなくなります。

HornetQ は進化していますが、データのレプリケーションがなければ、生産環境のための本格的なソリューションにはなりません。

優れたパフォーマンス、モニタリング、そしてもちろん JBoss 5 の相互運用性と併せて、本番環境で安全な HA およびフェイルオーバー機能をサポートする JMS プロバイダーはどれですか?

次のテストクライアントコード（https://github.com/jmesnil/stomp-websocketを使用）では、JBoss7.0.1で例外が発生します。

これは、以下の1行でも発生します。

JBoss HornetQが次の例外を報告するのはなぜですか？

hornetqでstompを使用して同期メッセージングを行う方法、または可能であればそれを理解しようとしています。非同期ストンプクライアントが動作していますが、同期バージョンを実装する方法がわかりません。

サーバー側では、私のアクセプターは次のようになります。

私のリスナーは次のようになります。

JMSの場合と同じように、一時キューに何かを入れて送り返す必要があると思います。それがSTOMPでどのように機能するかは私にはわかりません。サーバー側の「一時キュー」に対応する別のtcp接続をクライアント側で開く必要がありますか？

トランザクションと HornetQ ネイティブ API に関して基本的な疑問があります。

アプリケーションが Spring ベースで、Spring 管理のトランザクションを使用している場合、Spring (AOP) が管理する同じトランザクションに参加するには、HornetQ をどのように設定すればよいですか?

JMS API を使用すると、Spring は JMS リソースをトランザクションと見なすため、かなり明白だと思います。

しかし、nativa API を使用して正しく行う方法がわかりません。誰かがこの問題に光を当てることができますか?

どうもありがとう！

最近、JBoss 4.2 から JBoss 6.1 にアップグレードしました。新しい JMS メッセージング (現在は HornetQ を使用) が停止し、15 のコンシューマーが存在しますが、処理されるメッセージは 15 を超えません。メッセージが確認されていない確認問題のようです。これらは EJB 2.0 で作成された MDB によって消費され、確認モードは自動確認です (現在、2.1 に引き上げて違いが生じるかどうかを確認しています)。誰もこれを経験しましたか？サーバーをデフォルトで自動確認するように設定する方法はありますか?

Bean はコンテナ管理のトランザクションにあります。

Hornetq クラスターを設定しようとしていました。1 つのサーバーと 1 つのバックアップ サーバーがあります。ユーザーガイドに記載されているように、configuration.xml を構成しました。しかし、マシンを起動できません。

誰かがこれを知っているなら、私を助けてください..... よろしくお願いします..... :)

私は、それが可能であるかどうか、現在私が認識していない要件を持っています。メッセージに特定のプロパティが含まれている場合、JMS メッセージのエラーを一時的に無効にしたいと考えています。現在、HornetQ をメッセージ プロバイダーとして使用しています。

例を挙げてみましょう:

キューには、次の 3 つのエントリが含まれます。

特定の時点で、アプリは HornetQ メッセージ サーバーに、B_CATEGORY に属するメッセージを現時点で配信してはならないことを伝えることができる必要があります (たとえば、B_CATEGORY オブジェクトの基礎となるデータベースが更新されるため)。そのため、id 2 のメッセージは現時点では配信されませんが、1 と 9 はカテゴリ オブジェクトの値が異なるため配信されます。

アプリケーションをまったく再起動せずに、Java コードから実行する必要があります。これはまったく可能ですか？

ご協力いただきありがとうございます！

この問題に対する別の設計アプローチについて考えてみました。最初のキューにすべての種類のカテゴリのメッセージが含まれていると仮定しましょう (カテゴリごとにキューを作成することはできません。カテゴリがたくさんある可能性があるからです)。この「通常の」キューは、通常は構成されています (たとえば、有効期限はありませんが、DLQ があります)。

リスナーがそのようなメッセージを消費し、特定のカテゴリに属する​​メッセージを処理できないことがわかった場合、それを 2 番目のキューに入れます。このキューには、再配信の遅延と有効期限が設定されています。有効期限を十分に長く設定し (もちろん、キューがオーバーフローすることはありません)、再配信時間を短すぎないように設定すると、上記の質問に対する解決策がない場合でもうまくいくはずです。

もちろん、カテゴリを処理できない間にこれらのキュー エントリがいくつ作成されるかを計算する必要があります。また、カテゴリが利用できない場合に、それに応じて再配信を調整できるようになるまでの時間。

自動ビルドを置き換えようとしているプロジェクトのビルドを作成しようとしています。FIND_JNIを適切に使用する必要があります。

単純なビルドを作成できましたが、jni.hが正しく見つかりません。

また、Javaインクルードを定義する適切な方法（ハックなし）を見つける必要があります。これは、他のユーザーが移植できる必要があるためです。

組み込みクラスター構成を開始しようとしていますが、開始できませんでした。hornetqの例で見つかったクラスターの例を使用しました。それは機能します。埋め込まれたhornetqを使用して例を実行することはありません。例外は発生しませんが、システムが停止します。

そしてこれはHornetQ構成ファイルです：

JNDI を使用せずに JMS リソースを REMOTE HORNETQ に直接インスタンス化しようとしています。

Eclipse IDE でテスト コードを実行しています。HornetQ 2.2.5 ライブラリーを使用するようにクラスパスをセットアップします。

ターゲットの HornetQ はバージョン 2.1.2.Final です。下位互換性があるはずだと思いましたが、間違っているのでしょうか?

さて、オンライン ドキュメントを読み、JNDI を使用せずにリモート JMS サーバーに接続する例に従いました。次の例外が引き続き発生します。何が欠けているのかわかりませんが、すべてが正しくセットアップされていると思います。誰かが私がここに欠けているものを指摘してもらえますか? 前もって感謝します。

JMSException: セッション ファクトリの作成に失敗しました

hornetq-configuration.xml のコネクターは次のとおりです。

アクセプターは次のとおりです。

私のテスト コードは次のとおりです。

次の例外が発生します