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

[ トップ ]   [ 新規 | 一覧 | 単語検索 | 最終更新 | ヘルプ ]

• バックアップ一覧
• 差分 を表示
• 現在との差分 を表示
• ソース を表示
• 非同期処理サービス構築の覚書（旧） へ行く。
  • 1 (2018-05-21 (月) 22:07:53)
  • 2 (2018-05-21 (月) 22:11:10)
  • 3 (2018-05-22 (火) 13:42:14)
  • 4 (2018-09-28 (金) 21:35:12)

---

「Open棟梁 wiki」は、「Open棟梁Project」,「OSSコンソーシアム .NET開発基盤部会」によって運営されています。

• 戻る

目次 †

概要 †

非同期処理サービス構築のチュートリアル作成前段階のメモ

準備 †

環境を準備する。

• Visual Studio 2010 以上の任意のエディション
• SQL Server 任意のバージョンとエディション
• Open棟梁 v01-70 以上のテンプレート

本ページの作成と検証には、

• Windows 7
• Visual Studio 2015
• SQL Server 2014
• root_VS2015（v02-20）

を使用した。

手順 †

前提ソフトウェアのインストール †

以下をインストール

• Visual Studio 2010 以上の任意のエディション
• SQL Server 任意のバージョンとエディション

非同期処理サービスのテンプレート †

取得 †

• GithubからOpen棟梁（v01-70 以上）- 非同期処理サービスのテンプレートを取得
  https://github.com/OpenTouryoProject/OpenTouryoTemplates
  • 必要に応じて、branchやtagを指定。以下は、02-20のtagを指定した場合。
    https://github.com/OpenTouryoProject/OpenTouryo/tree/02-20

デプロイ †

root_VS2010-2015のうちの何れかをC:\rootとしてデプロイ。

ビルド †

Readme.mdを参考にして一通りのビルドを行う。

データベースの準備 †

作成 †

• AsyncProcessingServiceDBというデータベースを作成する。

セキュリティ設定 †

サービス・アカウントからSQL Serverにログインする。

なので、以下の手順に従って、
ローカル・システム・アカウントのログインと権限付与をする。

• システム・アカウントのユーザを作成する。
  • Windows ユーザー
  • NT AUTHORITY\SYSTEM

• アクセス権限を付与する。
  • 「所有されているスキーマ」に”db_owner”を追加する。
  • 「メンバーシップ」に”db_owner”を追加する。

テーブルの作成 †

• このデータベースにテーブルを作成する。以下のSQLファイルを実行する。
  https://github.com/OpenTouryoProject/OpenTouryo/tree/02-20/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からソリューション・ファイルを開いてビルドする。

C:\root\programs\C#\Frameworks\Infrastructure\ServiceInterface\AsyncProcessingService\AsyncProcessingService.sln

インストール †

ビルド出力（*.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>

• ビルド
  Visual Studioから普通にビルドする。

サーバで実行される非同期処理タスク †

AsyncSvc_sample

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

• ビルド
  Visual Studioから普通にビルドする。

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

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

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

実行 †

• AsyncProcessingService?をSCMから開始する。
• TestAsyncSvc_Sampleを実行して非同期処理タスクを投入する。

確認 †

• 非同期処理管理テーブルを監視して非同期処理が遂行されることを確認する。
  

• 非同期処理サービスが実行されない場合は以下のログを分析する。
  "C:\root\files\resource\Log\"
  • 非同期処理サービス
    • ASYNC-SERVICE.log
    • ACCESS-ASYNC.YYYY-MM-DD.log
    • SQLTRACE-ASYNC.YYYY-MM-DD.log
  • クライアント
    • ACCESS.YYYY-MM-DD.log
    • SQLTRACE.YYYY-MM-DD.log

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

引数・戻り値、B層、D層 †

• https://github.com/OpenTouryoProject/OpenTouryo/tree/02-20/root/programs/C%23/Frameworks/Infrastructure/Business/AsyncProcessingService

非同期処理サービス本体 †

• https://github.com/OpenTouryoProject/OpenTouryo/tree/02-20/root/programs/C%23/Frameworks/Infrastructure/ServiceInterface/AsyncProcessingService

非同期処理タスクの開発方法 †

https://github.com/OpenTouryoProject/OpenTouryo/blob/02-20/root/programs/C%23/Samples/AsyncSvc_sample/AsyncSvc_sample/LayerB.cs

MyApsBaseLogic? †

• https://github.com/OpenTouryoProject/OpenTouryo/blob/02-20/root/programs/C%23/Frameworks/Infrastructure/Business/Business/MyApsBaseLogic.cs
  • 非同期処理タスクのB層が継承するクラス。
  • 業務テーブルと非同期処理管理テーブルに接続可能。

DamKeyforABT †

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

DamKeyforAMT †

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

接続文字列 †

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

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

UOC_Start（UOC_XXXX） †

• https://github.com/OpenTouryoProject/OpenTouryo/blob/02-20/root/programs/C%23/Samples/AsyncSvc_sample/AsyncSvc_sample/LayerB.cs#L184

概要 †

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

設定 †

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

https://github.com/OpenTouryoProject/OpenTouryo/blob/02-20/root/programs/C%23/Frameworks/Infrastructure/ServiceInterface/AsyncProcessingService/TMProtocolDefinition.xml

処理の流れ †

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

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

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

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

業務処理メソッド †

• https://github.com/OpenTouryoProject/OpenTouryo/blob/02-20/root/programs/C%23/Samples/AsyncSvc_sample/AsyncSvc_sample/LayerB.cs#L221

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

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

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

• 補足
  • 必要に応じてループで実装する。
  • サンプルでは一定の確率で
    • StopとAbortを実行する。
    • UpdateTaskCommandメソッドを使用する。

GenerateProgressRate?メソッド †

ダミーの業務処理。ランダムな進捗率を返す。

Utilityメソッド †

• https://github.com/OpenTouryoProject/OpenTouryo/blob/02-20/root/programs/C%23/Samples/AsyncSvc_sample/AsyncSvc_sample/LayerB.cs#L108

DeserializeFromBase64Stringメソッド †

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

SerializeToBase64Stringメソッド †

DeserializeFromBase64Stringメソッドの逆を行う。

GetCommandValue?メソッド †

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

ResumeProcessing?メソッド †

非同期処理管理テーブルの本非同期タスクのTaskIDに対応するCommandIDを、
UpdateTaskCommandメソッドによって「0」クリアする。

UpdateProgressRate?メソッド †

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

UpdateTaskCommand?メソッド †

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

     

Site admin: OpenTouryo

PukiWiki 1.4.7 Copyright © 2001-2006 PukiWiki Developers Team. License is GPL.
Based on "PukiWiki" 1.3 by yu-ji. Powered by PHP 5.3.3. HTML convert time: 0.038 sec.