問題タブ [activemq]

Java コードを使用して完全に構成された組み込みブローカーがあります (デプロイ可能な xml ファイルはありません)。ブラウザで Web コンソールを表示すると 404 が表示され、lsof は 8161 でリッスンしているものがないことを示します。Java コードだけで Web コンソールを使用することはできますか? ActiveMQ に付属の Web サーバーを使用しても問題ありません。ポート 8161 を使用しても問題ありません。

私は ActiveMQ をメッセージ ブローカーの候補として評価してきました。ActiveMQ のパフォーマンスの制限を理解するために、いくつかのテスト コードを作成しました。

次のようにできるだけ早くメッセージを送信することで、ブローカーで失敗状態を生成できます。

驚いたのはそのライン

ブローカが失敗状態になるとブロックします。何らかの例外がスローされることを期待していたので、ブローカーが失敗したという兆候があるでしょう。

テスト コードがブローカーにスパムを送信していることに気付きました。ブローカーが失敗することを期待しています。ただし、単にブロックするのではなく、ブローカーが「大声で」失敗した方がよいと思います。

これは非現実的な期待ですか？

アップデート：

Uri の回答は、3 月に提出された ActiveMQ バグ レポートを参照しています。バグの説明には、私が探しているもののように聞こえる提案が含まれています。待っているスレッドを構築するよりも。」

ただし、8 か月後、バグは現在 1 票で割り当てが解除されています。だから私は疑問がまだ残っていると思います.これはActiveMQが実装すべき(実装する?)ものですか?

外部に面したサーバーで実行され、STOMP インターフェイスを公開している ActiveMQ のインスタンスがあります。

外部に接続されたクライアントがトピック通知のみを受信でき、トピック自体には何も送信できないようにしたいと考えています。内部接続されたクライアントは、受信と送信の両方を行うことができます。

IP ルールに基づいてトピックへのアクセス許可を定義するトピックまたはサーバー レベルで設定できるいくつかのルールがあることを期待していましたが、これへの参照が見つかりません。

これを行う方法、または目的の効果を達成するための代替方法について誰か提案がありますか?

ActiveMQ 5.2を使用していますが、アプリケーションには500,000付近の多数のトピックが必要です。アプリケーションを実行すると、約1000のトピックのみを作成した後、ActiveMQはOutOfMemoryExceptionをスローします。

ActiveMQがこの数のトピックをサポートすることを期待するのは不合理ですか？

この使用法に最適な構成はありますか？

このスレッドは問題の詳細を示しています：http：//www.nabble.com/java.lang.OutOfMemoryError%3A-unable-to-create-new-native-thread-on-AMQ-5.0-td17005441.html

まあ、4つのことすべてではないかもしれませんが、私の状況は次のとおりです。

ActiveMQ バックエンドがあります (デスクトップ Mac で実行されています)。これは、基本的にログを追跡してクライアントをデバッグするためのエコー サーバーとして使用しているストック Apache ActiveMQ サーバーです。クライアントは、AsyncSocket を使用して Stomp.framework 実装をハッキングした iPhone プロジェクトです。

AsyncSocket Cocoa ライブラリを使用して Stomp サーバーと通信する必要がありますが、これは多かれ少なかれ機能しています。メッセージをキューに送信し、それらを読み返すことができるので、そこは得意だと思います。

しかし、SSL を使用するようにすべてを設定しようとすると (要件でもあります)、返される NSError オブジェクトから次のエラーの説明が表示されます。

私は一生、このエラーコードが何であるかを理解できません。誰にも手がかりがありますか？

AsyncSocket の SSL をセットアップする方法は次のとおりです。

編集：ここに正しいコードを追加しました。自己署名証明書に注意してください。

}

誰にもアイデアはありますか？ストリームのプロパティを正しく設定していると思います。多分それはActiveMQセットアップと関係がありますか? ActiveMQ で SSL over Stomp プロトコルを有効にする以外の構成は行いませんでした。証明書などはありません。たぶんそれが問題ですか？

どんな洞察も大歓迎です！

ActiveMQ に基づくアプリケーション インフラストラクチャを構築しました。

メッセージを問題なく送受信でき、ほとんどの場合、かなり高速で問題ありません。

ただし、メッセージのバッチを「一度に」送信すると、たとえば 5,000 件のメッセージを送信すると、ActiveMQ は相手側のサードパーティ アプリケーションにメッセージを非常に迅速に取得し、このアプリケーションも非常に迅速に処理することに気付きました。 、また、応答をブローカにすばやく (たとえば 1 分以内に) キューに入れます。

しかし、何らかの理由で、最初にメッセージを発信した VB.NET EXE は、受信した返信メッセージを不規則に処理しているように見えます。毎秒 1 つ。

レシーバーは、おそらく 9 か月前に ActiveMQ からダウンロードされた C# コードからのイベント MessageListener を待っています。

何が起きているかというと、MessageListener は 1 つのメッセージ (NMS.IMessage) しか提供しないので、それを処理します。

「MessageListener イベントで、現在キューに他のメッセージがあるかどうかを確認し、すべて実行してください」と言う方法はありますか?

メッセージを JSON 形式で ActiveMQ サーバーに送信しています。内部のデータでセレクターを使用できるようにするために、JMS Transformation を使用して、JSON でエンコードされたオブジェクトを真の Java オブジェクトに変換しようとしています。

Stomp と Message Transformation に関するドキュメントへのリンクは次のとおりです 。これは、誰かが正当な JSON オブジェクトの例を示しているパッチに関するディスカッションへのリンクです。

私が送信している JSON オブジェクトの形式 (整形式) は、次のようになります。

メッセージはメッセージ キューに到着しますが、transformation-error プロパティが「msg : msg」に設定されています。

ActiveMQ クライアントを使用する .NET サービスがあります。メッセージを消費するために、トランザクション接続を使用して MessageListener を実装しました。

ときどき、メッセージがキューに入れられた順序とは異なる順序でメッセージを受け取ることがあります。

MessageListner を使用するのは間違っていましたか? メッセージの順序を維持する方法はありますか?

参考までに: メッセージをキューに入れる 1 つのプロデューサーと、キューからメッセージを取り出す 1 つのコンシューマーがあります。

ドキュメントで説明されているように、activemq.xml (ActiveMQ バージョン 5.2.0) で構成することにより、キューをセットアップしました。

次のコードを使用して、(同じホスト上の) Java からアクセスしようとしています。

キューは jconsole (Tree / org.apache.activemq / Queue) に表示されますが、次のエラーが表示されます。

私が間違っていることを教えてください。大変感謝します！

2 種類のクライアントからのリクエストを処理する ActiveMQ インスタンスを (主に STOMP サーバーとして) セットアップしたいと考えています。

1. トピックの読み書きができる認証済みユーザー
2. トピックからの読み取りのみが可能な認証されていないユーザー

これまでSimpleAuthenticationBrokerを使用してきましたが、上記の状況を構成する方法がわかりません。また、ユーザーが認証を通過するためのワイルドカードを認識するコードも見当たりません。

認証ブローカーを使用するようにサーバーを構成すると、すべての接続が認証されることが期待されますが、これは望ましくありません。

私が考える唯一の解決策は、必要な機能をサポートする独自の実装を提供することですが、サーバーに組み込まれた方法を見つけたいと思っています。