Jboss-fuse-apache-amq
JBoss Fuse-Apache AMQ
この章では、ActiveMQと、アプリケーションが相互に通信できるようにするためのメッセージブローカーとしての機能について説明します。
AMQとは何ですか？
ActiveMQは、Javaで書かれたオープンソースのメッセージブローカーです。 JMS 1.1標準に完全に準拠しています。
JMSは、メッセージベースのシステムの開発を可能にする仕様です。 ActiveMQは、アプリケーション間に存在するメッセージのブローカーとして機能し、非同期で信頼できる方法で通信できるようにします。
メッセージングの種類
理解を深めるために、以下に2種類のメッセージングオプションを説明します。
ポイントからポイントへ
このタイプの通信では、ブローカーは1つのコンシューマーのみにメッセージを送信しますが、他のコンシューマーはブローカーからメッセージを取得するまで待機します。 消費者は同じメッセージを受け取りません。
コンシューマーがない場合、ブローカーはコンシューマーを取得するまでメッセージを保持します。 このタイプの通信は、*キューベースの通信*とも呼ばれ、プロデューサはメッセージをキューに送信し、1つのコンシューマのみがキューから1つのメッセージを取得します。 複数の消費者がいる場合、次のメッセージを受け取ることがありますが、他の消費者と同じメッセージを受け取ることはありません。
公開/購読
このタイプの通信では、ブローカーはすべてのアクティブなコンシューマーに同じメッセージのコピーを送信します。 このタイプの通信は、*トピックベースの通信*とも呼ばれ、ブローカーは特定のトピックを購読しているすべてのアクティブな消費者に同じメッセージを送信します。 このモデルは、送信されたメッセージの検証が期待されない一方向通信をサポートします。
キューとトピックの作成
ヒューズはActiveMQにバンドルされています。 FMCコンソール（AMQで動作するブラウザーベースのインターフェイス）を使用してActiveMQにアクセスできます。
*localhost：8181* を使用してFMCにログインし、 *ActiveMQ* タブを選択します。- [+作成]をクリックします
- キュー/トピック名を入力してください
- ラジオボタンからキュー/トピックを選択
- キューの作成/トピックの作成をクリックします
これで、ルート→キュー→の下に作成された TestQ が表示されるはずです。
作成されたトピックを確認するには、ルート→トピックに従ってください。
キューの内容の参照/削除
- localhost：8181 を使用してFMCにログインします
- ActiveMQタブを選択します
- ルート→キュー→TestQ <参照するキューを選択>→参照
- このメッセージの内容を確認するには、その特定のメッセージをクリックしてください。
- 特定のメッセージを削除するには、右上にある[削除]ボタンをクリックします
