当前位置: 首页 > 工具软件 > Dropthings > 使用案例 >

开源项目dropthings的工作流接口实现WorkflowHelper

吕子真
2023-12-01

开源项目dropthings的工作流接口实现WorkflowHelper

(注:本项目中,在业务层中使用工作流的方式引起了一些争议。

但我的本意是了解这个开源项目,所以,文章会继续下去,不管结果如何。)

系统版本 Dropthings-2.1
Dropthings.Business.Workflows.WorkflowHelper

用途:在业务层中,工作流被同步执行;而默认下,是异步。并且,
     异步工作流的返回值的取得,是比较复杂的。
     在asp.net环境中,异步执行需要另外的线程,
     如:线程的间接启动,停止额外的线程,
     等待线程,线程间的数据传递等。
     因此,同步比较好。
    
     所以,此类用于工作流环境的设置。
  
   一、创建工作流执行环境 
   ==================
其中:    //创建默认的asp.net工作流环境为同步
      public static WorkflowRuntime CreateDefaultRuntime()
        {
            //创建工作流运行库
            WorkflowRuntime workflowRuntime = new WorkflowRuntime();

            //添加【负责同步执行工作流的服务ManualWorkflowSchedulerService】
var manualService = new ManualWorkflowSchedulerService();
            workflowRuntime.AddService(manualService);
           
            //Activities.CallWorkflowService服务,支持在一个工作流中运行另外的工作流
            var syncCallService = new Activities.CallWorkflowService();
            workflowRuntime.AddService(syncCallService);

            workflowRuntime.StartRuntime();

            return workflowRuntime;
        }
为了确保一个应用程序域只有一个工作流执行环境,在Global.asax中如下设置:
void Application_Start(object sender, EventArgs e)
    {
        // 在应用程序开始时执行
        // 在应用程序中创建唯一的工作流环境并保存到应用程序环境中
        System.Workflow.Runtime.WorkflowRuntime runtime = Dropthings.Business.Workflows.WorkflowHelper.CreateDefaultRuntime();
        Application[APPLICATION_WORKFLOW_RUNTIME_KEY] = runtime;//这里是弱类型?????

        //Unity是微软Patterns & Practices团队所开发的一个轻量级的,可扩展的依赖注入(Dependency Injection)容器
        //http://unity.codeplex.com
        //负责工作流执行环境生命周期和容器一致。当离开容器的作用域范围时,容器会被销毁,同时工作流执行环境也被销毁。
        //当容器被显式销毁时,工作流执行环境也被销毁。在容器有效的作用域范围,
        //使用Resolve/ResolveAll方法获取工作流执行环境的时候,容器会在第一次调用时创建实例,但在后面的调用中,始终只得到相同的实例,利用这种Manager实现Singleton模式。
        //工作流执行环境不是强类型引用的时候,可能会被GC给回收。

        //此句不知道用中文如何表达:Setup default Dependencies for regular execution where all dependencies are real
        ObjectContainer.RegisterInstanceExternalLifetime<WorkflowRuntime>(runtime);
       
        //注入IWorkflowHelper的实例WorkflowHelper,在每个线程中返回同一个对象实例WorkflowHelper
        ObjectContainer.RegisterTypePerThread<IWorkflowHelper, WorkflowHelper>();
    }
   
    二、销毁工作流运行环境
    ===============
        void Application_End(object sender, EventArgs e)
    {
        //关闭应用程序是运行
        //关闭工作流运行环境
        System.Workflow.Runtime.WorkflowRuntime runtime = Application[APPLICATION_WORKFLOW_RUNTIME_KEY] as System.Workflow.Runtime.WorkflowRuntime;
        if (null != runtime)
            Dropthings.Business.Workflows.WorkflowHelper.TerminateDefaultRuntime(runtime);

        //拆卸依赖容器
        Dropthings.Business.Container.ObjectContainer.Dispose();
    }
   
    三、运行实际的工作流
    public static TResponse Run<TWorkflow, TRequest, TResponse>(TRequest request)
            where TResponse : new()
        {
            return ObjectContainer.Resolve<IWorkflowHelper>().ExecuteWorkflow<TWorkflow, TRequest, TResponse>(
                ObjectContainer.Resolve<WorkflowRuntime>(),
                request);
        }
       
       
    四、ObjectContainer 依赖注入。

 

转载地址:http://www.cnblogs.com/DotLee/archive/2009/05/25/1488898.html

 类似资料: