Red Hat AMQ 7 への移行

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

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

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

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

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

AMQ 7 に移行する前に、主な新機能、改良された機能、および既知の問題を理解する必要があります。この一覧は、Red Hat AMQ Broker 7.7 のリリースノート を参照してください。

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

sudo コマンド

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

sudo の使用の詳細は、sudo コマンド を参照してください。

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

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

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

AMQ 7 に移行する前に、AMQ Broker インスタンスを作成する必要があります。本書で説明されている 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 構造とデフォルトの設定設定の詳細については、AMQ ブローカーの設定 の デフォルトのブローカ設定について を参照してください。

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

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 または仮想マシン内) は、クライアントが使用するメッセージングプロトコル (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 は、アドレス、ルーティングタイプ、およびキューを使用して、キューおよびトピックのような動作を実現します。address はメッセージングエンドポイントを表します。キュー はアドレスに関連付けられています。ルーティングタイプ は、アドレスに関連付けられたキューにメッセージを配信する方法を定義します。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 の各設定プロパティーの詳細については、AMQ Broker の設定 の アドレス設定の構成要素 を参照してください。

...
<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) の必須前提条件です。クラスターが 1 つの Live Broker のみで設定されている場合でも、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 では、スレーブブローカーのトランスポートコネクターは、ブローカーがアクティブになるまでアクティブになりませんでした。

各ブローカーの BROKER_INSTANCE_DIR/etc/broker.xml 設定ファイルに HA ポリシー設定を追加して、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>

改訂日時：2023-01-28 11:51:43 +1000