実稼働環境を移行予定の場合には、Red Hat サポート担当者からさらにサポートおよびガイダンスを要求する必要があります。https://access.redhat.com/support/ からサポートケースを作成することができます。

本書を使用して、既存の OpenWire JMS クライアントが接続できる AMQ Broker 7 設定の作成に必要な設定変更について説明します。

本ガイドでは、以下の機能の移行方法を説明していません。

各 AMQ 機能エリアでの特定の設定変更について理解する前に、最初に AMQ 6 と AMQ 7 の重要な概念的な相違点を理解しておく必要があります。

AMQ 7 には、いくつかの主要なアーキテクチャー的な違いがあります。さらに、本リリースには新しいメッセージアドレス指定とルーティングモデルが実装されました。

AMQ 7 に移行する前に、主な新機能、改良された機能、および既知の問題を理解する必要があります。その一覧は、『Release Notes for Red Hat AMQ Broker 7.8』を参照してください。

本書では、sudo コマンドおよびファイルパスに以下の表記方法を使用します。

sudo コマンド

本書では、root 権限を必要とするコマンドには sudo が使用されています。sudo を使用する場合は、変更を加えるとシステム全体に影響する可能性があるため、常に注意が必要です。

sudo の使用に関する詳細は、「Managing sudo access」を参照してください。

本書におけるファイルパスの使用

本書では、すべてのファイルパスが Linux、UNIX、および同様のオペレーティングシステムで有効です (例: /home/...)。Microsoft Windows を使用している場合は、同等の Microsoft Windows パスを使用する必要があります (例: C:\Users\...)。

AMQ 7 に移行する前に、お使いの環境が以下の要件を満たす必要があります。

AMQ 7 に移行する前に、AMQ ブローカーインスタンスを作成する必要があります。本書で説明されている AMQ 7 での設定の違いを把握することで、このブローカーインスタンスを設定できます。

AMQ Broker をインストールした際に、AMQ Broker の実行に必要なバイナリー、ライブラリー、およびその他の重要なファイルがインストールされています。ただし、AMQ 7 では、新規ブローカーが必要な場合には、常にブローカーインスタンスを明示的に作成する必要があります。各ブローカーインスタンスは、独自の設定およびランタイムデータが含まれる個別のディレクトリーです。

各 AMQ 7 ブローカーインスタンスには独自のディレクトリーが含まれます。ディレクトリーの内容、および作成したブローカーインスタンスの設定ファイルの場所を理解している必要があります。

ブローカーインスタンスを作成すると、以下のディレクトリー構造が作成されます。

$ ls /var/lib/amq7/mybroker
bin  data  etc  lock  log  tmp

作成したブローカーインスタンスの設定方法と、編集が必要な設定ファイルを理解する必要があります。

AMQ 6 のように、プレーンテキストと XML ファイルを編集して AMQ 7 ブローカーインスタンスを設定します。ブローカーの設定を変更するには、ブローカーインスタンスのディレクトリーで適切な設定ファイルを開き、XML 階層で適切な要素を見つけ、実際の変更 (通常は、XML 要素と属性の追加または削除) を行う必要があります。

BROKER_INSTANCE_DIR/etc 内には、編集できる設定ファイルがいくつかあります。

AMQ 7 に移行するには、主に broker.xml ファイルを編集する必要があります。broker.xml 構造およびデフォルト設定の詳細は、『Configuring AMQ Broker』の「Understanding the default broker configuration」を参照してください。

既存のクライアントが作成したブローカーインスタンスに接続できることを確認するには、ブローカーインスタンスを起動して、テストメッセージを送信する必要があります。

AMQ 6 および AMQ Broker 7 の両方で、クライアントがブローカーに接続する方法を定義できます。これらの接続ポイントは AMQ 6 では トランスポートコネクター と呼ばれていましたが、AMQ Broker 7 では アクセプター と呼ばれます。

AMQ 6 では、トランスポート層の複数の実装 (TCP、NIO など) が提供されました。したがって、クライアント接続ポイントがブロッキングトランスポートまたはノンブロッキングトランスポートを使用するかどうかに応じて、異なるトランスポートコネクターを使用する必要がありました。AMQ Broker 7 では、トランスポート層はデフォルトで非ブロッキングの Netty のみを使用します。AMQ Broker 7 には、2 種類のアクセプターがあります。

AMQ 6 では、メッセージングプロトコルごとに個別のトランスポートコネクターを使用する必要もありました。AMQ Broker 7 では、低レベルのトランスポート (TCP または in-VM のいずれか) は、クライアントによって使用されるメッセージングプロトコル (AMQP、MQTT 等) とは独立しています。つまり、1 つのアクセプターが同じポートで複数のプロトコルを使用できます。実際、使用できるプロトコルを明示的に制限しない限り、アクセプターはサポートされるすべてのメッセージプロトコルを受け入れます。

たとえば、AMQ Broker 7 のデフォルトのアクセプターは、すべてのメッセージプロトコルを自動的に受け入れます。

<acceptor name="artemis">tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>

BROKER_INSTANCE_DIR/etc/broker.xml 設定ファイルを使用して、ブローカーインスタンスの受信クライアント接続を受け入れるようアクセプターを設定します。

broker.xml 設定ファイルには、<acceptors> セクションに以下のデフォルトアクセプターが含まれます。

<configuration>
...
  <core>
  ...
     <acceptors>
       <!-- Acceptor for every supported protocol -->
       <acceptor name="artemis">tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor> 1

       <!-- AMQP Acceptor.  Listens on default AMQP port for AMQP traffic.-->
       <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpMinCredits=300</acceptor>

       <!-- STOMP Acceptor. -->
       <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor>

       <!-- HornetQ Compatibility Acceptor.  Enables HornetQ Core and STOMP for legacy HornetQ clients. -->
       <acceptor name="hornetq">tcp://0.0.0.0:5445?protocols=HORNETQ,STOMP;useEpoll=true</acceptor>

       <!-- MQTT Acceptor -->
       <acceptor name="mqtt">tcp://0.0.0.0:1883?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=MQTT;useEpoll=true</acceptor>
       ...
  </core>
</configuration>

ブローカーインスタンスの受信クライアント接続を設定するには、デフォルトのアクセプターのいずれかの設定プロパティーを変更したり、新しいアクセプターを追加したりできます。以下の例は、OpenWire プロトコルを使用して TCP 接続を受け入れるように設定された新しいアクセプターを示しています。

<acceptor name="my-acceptor">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=OPENWIRE;useEpoll=true</acceptor>

AMQ Broker 7 と AMQ 6 の両方の認証は、Java Authentication and Authorization Service (JAAS) をベースとしたプラグ可能なログインモジュールによって提供されます。ただし、AMQ 6 の グループ は AMQ Broker 7 では ロール と呼ばれます。

さらに、ログインモジュールの名前と場所が AMQ Broker 7 で変更になりました。

ユーザーとロールを追加する構文も異なります。

ブローカーインスタンスの作成時に作成したデフォルトのユーザー名とパスワードを使用して、AMQ 7 ブローカーインスタンスにアクセスできます。追加のユーザーがブローカーインスタンスにアクセスできるようにするには、以下のいずれかの方法でブローカーのユーザー認証を設定できます。

AMQ 6 は、直接設定可能な宛先としてキュー、トピック、永続サブスクリプションなどの JMS の概念を実装しました。

<destinations>
     <queue physicalName="my-queue" />
     <topic physicalName="my-topic" />
</destinations>

AMQ Broker 7 はアドレス、ルーティングタイプ、およびキューを使用して、キューとトピックのような動作を実現します。アドレス はメッセージングエンドポイントを表します。キュー はアドレスに関連付けられます。ルーティングタイプ は、アドレスに関連付けられたキューにメッセージが配信される方法を定義します。ルーティングタイプには 2 種類あります。エニーキャスト の場合、マッチするアドレス内の単一のキューにメッセージを配信し、マルチキャスト の場合、アドレスに関連付けられたすべてのキューにメッセージを配信します。

キューをアドレスおよびルーティングタイプに関連付けることで、ポイントツーポイント (キュー) やパブリッシュ-サブスクライブ (トピック的) などのさまざまなメッセージングパターンを実装できます。

<address name="address.foo">
  <anycast>
    <queue name="my-queue"/>
  </anycast>
</address>

<address name="topic.foo">
  <multicast>
    <queue name="my-topic-1"/>
    <queue name="my-topic-2"/>
  </multicast>
</address>

BROKER_INSTANCE_DIR/etc/broker.xml 設定ファイルを使用して、ブローカーインスタンスのアドレスおよびキューを設定します。

broker.xml 設定ファイルには、<addresses> セクションに以下のデフォルトアドレス指定設定が含まれます。Dead Letter Queue (DLQ) および Expiry Queue (ExpiryQueue) には、デフォルトエントリーがあります。

<addresses>
   <address name="DLQ">
      <anycast>
         <queue name="DLQ" />
      </anycast>
   </address>
      <address name="ExpiryQueue">
         <anycast>
            <queue name="ExpiryQueue" />
         </anycast>
   </address>
</addresses>

以下の方法のいずれかを使用して、ブローカーインスタンスのアドレス指定を設定できます。

AMQ 6 と同様に、AMQ Broker 7 を使用すると、SSL/TLS を使用して受信ネットワーク接続をセキュア化できます。ただし、設定構文と設定プロパティーにはいくつかの違いがあります。

AMQ 6 では、キーストアとトラストストアを定義する SSL コンテキストを作成し、セキュリティー保護する各トランスポートコネクターに SSL 属性を追加して、トランスポート層セキュリティーが設定されていました。

AMQ Broker 7 では、トランスポート層は SSL をネイティブで使用する Netty をベースにしています。そのため、トランスポート層セキュリティーを設定するには、セキュリティー保護する各アクセプターに必要な SSL 属性を追加するだけです。別の SSL コンテキストを追加する必要はありません。

たとえば、以下の設定では、OpenWire クライアントからのセキュアな接続を受け入れます。

一方向または双方向 TLS のいずれかを設定できます。以下の表では、その方法について説明しています。

AMQ Broker 7 は、アドレスに基づいてセキュリティー設定をキューに適用するロールベースのセキュリティーモデルを提供します。このセキュリティーモデルは AMQ 6 と似ていますが、パーミッションとワイルドカード構文が異なり、さらに承認の設定方法が異なります。

<configuration ...>
  <core ...>
    ...
    <security-settings>
      <security-setting match="#"> 1
        <permission type="createNonDurableQueue" roles="admin"/> 2
        <permission type="deleteNonDurableQueue" roles="admin"/>
        <permission type="createDurableQueue" roles="admin"/>
        <permission type="deleteDurableQueue" roles="admin"/>
        <permission type="createAddress" roles="admin"/>
        <permission type="deleteAddress" roles="admin"/>
        <permission type="consume" roles="admin"/>
        <permission type="browse" roles="admin"/>
        <permission type="send" roles="admin"/>
        <permission type="manage" roles="admin"/>
      </security-setting>
    </security-settings>
    ...
  </core>
</configuration>

AMQ 6 では、リソースの制限およびポリシーはブローカーの設定ファイルで宛先ポリシーとして設定されていました。

AMQ Broker 7 では、アドレスまたはアドレスの セット のリソース制限およびポリシーを定義します。ブローカーインスタンスがメッセージを受信すると、メッセージのアドレスに定義されたリソース制限およびポリシーがメッセージに適用されます。

AMQ Broker 7 でリソース制限およびポリシーを設定するには、BROKER_INSTANCE_DIR/etc/broker.xml 設定ファイルを使用して適切な設定プロパティーで <address-setting> 要素を定義します。

broker.xml 設定ファイルには、以下のデフォルトアドレス設定が含まれます。

<address-settings>
    <!-- if you define auto-create on certain queues, management has to be auto-create -->
    <address-setting match="activemq.management#"> 1
        <dead-letter-address>DLQ</dead-letter-address>
        <expiry-address>ExpiryQueue</expiry-address>
        <redelivery-delay>0</redelivery-delay>
        <!-- with -1 only the global-max-size is in use for limiting -->
        <max-size-bytes>-1</max-size-bytes>
        <message-counter-history-day-limit>10</message-counter-history-day-limit>
        <address-full-policy>PAGE</address-full-policy>
        <auto-create-queues>true</auto-create-queues>
        <auto-create-addresses>true</auto-create-addresses>
        <auto-create-jms-queues>true</auto-create-jms-queues>
        <auto-create-jms-topics>true</auto-create-jms-topics>
    </address-setting>
    <!--default for catch all-->
    <address-setting match="#"> 2
        <dead-letter-address>DLQ</dead-letter-address>
        <expiry-address>ExpiryQueue</expiry-address>
        <redelivery-delay>0</redelivery-delay>
        <!-- with -1 only the global-max-size is in use for limiting -->
        <max-size-bytes>-1</max-size-bytes>
        <message-counter-history-day-limit>10</message-counter-history-day-limit>
        <address-full-policy>PAGE</address-full-policy>
        <auto-create-queues>true</auto-create-queues>
        <auto-create-addresses>true</auto-create-addresses>
        <auto-create-jms-queues>true</auto-create-jms-queues>
        <auto-create-jms-topics>true</auto-create-jms-topics>
    </address-setting>
</address-settings>

リソース制限およびポリシーを設定するには、アドレスまたはアドレス セット を指定します (<address-setting> 使用して)、リソース制限およびポリシープロパティーをこれに追加します。これらのプロパティーは、指定したアドレス (またはアドレスセット) に送信された各メッセージに適用されます。

AMQ 6 と同様に、AMQ Broker 7 では、リソース制限およびポリシーを追加して、メッセージの配信方法およびタイミング、配信試行の数、およびメッセージが期限切れになるタイミングなど、ブローカーが特定の側面を処理する方法を制御できます。ただし、これらのリソース制限およびポリシーを定義するために使用する設定プロパティーは、AMQ Broker 7 では異なります。

このセクションでは、AMQ 6 の <policyEntry> 設定プロパティーを AMQ Broker 7 の同等の <address-setting> プロパティーと比較します。AMQ Broker 7 の各設定プロパティーの詳細は、『Configuring AMQ Broker』の「Address Setting Configuration Elements」を参照してください。

...
<address-settings>
    <address-setting match="#">
        <dead-letter-address>DLQ</dead-letter-address>
        <expiry-address>ExpiryQueue</expiry-address>
        ...
    </address-setting>
    ...
</address-settings>
...

...
<addresses>
    <address name="DLQ">
        <anycast>
            <queue name="DLQ" />
        </anycast>
    </address>
    <address name="ExpiryQueue">
        <anycast>
            <queue name="ExpiryQueue" />
        </anycast>
    </address>
...
</addresses>
...

AMQ Broker 7 は AMQ 6 とは異なるタイプのメッセージジャーナルを使用し、ジャーナルインデックスを使用しません。

AMQ 6 では、メッセージストアに KahaDB が使用され、メッセージジャーナルインデックスを保持し、ジャーナル内の各メッセージの位置を追跡しました。このインデックスにより、ブローカーはジャーナルからページングされたメッセージをバッチでプルし、キャッシュに配置できるました。

デフォルトでは、AMQ Broker 7 はブローカーがメッセージをディスパッチできるインメモリーメッセージジャーナルを使用します。そのため、AMQ Broker 7 はメッセージジャーナルインデックスを使用しません。ブローカーインスタンスがメモリー不足になると、メッセージはブローカーに到達するものの、キューに置かれる前にページングされます。これらのメッセージページファイルは、到達したのと同じ順序でディスクに順次保存されます。次に、ブローカーでメモリーが解放されると、メッセージはページファイルからブローカーのジャーナルに移動します。ジャーナルは順番に読み取られるため、ジャーナルにメッセージのインデックスを保持する必要はありません。

さらに、AMQ Broker 7 では、AMQ 6 では利用できなかった別の JDBC ベースのメッセージジャーナルオプションもあります。

AMQ Broker 7 メッセージジャーナルは、以下の共有ファイルシステムをサポートします。

BROKER_INSTANCE_DIR/etc/broker.xml 設定ファイルを使用して、ブローカーインスタンスのメッセージジャーナルを設定します。

broker.xml 設定ファイルには、以下のデフォルトのメッセージジャーナル設定プロパティーが含まれます。

<core>

    <name>0.0.0.0</name>

    <persistence-enabled>true</persistence-enabled>

    <journal-type>ASYNCIO</journal-type>

    <paging-directory>./data/paging</paging-directory>

    <bindings-directory>./data/bindings</bindings-directory>

    <journal-directory>./data/journal</journal-directory>

    <large-messages-directory>./data/large-messages</large-messages-directory>

    <journal-datasync>true</journal-datasync>

    <journal-min-files>2</journal-min-files>

    <journal-pool-files>-1</journal-pool-files>

    <journal-buffer-timeout>744000</journal-buffer-timeout>

    <disk-scan-period>5000</disk-scan-period>

    <max-disk-usage>90</max-disk-usage>

    <global-max-size>104857600</global-max-size>

    ...

</core>

メッセージジャーナルを設定するには、いずれかのジャーナル設定プロパティーのデフォルト値を変更します。設定プロパティーをさらに追加することもできます。

AMQ 6 および AMQ Broker 7 はどちらも、ブローカーがメッセージを永続化する方法を制御する複数の設定プロパティーを提供します。ここでは、AMQ 6 KahaDB ジャーナルの設定プロパティーを、AMQ Broker 7 のインメモリーメッセージジャーナルの同等のプロパティーと比較します。

インメモリーメッセージジャーナルの各メッセージ永続化設定プロパティーの詳細は、以下を参照してください。

AMQ Broker 7 では、ブローカーネットワークはブローカークラスターと呼ばれます。クラスター内のブローカーはクラスター接続によって接続されます (connector 要素を参照)。クラスターのメンバーは、(UDP または JGroups を使用して) 動的に、または (クラスターメンバーの一覧を手動で指定して) 静的に、相互に検出するように設定できます。

クラスター構成は、高可用性 (HA) に必須の前提条件です。クラスターが単一のライブブローカーのみで構成される場合でも、HA を設定する前にクラスターを設定する必要があります。

ブローカークラスターは、多くの異なるトポロジーで設定できますが、対称およびチェーンクラスターは最も一般的なものです。(メッセージをクラスター内の別のブローカーに送信するようにブローカーを設定している限り) トポロジーに関係なく、メッセージ損失なしにクラスターのスケールアップおよびスケールダウンを実行できます。

ブローカークラスターは、AMQ 6 のブローカーネットワークとは異なる方法でメッセージを配布 (および再配布) します。AMQ 6 では、メッセージは常に特定のキューに到着し、コンシューマーの興味に基づいて、あるブローから別のブローカーにプルされました。AMQ Broker 7 では、キューの定義およびコンシューマーはクラスター全体で共有され、メッセージがブローカーで受信されると、クラスター全体にルーティングされます。

クラスターの各メンバーに ブローカーインスタンスを作成して から、クラスター設定を各ブローカーインスタンスに追加して、ブローカークラスターを設定します。

クラスター設定は以下で構成されます。

<!-- Clustering configuration -->
<broadcast-groups>
    <broadcast-group name="my-broadcast-group">
        <group-address>${udp-address:231.7.7.7}</group-address>
        <group-port>9876</group-port>
        <broadcast-period>100</broadcast-period>
        <connector-ref>netty-connector</connector-ref>
    </broadcast-group>
</broadcast-groups>

<discovery-groups>
    <discovery-group name="my-discovery-group">
        <group-address>${udp-address:231.7.7.7}</group-address>
        <group-port>9876</group-port>
        <refresh-timeout>10000</refresh-timeout>
    </discovery-group>
</discovery-groups>

<cluster-connections>
    <cluster-connection name="my-cluster">
        <connector-ref>netty-connector</connector-ref>
        <retry-interval>500</retry-interval>
        <use-duplicate-detection>true</use-duplicate-detection>
        <message-load-balancing>ON_DEMAND</message-load-balancing>
        <max-hops>1</max-hops>
        <discovery-group-ref discovery-group-name="my-discovery-group"/>
    </cluster-connection>
</cluster-connections>

<connectors>
   <connector name="netty-connector">tcp://localhost:61616</connector>
   <!-- connector to broker2 -->
   <connector name="broker2-connector">tcp://localhost:61716</connector>
</connectors>


<cluster-connections>
   <cluster-connection name="my-cluster">
      <address>jms</address>
      <connector-ref>netty-connector</connector-ref>
      <retry-interval>500</retry-interval>
      <use-duplicate-detection>true</use-duplicate-detection>
      <message-load-balancing>STRICT</message-load-balancing>
      <max-hops>2</max-hops>
      <static-connectors allow-direct-connections-only="true">
         <connector-ref>broker2-connector</connector-ref>
      </static-connectors>
   </cluster-connection>
</cluster-connections>

<connectors>
   <connector name="netty-connector">tcp://localhost:61716</connector>
   <!-- connector to broker3 -->
   <connector name="broker3-connector">tcp://localhost:61816</connector>
</connectors>


<cluster-connections>
   <cluster-connection name="my-cluster">
      <address>jms</address>
      <connector-ref>netty-connector</connector-ref>
      <retry-interval>500</retry-interval>
      <use-duplicate-detection>true</use-duplicate-detection>
      <message-load-balancing>STRICT</message-load-balancing>
      <max-hops>1</max-hops>
      <static-connectors allow-direct-connections-only="true">
         <connector-ref>broker3-connector</connector-ref>
      </static-connectors>
   </cluster-connection>
</cluster-connections>

<connectors>
   <connector name="netty-connector">tcp://localhost:61816</connector>
</connectors>

<cluster-connections>
   <cluster-connection name="my-cluster">
      <address>jms</address>
      <connector-ref>netty-connector</connector-ref>
      <retry-interval>500</retry-interval>
      <use-duplicate-detection>true</use-duplicate-detection>
      <message-load-balancing>STRICT</message-load-balancing>
      <max-hops>0</max-hops>
   </cluster-connection>
</cluster-connections>

以下の表は、AMQ 6 のブローカーネットワーク設定プロパティーを AMQ Broker 7 の同等の cluster-connection プロパティーと比較します。

マスターの決定方法とブローカー接続がアクティブになるタイミングに関して、AMQ Broker 7 での高可用性は AMQ 6 とは異なります。

AMQ Broker 7 では、マスターロールおよびスレーブロールは固定です。マスターであるブローカーインスタンスを指定し、特定の条件下でのみスレーブがアクティブになります。AMQ 6 では、マスターロールおよびスレーブロールは固定ではありませんでした。代わりに、HA ペアのブローカーはロックについて競争し、勝者がマスターになりました。

AMQ Broker 7 では、HA のペアでは、スレーブブローカーが非アクティブであってもブローカーのアクセプターがアクティブになります。AMQ 6 では、スレーブブローカーがアクティブになるまでブローカーのトランスポートコネクターはアクティブになりませんでした。

HA ポリシー設定を各ブローカーの BROKER_INSTANCE_DIR/etc/broker.xml 設定ファイルに追加して HA を設定します。

<configuration>
  <core>
    ...
    <ha-policy>
       <shared-store>
         <master/>
            <failover-on-shutdown>true</failover-on-shutdown>
       </shared-store>
    </ha-policy>
    ...
  </core>
</configuration>

スレーブブローカーは、以下のように設定されます。failover-on-shutdown を true に設定すると、現在のマスターブローカーがシャットダウンすると、このスレーブブローカーがマスターになります。

<configuration>
  <core>
    ...
    <ha-policy>
       <shared-store>
          <slave/>
            <failover-on-shutdown>true</failover-on-shutdown>
       </shared-store>
    </ha-policy>
    ...
  </core>
</configuration>

改訂日時： 2021-08-29 15:42:28 +1000