`

WF中的跟踪服务(2):使用SqlTrackingService

应用服务器WorkflowSQL Server工作活动 
阅读更多

WF提供了可插拔的跟踪服务，运行时引擎可以在其生存期过程中添加多个运行时服务，因此可以同时启用多个不同类型的跟踪服务。WF框架提供了一个现成的SqlTrackingService跟踪服务，该服务将可配置的跟踪信息写到Sql Server数据库中，下面我们来看看如何使用SqlTrackingService跟踪服务。

跟踪事件类型

工作流运行时在执行工作流时会引发某些事件。 跟踪服务通过捕获这些事件来记录跟踪信息，工作流可以引发以下三种事件：
1.工作流事件（workflow Events）：工作流事件（workflow events）表示工作流状态改变的事件，每次工作流状态的改变都会引发跟踪服务中的跟踪事件，工作流事件定义在TrackingWorkflowEvent枚举中，包括以下值：Created ，Completed，Idle，Suspended，Resumed，Persisted，Unloaded，Loaded，Exception，Terminated，Aborted，Changed，Started。

2.活动事件（Activity Events）：活动事件表示活动状态的改变，活动的状态被定义在ActivityExecutionStatus枚举中，如下：Initialized，Executing，Canceling，Closed，Compensating，Faulting

3.用户事件（User Events）： 在工作流事件（workflow events）和活动事件（Activity Events）中我们只能跟踪已经定义好的事件，有的时候我们需要工作流中特定位置的信息，此时，我们就可以使用自定义跟踪点，用户跟踪事件可以在整个工作流生命周期的任何位置。我们使用Activity的TrackData()方法来创建用户跟踪点。

SqlTrackingService跟踪服务应用举例

1.首先我们要建立跟踪数据，建立数据库的脚本在C:\WINDOWS\Microsoft.NET\Framework\v3.0\Windows Workflow Foundation\SQL\ZH-CHS目录中，Tracking_Logic.sql和Tracking_Schema.sql两个文件。建立完成的跟踪数据库包含表，视图和一些存储过程，详细信息，请查看WF中的跟踪服务(1):Sql跟踪数据库表，视图，存储过程等相关说明这文。

2.跟踪数据库建立完成后我们新建一个顺序工作流控制台程序，在工作流设计器中我们只要拖入一个CodeActivity活动即可，工作流的代码如下：

namespace CarySqlTrackingService
{
    public sealed partial class CarySqlTrackingServiceWorkflow: SequentialWorkflowActivity
    {
        public CarySqlTrackingServiceWorkflow()
        {
            InitializeComponent();
        }

        private void codeActivity1_ExecuteCode(object sender, EventArgs e)
        {
            Console.WriteLine("CodeActivity执行了哦！");
         }
    }
}

3.在宿主程序中，我们给workflow runtime添加SqlTrackingService跟踪服务，代码如下：
namespace CarySqlTrackingService
{
   class Program
   {
      private static String strConn = String.Format("Initial Catalog={0};Data Source={1};
           Integrated Security={2};","WorkflowTracking", @"localhost\SQLEXPRESS", "SSPI");
      static void Main(string[] args)
      {
         using(WorkflowRuntime workflowRuntime = new WorkflowRuntime())
         {
            SqlTrackingService sts = new SqlTrackingService(strConn);
            AutoResetEvent waitHandle = new AutoResetEvent(false);
            workflowRuntime.WorkflowCompleted += delegate(object sender, 
WorkflowCompletedEventArgs e) {waitHandle.Set();};
            workflowRuntime.WorkflowTerminated += delegate(object sender, 
WorkflowTerminatedEventArgs e)
            {
                Console.WriteLine(e.Exception.Message);
                waitHandle.Set();
            };
            workflowRuntime.AddService(sts);
            WorkflowInstance instance = workflowRuntime.CreateWorkflow(typeof
(CarySqlTrackingService.CarySqlTrackingServiceWorkflow));
            Console.WriteLine("---工作流执行开始---");
            instance.Start();
            waitHandle.WaitOne();
            Console.WriteLine("---工作流执行结束---");
         }
     }
  }
}

4.我们还可以使用配置文件的方式来使用SqlTrackingService，app.config代码如下：

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="WorkflowRuntime" 
      type="System.Workflow.Runtime.Configuration.WorkflowRuntimeSection,
        System.Workflow.Runtime, Version=3.0.00000.0, Culture=neutral,
        PublicKeyToken=31bf3856ad364e35" />
  </configSections>
  <WorkflowRuntime>
    <CommonParameters>
      <!--Add parameters common to all services-->
      <add name="ConnectionString" 
           value="Initial Catalog=WorkflowTracking;
             Data Source=localhost\SQLEXPRESS;
             Integrated Security=SSPI;" />
    </CommonParameters>
    <Services>
      <!--Add core services here-->
      <add type="System.Workflow.Runtime.Tracking.SqlTrackingService, 
        System.Workflow.Runtime, Version=3.0.00000.0, Culture=neutral, 
        PublicKeyToken=31bf3856ad364e35"/>
    </Services>
  </WorkflowRuntime>
</configuration>

5.在宿主程序中我们需要使用重载的WorkflowRuntime构造函数来传递配置节名就可以了。
using(WorkflowRuntimeworkflowRuntime = newWorkflowRuntime("WorkflowRuntime")

6.现在我们就使用了SqlTrackingService跟踪服务，运行工作流我们会发现执行的结果只显示CodeActivity被执行了，并没有看到我们的跟踪信息，实际上现在跟踪数据已经存到的Sql Server的跟踪数据库了，不信你可以打开Sql Server数据库中去查看相应的表内容。

使用 SqlTrackingQuery 查询跟踪数据

1.上面我们看到了使用SqlTrackingService跟踪服务后，跟踪的信息已经保存到了数据库中，但是我们直接去数据库中查看很不方便，SqlTrackingQuery 类提供了一些方法和属性，可用于访问存储在 SqlTrackingService 跟踪数据库中的跟踪数据。 对此数据的访问是通过 SqlTrackingWorkflowInstance 对象提供的。 可以调用 TryGetWorkflow 方法来获取特定工作流实例的 SqlTrackingWorkflowInstance。 还可以选择调用 GetWorkflows 方法来获取 SqlTrackingWorkflowInstance 对象的集合，这些对象对应于具有跟踪数据的工作流实例，其中的跟踪数据与一组包含在作为参数传递到方法的SqlTrackingQueryOptions 对象中的查询参数相匹配。

通过传递跟踪数据库的连接字符串，创建 SqlTrackingQuery 类的实例。 然后，可以调用TryGetWorkflow 或GetWorkflows 方法来得到SqlTrackingWorkflowInstance 对象或 SqlTrackingWorkflowInstance 对象的集合。 ActivityEvents 属性包含 ActivityTrackingRecord 对象的集合，这些对象包含工作流中的活动的跟踪信息。 此外，还可以通过检查包含在WorkflowEvents 集合中的 WorkflowTrackingRecord 对象，使用相同的过程来跟踪工作流实例事件。 对于通过调用 TrackData 方法插入的用户事件，UserTrackingRecord 对象将包含在 UserEvents 集合中，该集合也是在SqlTrackingWorkflowInstance 类中定义的。

2.下面我们对SqlTrackingQuery 自己封装了一个类来将跟踪数据查询出来写到控制台上，TrackingConsoleWriter.cs，该类我们会在以后的文章也会使用，现在虽然用不了该类的全部功能，但是先给出类的全部代码：代码如下：

namespace CarySqlTrackingService
{
    public class TrackingConsoleWriter
    {
        private String connectionString = String.Empty;
        public TrackingConsoleWriter(String connString)
        {
            connectionString = connString;
        }
public void DisplayTrackingData(Guid instanceId)
        {
            SortedList<Int32, TrackingRecord> records = QueryTrackingData(instanceId);
            WriteSingleInstanceToConsole(instanceId, records);
        }
private SortedList<Int32, TrackingRecord> QueryTrackingData(Guid instanceId)
        {
            SortedList<Int32, TrackingRecord> records = new SortedList<int, TrackingRecord>();
            try
{
                SqlTrackingQuery query = new SqlTrackingQuery(connectionString);
                SqlTrackingWorkflowInstance instance = null;
                query.TryGetWorkflow(instanceId, out instance);
                BuildSortedList(records, instance);
            }
            catch (System.Data.SqlClient.SqlException e)
            {
                Console.WriteLine("SqlException in QueryTrackingData: {0}", e.Message);
            }
            return records;
        }
private static void BuildSortedList(SortedList<Int32, TrackingRecord> records, 
SqlTrackingWorkflowInstance instance)
        {
            if (instance != null)
            {
                foreach (TrackingRecord record in instance.WorkflowEvents)
                {
                    records.Add(record.EventOrder, record);
                }
                foreach (TrackingRecord record in instance.ActivityEvents)
                {
                    records.Add(record.EventOrder, record);
                }
                foreach (TrackingRecord record in instance.UserEvents)
                {
                    records.Add(record.EventOrder, record);
                }
            }
        }
private void WriteSingleInstanceToConsole(Guid instanceId, 
SortedList<Int32, TrackingRecord> records)
        {
            Console.WriteLine("工作流实例 {0}的跟踪数据", instanceId);
            foreach (TrackingRecord record in records.Values)
            {
                if (record is WorkflowTrackingRecord)
                {
                    WorkflowTrackingRecord wfRecord = record as WorkflowTrackingRecord;
                    Console.WriteLine("{0:HH:mm:ss.fff} Workflow {1}", wfRecord.EventDateTime,
                        wfRecord.TrackingWorkflowEvent);
                }
                else if (record is ActivityTrackingRecord)
                {
                    ActivityTrackingRecord actRecord = record as ActivityTrackingRecord;
                    Console.WriteLine("{0:HH:mm:ss.fff} {1} {2}, Type={3}", 
                        actRecord.EventDateTime,actRecord.ExecutionStatus,
                        actRecord.QualifiedName,actRecord.ActivityType.Name);
                    WriteBodyToConsole(actRecord);
                }
                else if (record is UserTrackingRecord)
                {
                    UserTrackingRecord userRecord = record as UserTrackingRecord;
                    if (userRecord.UserData is RuleActionTrackingEvent)
                    {
                        WriteRuleData(userRecord);
                    }
                    else
                    {
                        Console.WriteLine("{0:HH:mm:ss.fff} UserData from {1} {2}:{3}",
                            userRecord.EventDateTime,userRecord.QualifiedName,
                            userRecord.UserDataKey,userRecord.UserData);
                    }
                }
            }
            Console.WriteLine("工作流实例{0}跟踪数据完成\n\r", instanceId);
        }

        private void WriteBodyToConsole(ActivityTrackingRecord record)
        {
            if (record.Annotations.Count > 0)
            {
                foreach (String annotation in record.Annotations)
                {
                    Console.WriteLine("{0}", annotation);
                }
            }
            if (record.Body.Count > 0)
            {
                foreach (TrackingDataItem data in record.Body)
                {
                    Console.WriteLine("{0}={1}",data.FieldName, data.Data);
                }
            }
        }

        private static void WriteRuleData(UserTrackingRecord userRecord)
        {
            RuleActionTrackingEvent ruleAction
                = userRecord.UserData as RuleActionTrackingEvent;
            Console.WriteLine(
                "{0:HH:mm:ss.fff} RuleAction from {1} Rule:{2} Result:{3}",
                userRecord.EventDateTime,userRecord.QualifiedName,
                ruleAction.RuleName,ruleAction.ConditionResult);
        }

        public void DisplayAllTrackingData(SqlTrackingQueryOptions options)
        {
            IList<SqlTrackingWorkflowInstance> workflows = QueryWorkflowList(options);
            SortedList<Int32, TrackingRecord> records = new SortedList<int, TrackingRecord>();
            foreach (SqlTrackingWorkflowInstance wf in workflows)
            {
                records.Clear();
                BuildSortedList(records, wf);
                WriteSingleInstanceToConsole(wf.WorkflowInstanceId, records);
            }
        }

   private IList<SqlTrackingWorkflowInstance> QueryWorkflowList(SqlTrackingQueryOptions options)
   {
       IList<SqlTrackingWorkflowInstance> workflows = new List<SqlTrackingWorkflowInstance>();
       try
       {
           SqlTrackingQuery query = new SqlTrackingQuery(connectionString);
           workflows = query.GetWorkflows(options);
       }
       catch (System.Data.SqlClient.SqlException e)
       {
           Console.WriteLine("SqlException in QueryWorkflowList: {0}", e.Message);
       }
       return workflows;
    }
  }
}

3.然后我们使用我们封装好的类来查询跟踪数据，需要添加如下代码就可以了：
TrackingConsoleWriter trackingWriter= new TrackingConsoleWriter(strConn);
trackingWriter.DisplayTrackingData(instance.InstanceId);

4.下面是执行结果：

SqlTrackingService1

用户跟踪的事件

1.一个User Track Point（用户跟踪点）是我们在工作流或是自定义活动中加入的。你可以加在任意的位置。我们如何创建用户跟踪点呢，我只要调用Activity的TrackData方法就可以了。这样你设定的用户跟踪点就会被跟踪服务记录下来，同样是一条UserTrackingRecord。我们在CodeActivity中添加TrackData方法，代码如下：

private void codeActivity1_ExecuteCode(object sender, EventArgs e)
{
   Console.WriteLine("CodeActivity执行了哦！");
   TrackData("CaryUserPoint", "CaryUserData");
}

2.再次运行工作流，结果如下：

SqlTrackingService2

3.从结果中我们可以看到红色线部分就是我们自己加入的跟踪点。

分享到：
| WF中的跟踪服务(1):Sql跟踪数据库表，视图 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics