8.4.2 トランザクション・イニシエータまたは参加側としてのNode.jsアプリケーションの構成

1. Node.jsのMicroTxライブラリをpackage.jsonファイルに依存関係として追加します。

   "dependencies": {
       "@oracle/microtx": "<version>"
     }

   ここで、<version>は、Node.jsのMicroTxライブラリの最新バージョンです。

2. MicroTxライブラリのプロパティ値を構成します。「Node.jsアプリケーションのライブラリ・プロパティの構成」を参照してください。
3. Node.jsアプリケーションのロギングを有効にするには、追加のプロパティを設定する必要があります。「MicroTx Node.jsライブラリのログの有効化」を参照してください。
4. プロパティ値を定義したtmm.propertiesファイルを渡して、マイクロサービスのMicroTxライブラリ・プロパティを構成します。

   TrmConfig.init('./tmm.properties');

5. MicroTxおよびExpressライブラリをインポートします。

   import { Request, Response, Router } from 'express';
   import { getLRAId, LRA, LRAConfig, LRAType, ParticipantStatus, cancelLRA, LRA_HTTP_CONTEXT_HEADER, LRA_HTTP_ENDED_CONTEXT_HEADER } from "@oracle/microtx/lra/lra";
   import { getHeaderValue } from '@oracle/microtx/util/trmutils';

6. プログラム内でリクエストを処理するルーター・オブジェクトを作成します。
   次のコードを使用して、flightSvcRouterという名前のルーター・オブジェクトを作成します。

   const flightSvcRouter = Router();

7. MicroTx SagaコーディネータのURLを入力します。この属性値を取得するには、MicroTxへのアクセスに使用するURLに/lra-coordinatorを追加します。たとえば、https://tmm-app:9000/api/v1がMicroTx URLの場合、lraCoordinatorUrlはhttps://tmm-app:9000/api/v1/lra-coordinatorです。

   const lraCoordinateUrl = process.env.ORACLE_TMM_TCS_URL

8. 次のコードを追加して、トランザクション・イニシエータ・サービスおよびトランザクション参加側サービスのRESTエンドポイントのLRAConfigオブジェクトを初期化します。サービスによって多数のREST APIエンドポイントが公開されることがありますが、LRAConfigオブジェクトを初期化する必要があるのは、Sagaトランザクションに参加する必要があるREST APIエンドポイントのみです。

   const lra: LRA = new LRA("/flight", LRAType.REQUIRES_NEW);
   lra.end = false;
   lra.timeLimitInMilliSeconds = 100000;
   new LRAConfig(lraCoordinateUrl, flightSvcRouter, "/flightService/api", lra, "/complete", "/compensate", "/status", "/after", "", "", "");

   説明

   • /flightは、Sagaトランザクションに参加するためにトランザクション・イニシエータ・アプリケーションが公開するREST APIエンドポイントです。
   • LRAType.REQUIRES_NEWは、サービスが既存のSagaトランザクションに参加するか、新しいトランザクションを作成するかを決定します。LRATypeをREQUIRES_NEWに設定すると、新しいトランザクションが作成されます。LRATypeをMANDATORYに設定すると、サービスが既存のトランザクションに参加します。LRAType値の詳細は、マイクロサービス対応トランザクション・マネージャTypeScript APIリファレンスを参照してください。
   • flightSvcRouterは、事前に作成しておいたルーター・オブジェクトです。
   • /flightService/apiは、flightSvcRouterルーターのマウント・ポイントです。これは、LRAConfigオブジェクトのapplRouterMountPathフィールドの値です。
   • timeLimitInMilliSecondsは、トランザクションを完了または補正する必要がある期間(ミリ秒)です。指定した期間内にトランザクションが完了しない場合、MicroTxはトランザクションを補正します。業務要件に基づいて期限を決めてください。
   • "/complete"、"/compensate"、"/status"、"/after"は、アプリケーションのビジネス・ロジックを定義するためのREST APIエンドポイントです。

   Sagaトランザクション中に、MicroTxは、指定したREST APIエンドポイントからのすべての送信リクエストのリンク・ヘッダーを追加します。

9. LRAConfigオブジェクトの作成時に指定したすべてのREST APIエンドポイントに対してビジネス・ロジックを定義します。

   flightSvcRouter.put('/complete', async (req, resp) => {
   //application business logic
   });
   
   flightSvcRouter.put('/compensate', async (req, resp) => {
   //application business logic
   });
   
   flightSvcRouter.put('/status', async (req, resp) => {
   //application business logic
   });
   
   flightSvcRouter.put('/after', (req, resp) => {
   //application business logic
   });

   ここで、flightSvcRouterは、事前に作成しておいたルーター・オブジェクトです。このサンプル・コードはputのみを示していますが、ビジネス・ロジックに基づいて任意のHTTP動詞を使用できます。

10. 変更内容を保存します。

MicroTxライブラリを使用するサンプルNode.jsトランザクション参加側アプリケーションのソース・コードは、microtx-samples GitHubリポジトリのflightフォルダにあります。これは、MicroTxライブラリとアプリケーションの統合時に参照として使用できます。