Function/service/beancontrol - Nimbus Wiki - Nimbus

[フレームワーク]業務フロー

アプリケーション開発において、業務ロジックを部品化して、部品を組み合わせる事で、業務フローを組み立てる要求があります。

部品化した業務ロジックのフロー制御には、以下のような機能が必要となります。

• 呼び出し元から処理パラメータを受け取る
• 業務ロジックBeanに設定やデータを渡す
• 業務ロジックBeanの処理実行メソッドを呼び出す
• 業務ロジックBeanの処理結果を参照する
• 処理結果を元に分岐する
• 子となる業務フローを呼び出す
• 同期/非同期（応答待ち、応答時コールバック）実行をサポートする
• 分散並列実行をサポートする
• 流量制御をサポートする
• トランザクション制御（呼び出し時トランザクション指定、宣言的トランザクション指定）をサポートする
• 業務フローのオーバーライド
• アスペクト指向

業務フローの呼び出し機能を抽象化したのがBeanFlowInvokerです。
また、そのファクトリが、BeanFlowInvokerFactoryです。

関連するパッケージは、以下です。

• jp.ossc.nimbus.service.beancontrol
• jp.ossc.nimbus.service.beancontrol.interfaces
• jp.ossc.nimbus.service.beancontrol.resource

アプリケーション向けインタフェース BeanFlowInvokerFactory

アプリケーション向けインタフェースBeanFlowInvokerFactoryを使った簡単なアプリケーションのサンプルを示します。

 import jp.ossc.nimbus.core.ServiceManagerFactory;
 import jp.ossc.nimbus.service.beancontrol.interfaces.BeanFlowInvokerFactory;
 import jp.ossc.nimbus.service.beancontrol.interfaces.BeanFlowInvoker;
 
 // BeanFlowInvokerFactoryを取得
 BeanFlowInvokerFactory factory = (BeanFlowInvokerFactory)ServiceManagerFactory.getServiceObject("BeanFlowInvokerFactory");
 
 // BeanFlowInvokerを生成する
 BeanFlowInvoker invoker = factory.createFlow("FlowName");
 
 // 業務フローを呼び出す
 Object ret = invoker.invokeFlow("param");

実装サービスの一覧は以下のとおりです。

実装サービス	実装概要
jp.ossc.nimbus.service.beancontrol.DefaultBeanFlowInvokerFactoryService	デフォルト実装
jp.ossc.nimbus.service.beancontrol.BeanFlowInvokerFactoryGroupService	BeanFlowInvokerFactoryをグルーピングする
jp.ossc.nimbus.service.beancontrol.ClientBeanFlowInvokerFactoryService	リモートの業務フローを呼び出す

アプリケーション向けインタフェース BeanFlowInvoker

アプリケーション向けインタフェースBeanFlowInvokerを使った簡単なアプリケーションのサンプルを示します。

 import jp.ossc.nimbus.core.ServiceManagerFactory;
 import jp.ossc.nimbus.service.beancontrol.interfaces.BeanFlowInvokerFactory;
 import jp.ossc.nimbus.service.beancontrol.interfaces.BeanFlowInvoker;
 
 // BeanFlowInvokerFactoryを取得
 BeanFlowInvokerFactory factory = (BeanFlowInvokerFactory)ServiceManagerFactory.getServiceObject("BeanFlowInvokerFactory");
 
 // BeanFlowInvokerを生成する
 BeanFlowInvoker invoker = factory.createFlow("FlowName");
 
 // 監視用のBeanFlowMonitorを生成する
 BeanFlowMonitor monitor = factory.createMonitor();
 
 // 業務フローを同期的に呼び出す
 Object ret = invoker.invokeFlow(
     "param", // フローへの引数。任意
     monitor
 );
 
 // 業務フローを応答待ちせずに、非同期的に呼び出す
 invoker.invokeAsynchFlow(
     "param", // フローへの引数。任意
     monitor, 
     false, // 応答待ちをするかどうか。falseは応答待ちしない
     10 // この数以上の処理要求が溜まっている場合には、待たずにエラーにする。0以下を指定した場合、このチェックは行わない 
 );
 
 // 業務フローを非同期的に呼び出し、後で応答待ちをする
 Object context = invoker.invokeAsynchFlow(
     "param", // フローへの引数。任意
     monitor, 
     true, // 応答待ちをするかどうか。trueは応答待ちする
     0 // この数以上の処理要求が溜まっている場合には、待たずにエラーにする。0以下を指定した場合、このチェックは行わない 
 );
 ret = invoker.getAsynchReply(
     context, // 非同期呼び出し時の戻り値で、応答待ちのコンテキスト
     monitor,
     10000, // 非同期で要求した処理の応答を待つタイムアウト[ms] 
     true // タイムアウトした場合に、非同期で要求した処理を取り消すかどうか。trueは、取り消す。
 );
 
 // 業務フローを、非同期的に呼び出し、応答をコールバックさせる
 invoker.invokeAsynchFlow(
     "param", // フローへの引数。任意
     monitor, 
     new BeanFlowAsynchInvokeCallback(){
         public void reply(Object output, Throwable th){
             if(th == null){
                 System.out.println(output);
             }else{
                 th.printStackTrace();
             }
         }
     },
     10 // この数以上の処理要求が溜まっている場合には、待たずにエラーにする。0以下を指定した場合、このチェックは行わない 
 );

実装クラスの一覧は以下のとおりです。

実装クラス	実装概要
jp.ossc.nimbus.service.beancontrol.BeanFlowInvokerAccessImpl	簡易実装。デフォルト実装
jp.ossc.nimbus.service.beancontrol.BeanFlowInvokerAccessImpl2	高機能実装

サンプルは、以下。

• サンプル１：業務フローをXML定義で制御してみよう。
• サンプル２：業務フローのジャーナルを出力してみよう。
• サンプル３：業務フローで並列処理を実行してみよう。
• サンプル４：業務フローで分散処理を実行してみよう。