Workflow笔记3——BookMark和持久化

简介:

BookMark

我们在平时的工作流使用中,并不是直接这样一气呵成将整个工作流直接走完的,通常一个流程到了某一个节点,该流程节点的操作人,可能并不会马上去处理该流程,而只有当处理人处理了该流程,流程才会继续往下走。对于不同流程节点的处理人,他所能处理的是不同的流程节点。

怎么让流程停下来,等待其他用户对流程进行参与处理。并且必须能够保证流程能够在原有的处理现场情况进行保存,而且能够对流程进行继续启动和处理?那就是书签。

就好像我们看书,我们需要书签来标识,我现在已经看到哪个地方了,工作流也是一样的,我需要通过书签,来确定不同角色的人能处理的是哪一个流程。

要定义具备Bookmark的Activit,可从 NativeActivity继承,override [Execute 方法],使用[NativeActivityContext.CreateBookmark方法]添加Bookmark,需要override [ CanInduceIdle 属性],使其返回值为[True]。

1、在项目WindowsWorkFlowApp中,新建“代码活动” BookMarkCodeActivity

修改继承类为NativeActivity,Execute方法的参数类型变为NativeActivityContext类型了。代码如下:

复制代码
    public sealed class BookMarkCodeActivity : NativeActivity
    {
        // 定义一个字符串类型的活动输入参数
        public InArgument<string> BookMarkName { get; set; }
        //定义一个输出参数,用来做流程判断,相当于模拟用户处理流程节点的操作
        public OutArgument<int> Num { get; set; }

        // 创建一个BookMark,让流程停下来
        protected override void Execute(NativeActivityContext context)
        {
            // 1.获取BookMark名称
            string strBookMarkName = context.GetValue(BookMarkName);
            // 2.创建BookMark
            context.CreateBookmark(strBookMarkName,new BookmarkCallback(PreExecuteWorkFlow));
        }
        /// <summary>
        /// 注意,一定要记得注意重写此属性,并返回true,否则后面运行会报错
        /// </summary>
        protected override bool CanInduceIdle
        {
            get
            {
                return true;// base.CanInduceIdle;
            }
        }
        /// <summary>
        /// 继续执行下一个状态前,必须先执行该方法。
        /// </summary>
        /// <param name="context"></param>
        /// <param name="bookmark">书签</param>
        /// <param name="value">传递过来的值</param>
        public void PreExecuteWorkFlow(NativeActivityContext context, Bookmark bookmark, object value)
        {
            context.SetValue(Num, Convert.ToInt32(value));
        }
}
复制代码

2、生成项目WindowsWorkFlowApp

3、双击State1打开,将代码活动添加到State1中,并创建变量Vnum。

4、创建输入参数InputBookMarkName

5、改造Form1窗体

修改启动工作流的代码:

将以WorkflowApplication app;提取到类下面。

复制代码
            app = new WorkflowApplication(new Activity1(), new Dictionary<string, object>() { 
            {"InputName","神刀张三"},{"InputBookMarkName",txtBookMarkName.Text}
            });
            app.Idle = delegate(WorkflowApplicationIdleEventArgs er)
            {
                Console.WriteLine("工作流 {0} 空闲.", er.InstanceId);
                syncEvent.Set(); //这里要唤醒,不让的话,当创建了一个书签之后,界面就卡死了。
            };
复制代码

为“继续执行”按钮添加代码

复制代码
        //唤醒BookMark执行流程
        private void btnContinue_Click(object sender, EventArgs e)
        {
            //这里会调用PreExecuteWorkFlow方法,并将txtNum的值传过去
            app.ResumeBookmark(txtBookMarkName.Text, int.Parse(txtNum.Text));
        }
复制代码

6、双击T1进行修改,添加条件判断

假设VNum变量的值等于5,则继续往下执行State2。

7、添加T3,当VNum变量的值不等于5,再回到State1。

双击T3,添加条件

8、运行结果如下:

工作流持久化

持久化:工作流持久性是指独立于进程或计算机信息持续捕获工作流实例的状态。持久存储化,例如用磁盘进行存储,光盘存储等持久化的存储数据就是持久化。

为何持久化?财务审批中,提交了审批邀请后,财务总监过了一周才进行审批。那么数据必须进行持久化的保存,等待流程的继续相关处理。
工作流在长时间运行时难免会遇到一些问题,许多业务逻辑需要花费数日、数周乃至数月。在这段时间中,我们不能让工作流实例一直驻留在内存中。

工作流什么时候进行持久化?

  • 当 TransactionScope 活动完成时或 TransactedReceiveScope 活动完成时。
  • 当工作流实例变为空闲状态,且对工作流主机设置了 WorkflowIdleBehavior 时。 例如,当使用消息传递活动或 Delay 活动时会发生此情况。
  • 当 WorkflowApplication 变为空闲状态且将应用程序的 PersistableIdle 属性设置为 PersistableIdleAction.Persist 时。
  • 当指示主机应用程序持久化或卸载工作流实例时。
  • 当终止工作流实例或工作流实例结束时。
  • 当执行 Persist 活动时。
  • 当使用 Windows Workflow Foundation 的早期版本开发的工作流实例在可互操作执行过程中遇到持久点时。

1、通过创建一个数据库来持久保存工作流实例。新建数据库WorkFlowDB:

复制代码
CREATE DATABASE [WorkFlowDB]
 CONTAINMENT = NONE
 ON  PRIMARY 
( NAME = N'WorkFlowDB', FILENAME = N'G:\DataBase\WorkFlowDB.mdf' , SIZE = 5120KB , MAXSIZE = UNLIMITED, FILEGROWTH = 1024KB )
 LOG ON 
( NAME = N'WorkFlowDB_log', FILENAME = N'G:\DataBase\WorkFlowDB_log.ldf' , SIZE = 2048KB , MAXSIZE = 2048GB , FILEGROWTH = 10%)
GO
复制代码

2、然后新建表来存储工作流的实例数据,如何新建表?

到%WINDIR%\Microsoft.NET\Framework\v4.xxx\SQL\EN 文件夹下面去寻找脚本,按Win+R,运行%WINDIR%\Microsoft.NET\Framework

找到这两个SQL脚本之后,在数据库WorkFlowDB中首先运行 SqlWorkflowInstanceStoreSchema.sql 文件,然后运行 SqlWorkflowInstanceStoreLogic.sql 文件。执行完成之后,就会在数据库WorkFlowDB中新建如下表。

InstancesTable表就是用来存储工作流实例的表。

3、在项目WindowsWorkFlowApp中,添加如下两个程序集的引用

4、修改工作流启动代码

引入命名空间

using System.Activities.DurableInstancing;  

修改btnStartWorkFlow_Click代码:

            SqlWorkflowInstanceStore store =
    new SqlWorkflowInstanceStore(@"Server=.\MSSQLSERVER2012;database=WorkFlowDB;uid=sa;pwd=yujie1127);
            app.InstanceStore = store;

只需要这两行代码,就可以执行持久化工作。那么当下次重新打开工作流的时候,我需要从数据库中找到是那一条工作流实例数据,为了演示简单,我这里就将工作流实例的主键直接放到From窗体界面展示,而通常在工作中,我们是会用数据表来专门存储这些数据信息的。

5、改造Form1代码,修改btnContinue_Click

  View Code

6、我们看数据表中已经多了一条工作流实例数据

7、然后关闭应用程序,再重新启动

从数据库中找到这个ID,然后填写上。

我们看到整个工作流执行完成了,在来看数据表中的工作流实例数据已经删除了。

源码下载:WorkflowConsoleApp3.zip


本文转自邹琼俊博客园博客,原文链接:http://www.cnblogs.com/jiekzou/p/6194003.html,如需转载请自行联系原作者

相关文章
|
4天前
|
存储 人工智能 安全
AI 越智能,数据越危险?
阿里云提供AI全栈安全能力,为客户构建全链路数据保护体系,让企业敢用、能用、放心用
|
7天前
|
域名解析 人工智能
【实操攻略】手把手教学,免费领取.CN域名
即日起至2025年12月31日,购买万小智AI建站或云·企业官网,每单可免费领1个.CN域名首年!跟我了解领取攻略吧~
|
6天前
|
数据采集 人工智能 自然语言处理
3分钟采集134篇AI文章!深度解析如何通过云无影AgentBay实现25倍并发 + LlamaIndex智能推荐
结合阿里云无影 AgentBay 云端并发采集与 LlamaIndex 智能分析,3分钟高效抓取134篇 AI Agent 文章,实现 AI 推荐、智能问答与知识沉淀,打造从数据获取到价值提炼的完整闭环。
406 93
|
6天前
|
SQL 人工智能 自然语言处理
Geo优化SOP标准化:于磊老师的“人性化Geo”体系如何助力企业获客提效46%
随着生成式AI的普及,Geo优化(Generative Engine Optimization)已成为企业获客的新战场。然而,缺乏标准化流程(Geo优化sop)导致优化效果参差不齐。本文将深入探讨Geo专家于磊老师提出的“人性化Geo”优化体系,并展示Geo优化sop标准化如何帮助企业实现获客效率提升46%的惊人效果,为企业在AI时代构建稳定的流量护城河。
400 156
Geo优化SOP标准化:于磊老师的“人性化Geo”体系如何助力企业获客提效46%
|
6天前
|
数据采集 缓存 数据可视化
Android 无侵入式数据采集:从手动埋点到字节码插桩的演进之路
本文深入探讨Android无侵入式埋点技术,通过AOP与字节码插桩(如ASM)实现数据采集自动化,彻底解耦业务代码与埋点逻辑。涵盖页面浏览、点击事件自动追踪及注解驱动的半自动化方案,提升数据质量与研发效率,助力团队迈向高效、稳定的智能化埋点体系。(238字)
292 158
|
14天前
|
机器人 API 调度
基于 DMS Dify+Notebook+Airflow 实现 Agent 的一站式开发
本文提出“DMS Dify + Notebook + Airflow”三位一体架构,解决 Dify 在代码执行与定时调度上的局限。通过 Notebook 扩展 Python 环境,Airflow实现任务调度,构建可扩展、可运维的企业级智能 Agent 系统,提升大模型应用的工程化能力。