3.2 工作流与外部世界

　　对许多工作流来说,有一个重要的步骤是决定工作流与应用程序之间如何交互.我们如何得知工作流是否顺利完成?如何从运行中的工作流实例获取数据?如何获取已经完成的工作流的数据?这一节,我们来介绍一些解决这些问题的基本技术原理.

　　工作流的基本通信机制包括事件,方法和工作流参数.应用程序可以触发工作流实例的事件,也可以从工作流Runtime接收工作流实例的生存周期事件.首先我们来讨论一下工作流的生命周期事件.

　　3.2.1 工作流实例生存周期事件

　　WorkflowRuntime类是进入所有正在运行的工作流的大门.WorkflowRuntime公开了许多事件,我们可以利用这些事件来监听正在运行的工作流的变化.这些事件如下表所示:

　　OK,实践一下,新建一个Sequential Workflow Console Application项目,名为chapter3_sequential,项目中的WorklowEvents.xoml包含一个Code活动和一个Suspend活动,工作流的设计视图如下:

　　Code活动只负责在控制台中输出一条消息,WorklowEvents的代码如下:

usingSystem;
usingSystem.ComponentModel;
usingSystem.ComponentModel.Design;
usingSystem.Collections;
usingSystem.Drawing;
usingSystem.Workflow.ComponentModel.Compiler;
usingSystem.Workflow.ComponentModel.Serialization;
usingSystem.Workflow.ComponentModel;
usingSystem.Workflow.ComponentModel.Design;
usingSystem.Workflow.Runtime;
usingSystem.Workflow.Activities;
usingSystem.Workflow.Activities.Rules;
　　
namespacechapter3_sequential
{
publicsealedpartialclassWorklowEvents:SequentialWorkflowActivity
{
publicWorklowEvents()
{
InitializeComponent();
}
　　
privatevoidcodeActivity1_ExecuteCode(objectsender,EventArgse)
{
Console.WriteLine("Executing");
}
}
　　
}

　　然后将SuspendActivty的Error属性设置为intentionally suspended.

　　编写Program.cs的代码如下:

#regionUsingdirectives
　　
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingSystem.Threading;
usingSystem.Workflow.Runtime;
usingSystem.Workflow.Runtime.Hosting;
　　
#endregion
　　
namespacechapter3_sequential
{
classProgram
{
staticvoidMain(string[]args)
{
using(WorkflowRuntimeworkflowRuntime=newWorkflowRuntime())
{
AutoResetEventwaitHandle=newAutoResetEvent(false);
//工作流创建
workflowRuntime.WorkflowCreated+=delegate(objectsender,WorkflowEventArgse)
{
Console.WriteLine("Workflowcreated");
};
//工作流开始
workflowRuntime.WorkflowStarted+=delegate(objectsender,WorkflowEventArgse)
{
Console.WriteLine("Workflowstarted");
};
//工作流空闲
workflowRuntime.WorkflowIdled+=delegate(objectsender,WorkflowEventArgse)
{
Console.WriteLine("Workflowidled");
};
//工作流暂停
workflowRuntime.WorkflowSuspended+=delegate(objectsender,WorkflowSuspendedEventArgse)
{
Console.WriteLine("Workflowsuspended");
//输出SuspendActivty的Error属性内容
Console.WriteLine("tReason:"+e.Error);
//让工作流恢复执行
e.WorkflowInstance.Resume();
};
//工作流恢复
workflowRuntime.WorkflowResumed+=delegate(objectsender,WorkflowEventArgse)
{
Console.WriteLine("Workflowresumed");
waitHandle.Set();
};
//工作流完成
workflowRuntime.WorkflowCompleted+=delegate(objectsender,WorkflowCompletedEventArgse)
{
Console.WriteLine("Workflowcompleted");
waitHandle.Set();
};
//工作流终止
workflowRuntime.WorkflowTerminated+=delegate(objectsender,WorkflowTerminatedEventArgse)
{
Console.WriteLine("Workflowterminated");
Console.WriteLine("tException:"+e.Exception.Message);
waitHandle.Set();
　　
};
　　
WorkflowInstanceinstance=workflowRuntime.CreateWorkflow(typeof(chapter3_sequential.WorklowEvents));
instance.Start();
Console.Read();
waitHandle.WaitOne();
}
}
}
}

　　代码中有两个事件(Terminated和Completed)需要执行WaitHandle对象的Set方法.我们在第一章中讨论过,Runtime的默认是在后台线程执行工作流.我们需要通过WaitHandle对象的WaitOne方法来阻止主线程的执行,该方法会使主线程一直等待Set方法发出的完成信号.如果我们不等待完成信号,主线程就会退出,应用程序将在工作流执行之前终止.

　　现在来执行一下:

　　如果执行过程遇到了不能继续的点,我们不希望发生异常而去终止工作流,这时,我们用SuspendActivty中断了工作流并触发了WorkflowSuspended事件,其EventHandler的WorkflowSuspendedEventArgs中也会包含Error属性的内容.

　　当WorkflowSuspended事件触发后,我们输出了一条消息并且直接让工作流实例去恢复操作.工作流从停止的地方继续执行到完成.

　　工作流实例事件不是唯一可以监视工作流执行过程的技术,工作流跟踪服务也可以接收关于工作流状态的粗粒化(exceptionally granular)信息.WF提供SqlTrackingService类来将跟踪日志信息记录到SQL Server数据库,而且我们还可以实现自定义跟踪服务并在Runtime中启用.