AMQ Broker の使用

手順

1. Web ブラウザーで https://access.redhat.com/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.9 と似たディレクトリーが作成されます。本書では、この場所は <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.9 と似たディレクトリーが作成されます。本書では、この場所は <install_dir> と呼ばれます。

手順

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

   使用している場合は...	方法
   Red Hat Enterprise Linux (RHEL)	ブローカーインスタンスのロケーションとして使用する新しいディレクトリーを作成します。 $ 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 (RHEL)	インストール時に作成したユーザーアカウントに切り替えます。 $ 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、および OPEN) からの接続を許可できます。各プロトコルには個別のポートも存在します。

   • 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