非同期処理サービス構築の覚書のバックアップ(No.5)

このデータベースにテーブルを作成する。以下のSQLファイルを実行する。
https://github.com/OpenTouryoProject/OpenTouryo/tree/develop/root/files/resource/Sql/sqlserver/AsyncProcessingService
- CreateAsyncProcessingServiceStatusManagementTableScript?.sql
- CreateEnumAsyncCommandTableScript?.sql
- CreateOpenTouryoCodeTableScript?.sql

↑

非同期処理サービス †

↑

設定 †

app.configファイルの接続文字列を設定する。

 <connectionStrings>
   <!-- SQL Server / SQL Client用 -->
   <add name="ConnectionString_SQL" connectionString="Data Source=localhost\sqlexpress;Integrated Security=SSPI;Initial Catalog=AsyncProcessingServiceDB;"/>
 </connectionStrings>

↑

ビルド †

AsyncProcessingService?をビルドする。
Visual Studioからソリューション・ファイルを開いてビルドする。

↑

インストール †

ビルド出力（*.exe）をWindowsサービスとしてインストールする。

CMDを起動し、CD（Change Directory）コマンドで以下のパスに移動
```
C:\Windows\Microsoft.NET\Framework64\v4.0.30319
```

以下のInstallUtil?コマンドで、ビルド出力（*.exe）をWindowsサービスとしてインストールする。

C:\Windows\Microsoft.NET\Framework64\v4.0.30319>InstallUtil.exe -i "C:\root\programs\C#\Frameworks\Infrastructure\ServiceInterface\AsyncProcessingService\bin\Debug\AsyncProcessingService.exe"

管理ツールのサービス（コマンドからはservices.msc）を起動し、
サービスの一覧にAsyncProcessingService?が登録されていることを確認する。

↑

非同期処理の開発 †

非同期処理のクライアントとサーバを開発する。

以下のソリューションファイルを開くと、２つのプロジェクトが開く。

"C:\root\programs\C#\Samples\AsyncSvc_sample\AsyncSvc_sample.sln"

↑

非同期処理のクライアント †

TestAsyncSvc_Sample

非同期処理をキューに登録するプログラム。

↑

設定 †

app.configファイルの接続文字列を設定する。

 <connectionStrings>
   <!-- SQL Server / SQL Client用 -->
   <add name="ConnectionString_SQL" connectionString="Data Source=localhost\sqlexpress;Integrated Security=SSPI;Initial Catalog=AsyncProcessingServiceDB;"/>
 </connectionStrings>

↑

ビルド †

普通にビルドする。

↑

非同期処理のサーバ †

AsyncSvc_sample

登録された非同期処理を取り出しディスバッチする先のビジネスロジック。

↑

ビルド †

普通にビルドする。

ビルドが完了したら、非同期処理サービスのプロジェクト出力フォルダにコピーする。

"C:\root\programs\C#\Frameworks\Infrastructure\ServiceInterface\AsyncProcessingService\bin\Debug"

↑

非同期処理サービスの実行 †

AsyncProcessingService?をSCMから開始する。
TestAsyncSvc_Sampleを実行して非同期タスクを登録する。
非同期処理管理テーブルを監視して非同期処理が遂行されることを確認する。
非同期処理サービスが実行されない場合は以下のログを分析する。
- パス："C:\root\files\resource\Log\"
- ファイル：
  - ASYNC-SERVICE
  - ACCESS-ASYNC.YYYY-MM-DD.log
  - SQLTRACE-ASYNC.YYYY-MM-DD.log
  - ACCESS.YYYY-MM-DD.log
  - SQLTRACE.YYYY-MM-DD.log

↑

非同期処理のサーバの開発方法 †

↑

Dam †

↑

DamKeyforABT †

業務テーブルにアクセスする場合に使用するDam

↑

DamKeyforAMT †

非同期処理管理テーブルにアクセスする場合に使用するDam

↑

接続文字列 †

非同期処理管理テーブルと業務テーブルが同じデータベース内にある場合は、
DamKeyforABTとDamKeyforAMTの接続文字列には同じ接続文字列を使用する。

非同期処理管理テーブルと業務テーブルが異なるデータベース内にある場合は、
以下をカスタマイズして、DamKeyforABTとDamKeyforAMTの接続文字列を分割する。

MyApsBaseLogic?.UOC_ConnectionOpen()メソッド
https://github.com/OpenTouryoProject/OpenTouryo/blob/develop/root/programs/C%23/Frameworks/Infrastructure/Business/Business/MyApsBaseLogic.cs

↑

UOC_Start（UOC_XXXX） †

非同期処理のサーバ処理のエントリポイント。
通信制御機能のインプロセス呼び出しにより呼び出される。

インプロセス呼び出しの定義は以下のファイルの中に定義にされている。

"C:\root\programs\C#\Frameworks\Infrastructure\ServiceInterface\AsyncProcessingService\TMInProcessDefinition.xml"

↑

処理の流れ †

DeserializeFromBase64Stringメソッドで業務データを復元
GetCommandValue?メソッドによりCommandIDを取得する。

CommandIDがStopの場合、
- ResumeProcessing?メソッドでCommandIDを「0」クリアする。
- 既存処理をResumeを行う。

それ以外の場合、
- 新規処理の初期化を行う。

Updateメソッドにより業務処理を行う。
処理を抜けた場合、正常終了の扱いとなる。

↑

SerializeToBase64Stringメソッド †

DeserializeFromBase64Stringメソッドで、
userParameterValue?.Dataの業務データを
バイナリデータからオブジェクトへ復元する。

↑

GetCommandValue?メソッド †

非同期処理管理テーブルから
本非同期タスクのTaskIDに対応するCommandIDを取得する。

↑

ResumeProcessing?メソッド †

非同期処理管理テーブルの
本非同期タスクのTaskIDに対応するCommandIDを「0」クリアする。

↑

Updateメソッド（業務処理） †

業務処理を実行する。必要に応じてループで実装する。

GetCommandValue?メソッドによりCommandIDを取得する。

取得したCommandIDをチェックする。
- Stop：業務例外をthrowして処理をリトライする。
- Abort：システム例外をthrowして処理をABENDする。
- その他：
  - 業務処理を続行する。
  - 進捗率をUpdateProgressRate?メソッドでアップデートする。

↑

UpdateProgressRate?メソッド †

非同期処理管理テーブルの
本非同期タスクのTaskIDに対応する進捗率をアップデートする。

非同期処理サービス構築の覚書 のバックアップ(No.5)

目次 †

問題点 †

概要 †

準備 †

手順 †

インストール †

Open棟梁のテンプレート †

データベース †

作成 †

セキュリティ設定 †

テーブルの作成 †