ApsaraMQ for RocketMQ:Azure App Service への WordPress のデプロイ

技術評価

• Apache RocketMQ クラスタの制限: Apache RocketMQ クラスタを ApsaraMQ for RocketMQ インスタンスに移行する前に、クラスタが要件を満たしているかどうかを評価します。クラスタが要件を満たしていない場合は、チケットを送信してください。次の表に、Apache RocketMQ クラスタの制限を示します。

  制限	説明
  デプロイされたバージョン	Apache RocketMQ 4.x および 5.x ブローカーがサポートされています。
  ネットワーク	ソース Apache RocketMQ クラスタは VPC にデプロイする必要があります。ソース Apache RocketMQ クラスタがオンプレミス データセンターにデプロイされている場合は、クラスタに VPC からアクセスできることを確認してください。
  リージョン	セルフマネージド Apache RocketMQ クラスタを、中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深圳)、中国 (張家口)、米国 (シリコンバレー)、シンガポールのリージョンにある ApsaraMQ for RocketMQ インスタンスに移行できます。
  パラメーター	メッセージサイズ メッセージのサイズは 4 MB を超えることはできません。 メッセージの保存期間 最小値: 24。単位: 時間。 最大値: 720。単位: 時間。 スケジュール済みメッセージの最大遅延時間 サブスクリプションおよび従量課金 Standard Edition インスタンス、サーバーレス Standard Edition および Professional Edition インスタンス: 7 日間。 サブスクリプションおよび従量課金 Professional Edition および Enterprise Platinum Edition インスタンス: 40 日間。 詳細については、「クォータと制限」をご参照ください。

• SDK バージョンの制限: 移行ソリューションは最小限の変更の原則に従います。ほとんどの場合、クライアント SDK のバージョンは自動的にアップグレードされます。メジャーバージョンのアップグレードが含まれる場合、新機能が追加され、安定性の最適化が提供されます。この場合、移行中に SDK バージョンをアップグレードすることをお勧めします。

  SDK	プログラミング言語	SDK バージョン	アップグレードが必要かどうか
  Apache RocketMQ Remoting SDK Java 用 SDK の Maven 依存関係のサンプルコード: <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>{version}</version> </dependency> エンドポイント形式: producer.setNamesrvAddr(“xxx:9876”); consumer.setNamesrvAddr(“xxx:9876”);	Java	5.x SDK	このタイプの SDK は ApsaraMQ for RocketMQ インスタンスと互換性があります。アップグレードは必要ありません。
  	Java および C++	4.x SDK	ソース Apache RocketMQ クラスタによって PullConsumer、DefaultLitePullConsumer、および DefaultPullConsumer 操作が呼び出される場合は、SDK を 5.x にアップグレードする必要があります。詳細については、「概要」をご参照ください。

移行範囲の確認

ApsaraMQ for RocketMQ が提供する移行ソリューションを使用すると、トピックごとに Apache RocketMQ クラスタを ApsaraMQ for RocketMQ インスタンスに移行できます。バッチ移行、カナリアリリース、ロールバックもサポートされています。これにより、大規模な変更によるリスクが効果的に軽減されます。

使用上の注意

• ApsaraMQ for RocketMQ が提供する移行ツールは、最小スコープポリシーに基づいて、ソース Apache RocketMQ クラスタに関する次の情報にのみアクセスできます。

  • トピックのメタデータ

  • グループのメタデータ

  • トピックの動的ルーティング登録に関する情報

  • コンシューマー接続とメッセージ蓄積に関する情報

  移行ツールは、ソース Apache RocketMQ クラスタに関する他の情報にアクセスしたり、クラスタに構成情報を書き込んだりしません。したがって、移行ツールが Apache RocketMQ クラスタにアクセスしても、クラスタの実行に影響はありません。

• 次のステップに進む前に、ネットワーク構成が有効であることを確認してください。次のステップに入ると、ネットワーク構成ステップにロールバックすることはできません。ネットワーク構成を変更するには、新しい移行タスクを作成する必要があります。

手順

1. ApsaraMQ for RocketMQ コンソール にログオンします。

2. 上部のナビゲーションバーで、ソース Apache RocketMQ クラスタと宛先 ApsaraMQ for RocketMQ インスタンスが存在するリージョンを選択します。左側のナビゲーションウィンドウで、[RocketMQ Copilot] > クラウドへの移行 を選択します。

3. クラウドへの移行 ページで、タスクの作成 をクリックします。

4. 移行タスクの作成 パネルで、パラメーターを構成し、OK をクリックします。

   パラメーターの詳細については、「ソース Apache RocketMQ クラスタのネットワーク用に構成されたパラメーター」をご参照ください。

5. ネットワーク情報の設定 ステップの クラウドへの移行 ウィザードで、ソース Apache RocketMQ クラスタに関するネットワーク情報を入力し、ネットワーク情報の設定 をクリックします。

   パラメーターの詳細については、「ソース Apache RocketMQ クラスタのネットワーク用に構成されたパラメーター」をご参照ください。

6. バックグラウンド構成が完了するまで待ちます。次に、次へ をクリックします。

パラメーター設定

使用上の注意

• メタデータの移行中、ApsaraMQ for RocketMQ 移行ツールは、Apache RocketMQ クラスタに作成されたすべてのトピックとグループに関する情報を動的に読み取り、リストに表示します。移行するトピックとグループのメタデータのみを移行する必要があります。

• このステップにロールバックすることはできません。次のステップに進む前に、移行するトピックとグループがすべて移行されていることを確認してください。そうでない場合は、後続の操作でトピックを手動で追加する必要があります。

手順

1. メタデータの移行 ステップで、トピックメタデータ タブをクリックします。

2. 移行する Topic を Topic リストから選択し、対応するメッセージタイプを メッセージのタイプ ドロップダウンリストから選択します。次に、確認してインポート を 操作 列でクリックして、Topic をインポートします。

   複数のトピックを選択し、一括インポート をクリックして、一度に複数のトピックをインポートすることもできます。

   重要

   メッセージタイプは Apache RocketMQ 4.x では定義されていません。ApsaraMQ for RocketMQ は、移行するトピックに指定したメッセージタイプが、トピックが処理するメッセージのタイプと一致するかどうかを確認します。メタデータを移行する場合は、実際のビジネスに基づいてメッセージタイプを選択する必要があります。

   間違ったメッセージタイプを選択すると、移行後にメッセージの送受信に失敗します。トピックのメッセージタイプ、またはトピックに異なるタイプのメッセージが存在するかどうかがわからない場合は、チケットを送信してください。

3. グループメタデータ タブをクリックし、グループリストから移行するグループを選択し、消費シーケンスのタイプ ドロップダウンリストからメッセージが消費される順序を選択し、確認してインポート操作 列の をクリックして、グループをインポートします。

   複数のグループを選択し、一括インポート をクリックして、一度に複数のグループをインポートすることもできます。

   重要

   Apache RocketMQ 4.x SDK でのメッセージの消費順序は、クライアントで指定されます。ApsaraMQ for RocketMQ 5.x インスタンスのグループでのメッセージの消費順序は、ブローカーによって制御されます。メタデータを移行する場合は、ビジネスシナリオに基づいてグループ内のメッセージの消費順序を指定する必要があります。

   間違ったメッセージ消費順序を選択すると、移行後に消費例外が発生します。グループ内のメッセージの消費順序がわからない場合は、チケットを送信してください。

4. 移行するすべてのトピックとグループがインポートされたことを確認した後、インポートが完了したら、次のステップに進みます をクリックします。

使用上の注意

• エンドポイントを変更した後、プロデューサーおよびコンシューマー アプリケーションを再起動して、アプリケーションを宛先 ApsaraMQ for RocketMQ インスタンスに接続する必要があります。このプロセス中、移行ツールはメッセージングに使用されるトピックをバックエンドの Apache RocketMQ クラスタにルーティングします。このステップでは、メッセージングシステムは変更されません。メッセージング アプリケーションがエンドポイントを変更する順序に制限はありません。

• 移行に関与するすべてのプロデューサーおよびコンシューマー アプリケーションでエンドポイントが変更されていることを確認してください。

  • 特定のプロデューサー アプリケーションでエンドポイントが変更されていない場合、特定のメッセージの送信に失敗します。

  • 特定のコンシューマー アプリケーションでエンドポイントが変更されていない場合、メッセージが蓄積され、特定のメッセージを消費できません。

エンドポイント変更の例

• Apache RocketMQ Remoting SDK

  • 変更前:

    producer.setNamesrvAddr("192.168.XX.XX:9876");
      
    consumer.setNamesrvAddr("192.168.XX.XX:9876");

  • 変更後:

    バージョン 4.5.1 以降

    producer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // vipChannelEnabled のデフォルト値は false です。vipChannelEnabled を true に設定する場合は、このパラメーターをコメントアウトします。
    // producer.setVipChannelEnabled(false);
      
    consumer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // vipChannelEnabled のデフォルト値は false です。vipChannelEnabled を true に設定する場合は、このパラメーターをコメントアウトします。
    // consumer.setVipChannelEnabled(false);

    バージョン 4.5.1 より前

    producer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // vipChannelEnabled のデフォルト値は true です。false に設定する必要があります。
    producer.setVipChannelEnabled(false);
      
    consumer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // vipChannelEnabled のデフォルト値は true です。false に設定する必要があります。
    consumer.setVipChannelEnabled(false);

• Apache RocketMQ gRPC SDK

  • 変更前:

    ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
                .setEndpoints(192.168.XX.XX:9876)
                .setCredentialProvider(sessionCredentialsProvider)
                .build();

  • 変更後:

    ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
                .setEndpoints(rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080)
                .setCredentialProvider(sessionCredentialsProvider)
                .build();

手順

使用上の注意

• トラフィックの切り替え中は、トピックのステータスが変更されるたびに、メッセージが想定どおりに送受信されるかどうかを確認する必要があります。例外が発生しない場合は、次のステップに進みます。例外が発生した場合は、前のステップにロールバックして、問題のトラブルシューティングを行ってください。

• 移行タスクを完了する前に、移行するすべてのトピックのトラフィックが切り替えられ、メッセージが想定どおりに送受信できることを確認してください。移行タスクの完了後は、トラフィック切り替えに関する情報を変更することはできません。

トラフィック切り替えの詳細

トラフィックの切り替え

1. メッセージの移行 ステップで、メッセージを移行するトピックを選択し、トピックのチェックステータスを確認します。

   • ステータスが チェックに合格する の場合は、次のステップに進みます。

   • ステータスが チェックに合格する でない場合は、チェック結果に基づいて例外のトラブルシューティングを行ってください。次に、チェックに合格するまで、トピックの 操作 列の 再チェック をクリックします。チェックに合格したら、次のステップに進みます。

     トラフィック切り替えの各段階でチェックされる項目については、「チェック項目」をご参照ください。

   • ステータスが チェックに合格する でなく、チェック結果が移行に影響しないと判断した場合は、トピックの 操作 列の チェックを無視する をクリックして、次のステップに進みます。

2. トラフィックを切り替えるトピックの 操作 列で、トラフィックの切り替えの確認 をクリックします。

3. 表示されるメッセージで、確定 をクリックします。

   トラフィックの切り替えは 4 つの段階で構成されます。トラフィック切り替え操作を 4 回実行する必要があります。トラフィック切り替えフェーズ が ターゲットクラスターの読み取りと書き込み に変わるまで、トラフィックの切り替えは完了しません。

   トラフィック切り替えの各段階におけるトピックの読み取りおよび書き込みトラフィックの変更については、「トラフィック切り替えステータス」をご参照ください。

4. 移行タスクで移行するすべてのトピックのトラフィックが切り替えられたことを確認し、ページの下部にある 移行が完了しました をクリックします。

その他の操作

メッセージの移行ページでトラフィックを切り替えるときに実行できるその他の操作を以下に示します。

• ロールバック

  • 前の状態へのロールバック: 移行が想定どおりに機能しない場合は、指定されたトピックのステータスを移行が想定どおりに機能した前の状態にロールバックし、問題のトラブルシューティングを行ってから後続の操作を実行できます。

  • 初期状態へのロールバック: この方法を使用して、トラフィック切り替えの初期状態にロールバックできます。トラフィック切り替えの初期状態とは、ルーティング状態を指し、緊急トラブルシューティングに使用されます。

    説明

    この操作を実行すると、トラフィック切り替えのステータスに大きな変更が生じます。以前の移行プロセス中に生成された未消費メッセージが遅延したり、処理できない場合があります。

• 補足作成

  メタデータの移行中に移行するトピックが選択されていない場合は、トラフィック切り替え中に ApsaraMQ for RocketMQ 5.x インスタンスで、移行するトピックと同じ名前のトピックを作成できます。

• トラフィックの一括切り替え/一括ロールバック

  バッチトラフィック切り替えと一括ロールバックを実行できます。

  説明

  バッチトラフィック切り替えと一括ロールバックは、同じトラフィック切り替えステージにあるトピックに対してのみ実行できます。

トラフィック切り替え中のチェック項目