学步园

1.WorkflowRuntime在ASP.NET下的寄宿方式

      WF在APS.NET的运行方案中最直接的宿主方式，便是将workflowRuntime的起始及结束交给网站静态的Global.asax程序区块负责，将workflowRuntime.StartRuntime()置于Application_Start中执行。

Global.asax源代码如下

using System;<br /> using System.Collections.Generic;<br /> using System.Linq;<br /> using System.Web;<br /> using System.Web.Security;<br /> using System.Web.SessionState;<br /> using System.Workflow.Activities;<br /> using System.Workflow.ComponentModel;<br /> using System.Workflow.Runtime;<br /> /*<br /> * WF在APS.NET的运行方案中最直接的宿主方式，<br /> * 便是将workflowRuntime的起始及结束交给网站静态的Global.asax程序区块负责，<br /> * 将workflowRuntime.StartRuntime()置于Application_Start中执行<br /> */<br /> namespace WebApplication1<br /> {<br /> public class Global : System.Web.HttpApplication<br /> {<br /> // 在应用程序启动时运行的代码<br /> protected void Application_Start(object sender, EventArgs e)<br /> {<br /> //使用应用程序配置文件的指定节初始化 WorkflowRuntime 类的新实例。<br /> //在Web.config有节点<!--WF注册服务--><section name="WorkflowRuntime"><!--结束WF注册服务--><br /> WorkflowRuntime workflowRuntime = new WorkflowRuntime("WorkflowRuntime");<br /> //将workflowRuntime实例保存到当前应用程序中<br /> Application["WorkflowRuntime"] = workflowRuntime;<br /> workflowRuntime.StartRuntime();<br /> }<br /> // 在新会话启动时运行的代码<br /> protected void Session_Start(object sender, EventArgs e)<br /> {<br /> }<br /> protected void Application_BeginRequest(object sender, EventArgs e)<br /> {<br /> }<br /> protected void Application_AuthenticateRequest(object sender, EventArgs e)<br /> {<br /> }<br /> // 在出现未处理的错误时运行的代码<br /> protected void Application_Error(object sender, EventArgs e)<br /> {<br /> }<br /> // 在会话结束时运行的代码。<br /> // 注意: 只有在 Web.config 文件中的 sessionstate 模式设置为<br /> // InProc 时，才会引发 Session_End 事件。如果会话模式设置为 StateServer<br /> // 或 SQLServer，则不会引发该事件。<br /> protected void Session_End(object sender, EventArgs e)<br /> {<br /> }<br /> // 在应用程序关闭时运行的代码<br /> protected void Application_End(object sender, EventArgs e)<br /> {<br /> WorkflowRuntime workflowRuntime = Application["WorkflowRuntime"] as WorkflowRuntime;<br /> workflowRuntime.StopRuntime();<br /> }<br /> }<br /> } 

PS:2011-6-8

上述的这种寄宿方式保证了WorkflowRuntime在整个程序运行期间只有一个实例（Making sure Workflow Runtime has a single instance in the WebApplication Runtime）

另外一种保证“WorkflowRuntime单一实例”的方法是通过工程模式来创建WorkflowRuntime实例。

我们定义一个静态类WorkflowFactory，其代码如下：

using System;<br /> using System.Collections.Generic;<br /> using System.Linq;<br /> using System.Text;<br /> using System.Workflow.Runtime;<br /> namespace WorkflowHost<br /> {<br /> public static class WorkflowFactory<br /> {<br /> //WorkflowRuntime的单一实例<br /> private static WorkflowRuntime _workflowRuntime = null;</p> <p> private static object _syncRoot = new object();<br /> //启动workflow运行时<br /> public static WorkflowRuntime GetWorkflowRuntime()<br /> {<br /> //多线程环境下防止并发访问<br /> lock (_syncRoot)<br /> {<br /> if (null == _workflowRuntime)<br /> {<br /> AppDomain.CurrentDomain.ProcessExit += new EventHandler(StopWorkflowRuntime);<br /> AppDomain.CurrentDomain.DomainUnload += new EventHandler(StopWorkflowRuntime);</p> <p> _workflowRuntime = new WorkflowRuntime();<br /> _workflowRuntime.StartRuntime();<br /> }<br /> }<br /> return _workflowRuntime;<br /> }<br /> //停止workflow运行时<br /> static void StopWorkflowRuntime(object sender, EventArgs e)<br /> {<br /> if (_workflowRuntime != null)<br /> {<br /> if (_workflowRuntime.IsStarted)<br /> {<br /> try<br /> {<br /> _workflowRuntime.StopRuntime();<br /> }<br /> catch (ObjectDisposedException)<br /> {<br /> }<br /> }<br /> }<br /> }<br /> }<br /> }<br />  

在程序中创建WorkflowRuntime实例的方法如下代码所示：

WorkflowRuntime workflowRuntime = WorkflowFactory.GetWorkflowRuntime(); 

2.WorkflowRuntime服务注册

      WorkflowRuntime.AddService 方法用于将指定的服务添加到工作流运行时引擎中。通过添加核心服务可以配置工作流运行时引擎。 核心服务是派生自以下任一服务基类的服务：WorkflowSchedulerService 类、WorkflowCommitWorkBatchService类、WorkflowPersistenceService 类和 TrackingService 类。 只能在工作流运行时引擎不运行的情况下添加核心服务，即当 IsStarted 为 false 时才能添加核心服务（在workflowRuntime.StartRuntime();前）。WorkflowRuntime 也可以用作存储其他服务的容器，其他工作流或宿主上运行的应用程序可能会使用这些服务。 如果您在工作流运行时引擎启动后添加派生自WorkflowRuntimeService 类的非核心服务，则 AddService 将会调用该服务实现的 Start 方法（即AddService方法会自动将添加的服务启动）。

前面的核心服务类都是派生自WorkflowRuntimeService 类，它的继承层次结构如下所示：

System.Object
    System.Workflow.Runtime.Hosting.WorkflowRuntimeService
      System.Workflow.Activities.ExternalDataExchangeService
      System.Workflow.Runtime.Hosting.ChannelManagerService
      System.Workflow.Runtime.Hosting.WorkflowCommitWorkBatchService
      System.Workflow.Runtime.Hosting.WorkflowLoaderService
      System.Workflow.Runtime.Hosting.WorkflowPersistenceService
      System.Workflow.Runtime.Hosting.WorkflowSchedulerService
      System.Workflow.Runtime.Tracking.TrackingService

从上面的基层结构我们也可以看出，WorkflowRuntimeService的7个派生服务中，只有4个是核心服务，其他的都不是核心服务。前面提到只能在workflowRuntime.StartRuntime();前添加核心服务，那么这个核心服务是如何添加的。这就涉及到了WF服务注册的问题，是通过web.config配置文件完成添加核心服务的。

web.config示例代码（摘取关键部分）：

<?xml version="1.0"?><br /> <configuration><br /> <configSections><br /> <sectionGroup name="system.web.extensions" type="System.Web.Configuration.SystemWebExtensionsSectionGroup, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35"><br /> <sectionGroup name="scripting" type="System.Web.Configuration.ScriptingSectionGroup, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35"><br /> <section name="scriptResourceHandler" type="System.Web.Configuration.ScriptingScriptResourceHandlerSection, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35" requirePermission="false" allowDefinition="MachineToApplication"/><br /> <sectionGroup name="webServices" type="System.Web.Configuration.ScriptingWebServicesSectionGroup, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35"><br /> <section name="jsonSerialization" type="System.Web.Configuration.ScriptingJsonSerializationSection, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35" requirePermission="false" allowDefinition="Everywhere"/><br /> <section name="profileService" type="System.Web.Configuration.ScriptingProfileServiceSection, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35" requirePermission="false" allowDefinition="MachineToApplication"/><br /> <section name="authenticationService" type="System.Web.Configuration.ScriptingAuthenticationServiceSection, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35" requirePermission="false" allowDefinition="MachineToApplication"/><br /> <section name="roleService" type="System.Web.Configuration.ScriptingRoleServiceSection, System.Web.Extensions, Version=3.5.0.0, Culture=neutral, PublicKeyToken=31BF3856AD364E35" requirePermission="false" allowDefinition="MachineToApplication"/><br /> </sectionGroup><br /> </sectionGroup><br /> </sectionGroup><br /> <!--WF注册服务--><br /> <section name="WorkflowRuntime" type="System.Workflow.Runtime.Configuration.WorkflowRuntimeSection, System.Workflow.Runtime, Version=3.0.00000.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"/><br /> <!--结束WF注册服务--><br /> </configSections><br /> <!--WF注册服务--><br /> <WorkflowRuntime Name="WorkflowServiceContainer"><br /> <Services><br /> <add type="System.Workflow.Runtime.Hosting.ManualWorkflowSchedulerService, System.Workflow.Runtime, Version=3.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"/><br /> <add type="System.Workflow.Runtime.Hosting.DefaultWorkflowCommitWorkBatchService, System.Workflow.Runtime, Version=3.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"/><br /> </Services><br /> </WorkflowRuntime><br /> <!--结束WF注册服务--><br /> <appSettings/><br /> <connectionStrings/> 

      第一个WF服务注册中的内容表示增加一个叫做WorkflowRuntime的节点，在应用程序中WorkflowRuntime对象就是通过这个配置节点来创建的。

      第二个WF服务注册中的内容表示节点WorkflowRuntime的名字叫做WorkflowServiceContainer，在其中添加了ManualWorkflowSchedulerService（继承自服务基类WorkflowSchedulerService）和DefaultWorkflowCommitWorkBatchService（继承自服务基类WorkflowCommitWorkBatchService）这两个核心服务，而且核心服务也必须在这里添加。

3.工作流调用及加载服务的方法

常见的方式是通过一个 StartWorkflow()方法，方法如下：

private void StartWorkflow()<br /> {<br /> /* 下面是与宿主程序对话的步骤:<br /> * 1. 宿主创建了ExternalDataExchangeService并将其加入到工作流Runtime中.<br /> * ExternalDataExchangeService dataService = new ExternalDataExchangeService();<br /> * wr.AddService(dataService);<br /> * 这个服务由Windows Workflow提供,用以管理工作流Runtime中的所有本地通信服务,<br /> * 并且将作为progressService容器.<br /> *<br /> * 2. 宿主创建了progressService的实例并将其加入到ExternalDataExchangeService<br /> * 管理的服务列表中.<br /> * progressService = new ProgressService();<br /> * dataService.AddService(progressService);//dataService==null<br /> * ExternalDataExchangeService将分析IProgressService接口<br /> */<br /> WorkflowRuntime wr = Application["WorkflowRuntime"] as WorkflowRuntime;<br /> ManualWorkflowSchedulerService scheduler = wr.GetService<ManualWorkflowSchedulerService>();<br /> // ExternalDataExchangeService dataService = wr.GetService<ExternalDataExchangeService>();创建的dataService为null，因此会报错误：未将对象引用设置到对象的实例</p> <p> //创建本地通信服务<br /> ExternalDataExchangeService dataService = new ExternalDataExchangeService();<br /> //本地通信服务添加到工作流运行时WorkflowRuntime中<br /> wr.AddService(dataService);<br /> //GetService<T>() 从工作流运行时引擎中检索指定泛型类型的服务。<br /> ProgressService progressService = wr.GetService<ProgressService>();<br /> //如果在工作流运行时中检索到的ProgressService为空，则创建该服务，<br /> //并将其添加到本地通信服务dataService中，这样，以后就能够从workflowruntime中检索到。<br /> if (progressService == null)<br /> {<br /> progressService = new ProgressService();<br /> dataService.AddService(progressService);<br /> }<br /> //载入WorkflowCompleted的事件驱动程序<br /> wr.WorkflowCompleted += new EventHandler<WorkflowCompletedEventArgs>(workflowRuntime_WorkflowCompleted);<br /> //创建工作流实例。CreateWorkflow(Type) 使用指定工作流 Type 创建新的工作流实例。<br /> WorkflowInstance workflowInstance = wr.CreateWorkflow(typeof(WorkflowLibrary1.Workflow1));</p> <p> //开始执行工作流实例。<br /> workflowInstance.Start();<br /> //RunWorkflow(Guid workflowInstanceId) 运行指定的工作流实例。<br /> scheduler.RunWorkflow(workflowInstance.InstanceId);<br /> } 

解析上述程序，我们会发现可以通过GetService<T>()方法从工作流运行时引擎中检索指定泛型类型（ManualWorkflowSchedulerService）的服务。

ManualWorkflowSchedulerService scheduler = wr.GetService<ManualWorkflowSchedulerService>(); 

而不能通过该方法获取ExternalDataExchangeService的服务，这是因为我们没有在web.config中为ExternalDataExchangeService服务进行注册。因为ExternalDataExchangeService不是核心服务，因此我们可以在WorkflowRuntime运行以后再添加。如上述代码所示，我们手工添加ExternalDataExchangeService服务的方法如下代码所示：

//创建本地通信服务<br /> ExternalDataExchangeService dataService = new ExternalDataExchangeService();<br /> //本地通信服务添加到工作流运行时WorkflowRuntime中<br /> wr.AddService(dataService); 

4.添加ExternalDataExchangeService服务的方法

      如果要添加ExternalDataExchangeService服务，只需要在web.config中添加ExternalDataExchangeService的声明。

<add type="System.Workflow.Activities.ExternalDataExchangeService, System.Workflow.Activities, Version=3.0.00000.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35"/> 

修改web.config以后我们需要注释掉前面手工添加ExternalDataExchangeService服务的代码才能运行，不然会报错:"异常详细信息: System.InvalidOperationException: 无法多次添加同一服务"。其他服务的添加方法都非常相似。