AMQ Broker の使用

手順

1. Web ブラウザーで https://access.redhat.com/downloads/ に移動し、ログインします。

   Product Downloads ページが表示されます。

2. JBoss Integration and Automation セクションで、Red Hat AMQ Broker のリンクをクリックします。

   Software Downloads ページが表示されます。

3. Version ドロップダウンメニューから必要な AMQ Broker のバージョンを選択します。
4. Releases タブで、ダウンロードする特定の AMQ Broker ファイルの Download のリンクをクリックします。

手順

1. amq-broker という名前の新規ユーザーを作成して、パスワードを指定します。

   $ sudo useradd amq-broker
   $ sudo passwd amq-broker

2. /opt/redhat/amq-broker ディレクトリーを作成して、新しい amq-broker ユーザーとグループの所有者として指定します。

   $ sudo mkdir /opt/redhat
   $ sudo mkdir /opt/redhat/amq-broker
   $ sudo chown -R amq-broker:amq-broker /opt/redhat/amq-broker

3. アーカイブの所有者を新規ユーザーに変更します。

   $ sudo chown amq-broker:amq-broker amq-broker-7.x.x-bin.zip

4. インストールアーカイブを、作成したディレクトリーに移動します。

   $ sudo mv amq-broker-7.x.x-bin.zip /opt/redhat/amq-broker

5. 新しい amq-broker ユーザーとして、unzip コマンドを使用してコンテンツを展開します。

   $ su - amq-broker
   $ cd /opt/redhat/amq-broker
   $ unzip <archive-name>.zip
   $ exit

   amq-broker-7.7 と似たディレクトリーが作成されます。本書では、この場所を <install-dir> と呼びます。

手順

1. Windows Explorer を使用して、任意のドライブ文字にディレクトリー \redhat\amq-broker を作成します。

   例: C:\redhat\amq-broker

2. Windows Explorer を使用して、作成したディレクトリーにインストールアーカイブを移動します。

3. \redhat\amq-broker ディレクトリーで、インストールアーカイブ zip ファイルを右クリックし、Extract All を選択します。

   amq-broker-7.7 と似たディレクトリーが作成されます。本書では、この場所を <install-dir> と呼びます。

手順

1. ブローカーインスタンスのディレクトリーを作成します。

   使用しているプラットフォーム	こちらを実行します。
   Red Hat Enterprise Linux	ブローカーインスタンスの場所として機能する新しいディレクトリーを作成します。 $ sudo mkdir /var/opt/amq-broker インストール時に作成したユーザーを割り当てます。 $ sudo chown -R amq-broker:amq-broker /var/opt/amq-broker
   Windows	Windows Explorer を使用して、ブローカーインスタンスの場所として機能する新規フォルダーを作成します。

2. artemis create コマンドを使用してブローカーを作成します。

   使用しているプラットフォーム	こちらを実行します。
   Red Hat Enterprise Linux	インストール時に作成したユーザーのアカウントに切り替えます。 $ su - amq-broker ブローカーインスタンス用に作成したディレクトリーに移動します。 $ cd /var/opt/amq-broker ブローカーインスタンスのディレクトリーから、ブローカーインスタンスを作成します。 $ <install-dir>/bin/artemis create mybroker
   Windows	ブローカーインスタンス用に作成したディレクトリーからコマンドプロンプトを開きます。 ブローカーインスタンスのディレクトリーから、ブローカーインスタンスを作成します。 > <install-dir>\bin\artemis.cmd create mybroker

3. artemis create プロンプトに従ってブローカーインスタンスを設定します。

   例4.1 artemis create を使用したブローカーインスタンスの設定

   $ /opt/redhat/amq-broker/bin/artemis create mybroker
   
   Creating ActiveMQ Artemis instance at: /var/opt/amq-broker/mybroker
   
   --user: is mandatory with this configuration:
   Please provide the default username:
   admin
   
   --password: is mandatory with this configuration:
   Please provide the default password:
   
   --role: is mandatory with this configuration:
   Please provide the default role:
   amq
   
   --allow-anonymous | --require-login: is mandatory with this configuration:
   Allow anonymous access? (Y/N):
   Y
   
   Auto tuning journal ...
   done! Your system can make 19.23 writes per millisecond, your journal-buffer-timeout will be 52000
   
   You can now start the broker by executing:
   
   "/var/opt/amq-broker/mybroker/bin/artemis" run
   
   Or you can run the broker in the background using:
   
   "/var/opt/amq-broker/mybroker/bin/artemis-service" start

手順

1. インストール時に作成したユーザーのアカウントに切り替えます。

   $ su - amq-broker

2. artemis run コマンドを使用してブローカーインスタンスを起動します。

   $ /var/opt/amq-broker/mybroker/bin/artemis run
   
             __  __  ____    ____            _
       /\   |  \/  |/ __ \  |  _ \          | |
      /  \  | \  / | |  | | | |_) |_ __ ___ | | _____ _ __
     / /\ \ | |\/| | |  | | |  _ <| '__/ _ \| |/ / _ \ '__|
    / ____ \| |  | | |__| | | |_) | | | (_) |   <  __/ |
   /_/    \_\_|  |_|\___\_\ |____/|_|  \___/|_|\_\___|_|
   
   Red Hat JBoss AMQ 7.2.1.GA
   
   10:53:43,959 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
   10:53:44,076 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=false,journalDirectory=./data/journal,bindingsDirectory=./data/bindings,largeMessagesDirectory=./data/large-messages,pagingDirectory=./data/paging)
   10:53:44,099 INFO  [org.apache.activemq.artemis.core.server] AMQ221012: Using AIO Journal
   ...

   ブローカーが起動し、以下の情報が含まれるログ出力が表示されます。

   • トランザクションログとクラスター設定の場所。
   • メッセージの永続性に使用されるジャーナルのタイプ (この場合は AIO)。

   • クライアント接続を許可できる URI。

     デフォルトでは、ポート 61616 はサポートされるプロトコル (CORE、MQTT、AMQP、STOMP、HORNETQ、および OPENWIRE) からの接続を受け入れることができます。各プロトコルには個別のポートもあります。

   • Web コンソールは、http://localhost:8161 から入手できます。
   • Jolokia サービス (JMX over REST) には、http://localhost:8161/jolokia からアクセスできます。

手順

1. artemis producer コマンドを使用していくつかのテストメッセージを生成し、ブローカーに送信します。

   このコマンドは、ブローカーに自動的に作成される helloworld アドレスにメッセージを 100 個送信します。プロデューサーは、サポートされるすべてのメッセージングプロトコルを受け入れるデフォルトのポート 61616 を使用してブローカーに接続します。

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis producer --destination helloworld --message-count 100 --url tcp://localhost:61616
   Producer ActiveMQQueue[helloworld], thread=0 Started to calculate elapsed time ...
   
   Producer ActiveMQQueue[helloworld], thread=0 Produced: 100 messages
   Producer ActiveMQQueue[helloworld], thread=0 Elapsed time in second : 1 s
   Producer ActiveMQQueue[helloworld], thread=0 Elapsed time in milli second : 1289 milli seconds

2. Web コンソールを使用して、ブローカーに保存されているメッセージを表示します。

   1. Web ブラウザーで、http://localhost:8161 にアクセスします。

   2. ブローカーインスタンスの作成時に作成したデフォルトのユーザー名およびパスワードを使用して、コンソールにログインします。

      Attributes タブが表示されます。

   3. Attributes タブでメニュー:[addresses > helloworld > queues > "anycast" > helloworld] に移動します。

      前の手順で、helloworld アドレスにメッセージを送信しています。これにより、キュー (helloworld という名前) を持つ新しい anycast helloworld アドレスが作成されました。Message count 属性は、現在 helloworld に送信された 100 個のメッセージがすべてこのキューに保存されていることを示しています。

      図4.1 メッセージ数

      

3. artemis consumer コマンドを使用して、ブローカーに保存されているメッセージ 50 個を消費します。

   このコマンドは、以前にブローカーに送信した 50 のメッセージを使用します。

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis consumer --destination helloworld --message-count 50 --url tcp://localhost:61616
   
   Consumer:: filter = null
   Consumer ActiveMQQueue[helloworld], thread=0 wait until 50 messages are consumed
   Consumer ActiveMQQueue[helloworld], thread=0 Consumed: 50 messages
   Consumer ActiveMQQueue[helloworld], thread=0 Consumer thread finished

4. Web コンソールで、メッセージ数 が 50 であることを確認します。

   メッセージが 50 個消費され、helloworld キューに格納されているメッセージ数の残りは 50 個になります。

5. ブローカーを停止し、残りのメッセージ 50 個が helloworld キューに保存されていることを確認します。

   1. ブローカーが実行されているターミナルで、Ctrl+Cを押してブローカーを停止します。

   2. ブローカーを再起動します。

      $ /var/opt/amq-broker/mybroker/bin/artemis run

   3. Web コンソールで、helloworld キューに戻り、キューに保存されているメッセージが 50 個であることを確認します。

6. 残りの 50 メッセージを使用します。

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis consumer --destination helloworld --message-count 50 --url tcp://localhost:61616
   
   Consumer:: filter = null
   Consumer ActiveMQQueue[helloworld], thread=0 wait until 50 messages are consumed
   Consumer ActiveMQQueue[helloworld], thread=0 Consumed: 50 messages
   Consumer ActiveMQQueue[helloworld], thread=0 Consumer thread finished

7. Web コンソールで、メッセージ数 が 0 であることを確認します。

   helloworld キューに保存されているメッセージはすべて消費され、キューが空になりました。

手順

1. 実行する例のディレクトリーに移動します。

   プログラムの例は <install_dir>/examples にあります。以下に例を示します。

   $ cd <install-dir>/examples/features/standard/queue

2. mvn clean verify コマンドを使用して、サンプルプログラムを実行します。

   Maven はブローカーを起動し、サンプルプログラムを実行します。サンプルプログラムの初回実行時に、Maven は不足している依存関係をダウンロードします。この処理には時間がかかる場合があります。

   この場合、queue のサンプルプログラムが実行され、プロデューサーを作成し、テストメッセージを送信してから、メッセージを受信するコンシューマーを作成します。

   $ mvn clean verify
   [INFO] Scanning for projects...
   [INFO]
   [INFO] -------------< org.apache.activemq.examples.broker:queue >--------------
   [INFO] Building ActiveMQ Artemis JMS Queue Example 2.6.1.amq-720004-redhat-1
   [INFO] --------------------------------[ jar ]---------------------------------
   ...
   server-out:2018-12-05 16:37:57,023 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.6.1.amq-720004-redhat-1 [0.0.0.0, nodeID=06f529d3-f8d6-11e8-9bea-0800271b03bd]
   [INFO] Server started
   [INFO]
   [INFO] --- artemis-maven-plugin:2.6.1.amq-720004-redhat-1:runClient (runClient) @ queue ---
   Sent message: This is a text message
   Received message: This is a text message
   [INFO]
   [INFO] --- artemis-maven-plugin:2.6.1.amq-720004-redhat-1:cli (stop) @ queue ---
   server-out:2018-12-05 16:37:59,519 INFO  [org.apache.activemq.artemis.core.server] AMQ221002: Apache ActiveMQ Artemis Message Broker version 2.6.1.amq-720004-redhat-1 [06f529d3-f8d6-11e8-9bea-0800271b03bd] stopped, uptime 3.734 seconds
   server-out:Server stopped!
   [INFO] ------------------------------------------------------------------------
   [INFO] BUILD SUCCESS
   [INFO] ------------------------------------------------------------------------
   [INFO] Total time:  48.681 s
   [INFO] Finished at: 2018-12-05T16:37:59-05:00
   [INFO] ------------------------------------------------------------------------

   注記

   一部のサンプルプログラムは UDP クラスターリングを使用しますが、デフォルトではお使いの環境で機能しない場合があります。これらの例を正常に実行するには、224.0.0.0 に送付されたトラフィックをループバックインターフェイスにリダイレクトします。

   $ sudo route add -net 224.0.0.0 netmask 240.0.0.0 dev lo