Blockchain as a Service:メッセージキュー

ブロックチェーン上のすべてのイベントをメッセージ指向ミドルウェアに自動的にリリースできるように、イベントとメッセージキュー（MQ）間のマッピングを構成できます。マッピングが構成されると、Alibaba Cloud Blockchain as a Service（BaaS）は、ブロックチェーンイベントが検出されたときにMQ メッセージを自動的に生成し、MQ Topic にリリースします。イベントメッセージをサブスクライブして、さらに処理することができます。

Alibaba Cloud BaaS と Message Queue for Apache RocketMQ を統合する

1. [組織] セクションで対象の組織を見つけ、右側の [クラウド サービス統合] をクリックします。

2. RocketMQ メッセージキュー タブをクリックします。

3. 条件検出 をクリックして、クラウドサービス統合のステータスを確認します。

4. Message Queue for Apache RocketMQ を有効にしていない場合は、サービスを有効にする をクリックします。

5. Alibaba Cloud BaaS が Message Queue for Apache RocketMQ にアクセスすることを承認していない場合は、承認サービス をクリックして Alibaba Cloud BaaS を承認します。

6. 次の図が表示されたら、統合は完了です。 構成の追加 をクリックし、以下の手順を参照してイベントトリガーを構成します。

Message Queue for Apache RocketMQ トリガーを構成する

1. RocketMQ メッセージキュー タブで、構成を追加する をクリックします。

2. 表示される [MQ 構成の追加] サイドペインで、次のパラメーターを設定します。

   • 名前: トリガーの名前 (識別しやすいように)。

   • チャンネル/ネットワーク: トリガーがイベントをリッスンしてプッシュするために使用するファブリックチャンネル。

   • イベントタイプ: 外部サービスにプッシュするイベントのタイプ。イベントタイプの詳細については、「イベントをサブスクライブする」をご参照ください。

   • MQ ドメイン名: MQ インスタンスの HTTP エンドポイント。

   • MQ インスタンス名: MQ インスタンスの詳細に表示される MQ インスタンス ID。

   • MQ Topic: MQ にプッシュされるメッセージ Topic。

   • メッセージタグ: MQ にプッシュされるメッセージタグ (オプション)。

   • 失敗のしきい値: 詳細オプション。失敗回数がこの値を超えると、トリガーは失敗状態になり、処理を停止します。 -1 は失敗回数が無制限であることを意味し、トリガーは失敗状態になりません。

   • フィルター: 詳細オプション。オプション。詳細については、「フィルターを使用する」をご参照ください。

3. [追加] をクリックします。トリガーが追加されると、リストに表示されます。

   説明

   注: トリガーがブロックチェーンイベントを統合サービスにプッシュすると、サービス処理エラーまたはパラメーター構成エラーにより、トリガーのステータスが [例外] になります。 [例外] にポインターを移動すると、エラー情報が表示されます。統合サービスが例外を返すと、トリガーは処理を再試行します。再試行が複数回失敗した場合、トリガーはイベントを破棄し、これは 1 回の失敗としてカウントされます。失敗の合計数が失敗のしきい値を超えない場合、トリガーは後続のイベントをプッシュします。失敗の合計数が失敗のしきい値を超えると、トリガーは失敗状態になり、処理を停止します。トリガーまたは関連サービスを修復して再度有効にすると、失敗回数はゼロに戻ります。 [ブロックの高さ] フィールドは、トリガーによって処理された最新のブロックを示し、トリガーの進捗状況を反映します。

4. トリガーを作成した後、次の操作を実行できます。

   • 削除: トリガーを削除します。

   • 無効化: トリガーを作成したサービスへのイベントのプッシュを停止します。

   • 有効: トリガーを作成したサービスにイベントをプッシュします。トリガーが有効になると、最新のブロックのイベントをプッシュします。トリガーが無効になっている間に生成されたイベントは破棄されます。