WF 4.0 之持久化操作一：SqlServer方式的存储-mysql教程-PHP中文網

首頁

資料庫

mysql教程

WF 4.0 之持久化操作一：SqlServer方式的存储

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 07, 2016 pm 03:08 PM

sqlserver儲存耐力操作方式

没有持久化的WF 能称为一个完整的WF吗，答案是否定的；如果WF不能持久化，那么流程就需要一次就执行完毕，所有的操作就要一次走下去，可现实中的工作流是这样吗，答案同样是否定的。一个投票流程需要多个评委投票之后确定一个票数最高的组长才可以进入

没有持久化的WF 能称为一个完整的WF吗，答案是否定的；如果WF不能持久化，那么流程就需要一次就执行完毕，所有的操作就要一次走下去，可现实中的工作流是这样吗，答案同样是否定的。一个投票流程需要多个评委投票之后确定一个票数最高的组长才可以进入下一个流程，如果不能持久化，那么在此流程中每个评委使用的数据(在流程中需要处理的公共数据，可能为简单类型，也可能为复杂类型)则完全不同，甚至说每个人都是不一样的，我们要在每一个步骤记录下数据，在流程结束时候进行汇总分析，很明显流程没有根据原始的思路一步一步走下去，所以我们需要在所有投票完成之前都保持一个挂起状态，只有等所有的投票完成，流程才结束，此时我们想到了持久化。

持久化分析之BookMark：

在持久化之前，我提到了需要挂起状态，为什么要挂起，挂起是一个怎样的操作。在WF中一个挂起很简单，就是一个BookMark(书签)，顾名思义，先存放一个书签，暂时结束，如果下次需要根据书签找到上次停止的地方，继续进行操作。

持久化分析之InstanceStore:

这个类为WF提供的，用于进行持久化的操作，WF中已经包含了一个实现它的SqlWorkflowInstanceStore，用于保存到数据库中，当然本文还会介绍另外一种是使用XML的方式。此类保存到的数据库有些要求，使用的sql脚本微软已经提供，下文将会一一说明。

持久化分析之PersistenceParticipant：

PersistenceParticipant class or the PersistenceIOParticipant class (derived class of the PersistenceParticipant class), implements abstract methods, and then add an instance of the class as a workflow instance extension.">持久性参与者派生自 PersistenceParticipant 类或 PersistenceIOParticipant 类（PersistenceParticipant 类的派生类），实现抽象方法，然后添加类的实例作为工作流实例扩展。WorkflowApplication and WorkflowServiceHost look for such extensions when persisting an instance and invoke appropriate methods at appropriate times."> WorkflowApplication 和 WorkflowServiceHost 在保留实例时查找此类扩展，并在适当的时间调用适当的方法。根据MSDN的解释可以看出来此类是我们自定义持久化需要继承的类，那么在进行XML方式持久化的时候我们就会用到，Sql方式的时候无需自定义具体信息下一篇介绍。

WorkflowApplication and WorkflowServiceHost look for such extensions when persisting an instance and invoke appropriate methods at appropriate times.">

到此，我们的关键技术分析已经完成，一个BookMark类和一个InstanceStore类以及自定义需要的PersistenceParticipant三个类来共同完成我们的持久化。

持久化实现之业务分析：

第一步，我们先来分析一个流程的，假设有若干个评委来投票，需要所有的评委投票完成之后流程才能进入到下一步，这里的投票可以认为是评委需要登录到系统进行投票，并且投票的先后顺序以及时间都不确定，
根据分析设计工作流如下：

一个包含了DoWhile和Foreach的流程，DoWhile控制是否进行多次审批，ForEach用于遍历所有的评委，同时创建多个书签，注意此处使用的Parallel循环，让创建书签的过程为同步，如果使用ForEach则只会创建一个书签；

在If中创建书签使流程同步，此时就是需要持久化的过程，同时每激活一个或多个也要再次持久化，直到流程结束。

持久化实现之BookMark类：

此类代码较简单直接贴出来

 <span>public</span> <span>sealed</span> <span>class</span> WaitForVote<t>: NativeActivity<t><span>
    {
        </span><span>public</span> InArgumentstring> UserId { <span>get</span>; <span>set</span><span>; }

        </span><span>public</span> InOutArgument<requestforexpert> InOutRequestForExpert { <span>get</span>; <span>set</span><span>; }

        </span><span>protected</span> <span>override</span> <span>void</span><span> Execute(NativeActivityContext context)
        {
            </span><span>string</span> name =  <span>this</span><span>.UserId.Get(context).ToString();
            context.CreateBookmark(name, </span><span>new</span><span> BookmarkCallback(OnReadComplete));
        }

        </span><span>void</span> OnReadComplete(NativeActivityContext context, Bookmark bookmark, <span>object</span><span> state)
        {  
            </span><span>string</span>[] input = (<span>string</span><span>[])state;
            context.SetValue(</span><span>this</span><span>.Result, input);
            RequestForExpert requestForExpert </span>=<span> context.GetValue(InOutRequestForExpert);
            requestForExpert.ExpertList.Find((ExpertInfo expert) </span>=> { <span>return</span> expert.UserId == input[<span>0</span>]; }).IsConfirmed=<span>true</span><span>;
            context.SetValue(InOutRequestForExpert ,requestForExpert);
        }

        </span><span>protected</span> <span>override</span> <span>bool</span><span> CanInduceIdle
        {
            </span><span>get</span><span>
            {
                </span><span>return</span> <span>true</span><span>;
            }
        }</span></requestforexpert></t></t>

此类继承了NativeActivity，有关该类的具体说明可以查看MSDN。
该类主要为以下几个部分：
1.一个InArguement的参数，用于接收书签的名称
2.重写Execute方法，用于创建书签，通过传递的参数，作为书签的名称，同时指定激活回调方法
3.给BookMark指定激活回调方法，可以在激活书签的时候传递值，在此方法中可以处理值，并传递到页面去(InOutRequestForExpert就是页面传递到书签的值，在此方法中进行修改再返回到页面去)
4.设置属性CanInduceIdle属性为true，这样才可以进行持久化。

持久化实现之宿主类：

 <span>interface</span><span> IExpertHost
    {
        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 创建并运行WorkFlow实例
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="rfe"></span>
        <span>///</span> <span><returns></returns></span>
<span>        WorkflowApplication CreateAndRun(RequestForExpert rfe);
        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 加载WorkFlow实例
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span>
        <span>///</span> <span><returns></returns></span>
<span>        WorkflowApplication LoadInstance(Guid instanceId);

        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 当前项目是否可以投票
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span><span>实例编号</span><span></span>
        <span>///</span> <span><param name="userId"></span><span>评委编号</span><span></span>
        <span>///</span> <span><returns></returns></span>
        <span>bool</span> CanVoteToInstance(Guid instanceId, <span>string</span><span> userId);
　　　　 </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 投票
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span><span>WorkFlow实例编号</span><span></span>
        <span>///</span> <span><param name="projectId"></span><span>项目编号</span><span></span>
        <span>///</span> <span><param name="userId"></span><span>用户编号</span><span></span>
        <span>///</span> <span><param name="selUserId"></span><span>推荐评委编号</span><span></span>
        <span>void</span> Vote(Guid instanceId, <span>string</span> userId, <span>string</span><span> selUserId);
    }</span>

首先来看CreateAndRun的实现写法：
这里定义了一个枚举类型，来表明持久化使用Sql方式还是XML的方式

 <span>public</span> <span>enum</span><span> StoreType
    {
        Sql, Xml
    }</span>

  <span>public</span><span> WorkflowApplication CreateAndRun(RequestForExpert rfe)
        {
           
            IDictionary</span>string, <span>object</span>> inputs = <span>new</span> Dictionarystring, <span>object</span>><span>();
            inputs.Add(</span><span>"</span><span>InRequestForExpert</span><span>"</span><span>, rfe);
            </span><span>//</span><span> 实例化工作流对象</span>
            Activity wf = <span>new</span><span> ExpertWorkFlow();
            WorkflowApplication instance </span>= <span>new</span><span> WorkflowApplication(wf, inputs);
            instance.PersistableIdle </span>+=<span> OnIdleAndPersistable;
            instance.Completed </span>+=<span> OnWorkflowCompleted;
            instance.Idle </span>+=<span> OnIdle;
            </span><span>//</span><span><strong>持久</strong>化设置</span>
<span>            GetSqlInstanceStore(instance, StoreType.Sql);
            instance.Run();
            </span><span>return</span><span> instance;
        }

 　　　　</span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 设置<strong>持久</strong>化<strong>方式</strong>
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instance"></span>
        <span>private</span> <span>void</span><span> GetSqlInstanceStore(WorkflowApplication instance, StoreType storeType)
        {
            </span><span>switch</span><span> (storeType)
            {
                </span><span>case</span><span> StoreType.Sql:
                    SqlWorkflowInstanceStore sqlInstanceStore </span>= <span>new</span><span> SqlWorkflowInstanceStore(connectionString);
                    InstanceView view </span>= sqlInstanceStore.Execute(sqlInstanceStore.CreateInstanceHandle(), <span>new</span> CreateWorkflowOwnerCommand(), TimeSpan.FromSeconds(<span>30</span><span>));
                    </span><span>//</span><span>设置默认实例的所有者</span>
                    sqlInstanceStore.DefaultInstanceOwner =<span> view.InstanceOwner;
                    instance.InstanceStore </span>=<span> sqlInstanceStore;
                    </span><span>break</span><span>;
                </span><span>case</span><span> StoreType.Xml:
                    XmlWorkflowInstanceStore store </span>= <span>new</span><span> XmlWorkflowInstanceStore(instance.Id);
                    instance.InstanceStore </span>=<span> store;
                    </span><span>break</span><span>;
                </span><span>default</span><span>:
                    </span><span>break</span><span>;
            }
        }</span>

    <span>//</span><span> executed when instance goes idle</span>
        <span>public</span> <span>void</span><span> OnIdle(WorkflowApplicationIdleEventArgs e)
        {
        }

        </span><span>public</span><span> PersistableIdleAction OnIdleAndPersistable(WorkflowApplicationIdleEventArgs e)
        {
            </span><span>return</span><span> PersistableIdleAction.Unload;
        }

        </span><span>//</span><span> executed when instance is persisted</span>
        <span>public</span> <span>void</span><span> OnWorkflowCompleted(WorkflowApplicationCompletedEventArgs e)
        {

        }</span>

在上述方法中创建了一个WorkFlowApplication工作流应用对象，同时绑定PersistableIdle ,此函数说明使用怎样的持久化方式，此处使用的为Unload即卸载并持久化，这样在Load的时候不会出现实例被锁定的错误。

设置持久化方式，此处使用的是Sql方式的存储，在存储的方法中主要是指定了要保存的数据库，此数据库可不是一般的数据库，需要特性的Sql脚本，别急此脚本已在你的电脑中，打开目录 "C:\Windows\Microsoft.NET\Framework\v4.0.30319\SQL\en"

创建一个数据库名字为WorkflowInstanceStore(可自定义),先执行第二个文件，再执行第一个文件。

下面再来看看其他的方法：

<span>　　　　　///</span> <span><summary></summary></span>
        <span>///</span><span> 加载工作流
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span>
        <span>///</span> <span><param name="userId"></span>
        <span>///</span> <span><returns></returns></span>
        <span>public</span><span> WorkflowApplication LoadInstance(Guid instanceId)
        {
            WorkflowApplication instance </span>= <span>new</span> WorkflowApplication(<span>new</span><span> ExpertWorkFlow());
            instance.Completed </span>+=<span> OnWorkflowCompleted;
            instance.PersistableIdle </span>+=<span> OnIdleAndPersistable;
            instance.Idle </span>+=<span> OnIdle;
            </span><span>//</span><span><strong>持久</strong>化设置</span>
<span>            GetSqlInstanceStore(instance, StoreType.Sql);
            instance.Load(instanceId);
            </span><span>return</span><span> instance;
        }

　　　　　</span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 当前评委是否可以投票,判断其有没有投票
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span>
        <span>///</span> <span><param name="userId"></span>
        <span>///</span> <span><returns></returns></span>
        <span>public</span> <span>bool</span> CanVoteToInstance(Guid instanceId, <span>string</span><span> userId)
        {
            WorkflowApplication instance </span>=<span> LoadInstance(instanceId);
            </span><span>//</span><span>除非存在当前的书签，则说明没有投票</span>
            <span>foreach</span> (BookmarkInfo item <span>in</span><span> instance.GetBookmarks())
            {
                </span><span>if</span><span> (item.BookmarkName.Equals(userId))
                {
                    </span><span>return</span> <span>true</span><span>;
                }
            }
            </span><span>return</span> <span>false</span><span>;
        }

　　　　  </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 投票
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span><span>工作流实例Id</span><span></span>
        <span>///</span> <span><param name="userId"></span><span>用户Id</span><span></span>
        <span>///</span> <span><param name="selUserId"></span><span>推荐的用户Id</span><span></span>
        <span>public</span> <span>void</span> Vote(Guid instanceId, <span>string</span> userId, <span>string</span><span> selUserId)
        {

            WorkflowApplication instance </span>=<span> LoadInstance(instanceId);
            </span><span>//</span><span>除非存在当前的书签，则说明没有投票</span>
            <span>foreach</span> (BookmarkInfo item <span>in</span><span> instance.GetBookmarks())
            {
                </span><span>if</span><span> (item.BookmarkName.Equals(userId))
                {
                    instance.ResumeBookmark(userId, </span><span>new</span> <span>string</span><span>[] { userId, selUserId });
                }
            }
            instance.Unload();
        }</span>

一个用于加载工作流的方法，一个判断是否可以投票的方法(如果对应当前评委的书签还存在，则可以投票，注意这里书签的名称都为评委的Id，不过这个不重要，大家可以在自己的程序中自己决定使用什么，只是在激活

书签的时候需要使用一样的值，这样才可以找到书签)，一个就是投票的方法(主要用于激活书签)。

持久化实现之WCF以及Web客户端：
到这里WorkFlow的工作已经完成了看看怎么调用，在这里我是通过WCF把WorkFlow和Web端结合起来，所以又添加了一个WCF的项目WFWCF(源码中都包含)，添加WCF IExpertWCF

<span>  [ServiceContract]
    </span><span>public</span> <span>interface</span><span> IExpertWCF
    {
        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 创建工作流
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="rfe"></span>
<span>        [OperationContract]
        </span><span>void</span><span> CreateWorkFlow(RequestForExpert rfe);

        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span>投票
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span>
        <span>///</span> <span><param name="userId"></span>
        <span>///</span> <span><param name="selUserId"></span>
<span>        
        [OperationContract]
        </span><span>void</span> Vote(Guid instanceId,<span>string</span> userId,<span>string</span><span> selUserId);
    }

  </span><span>public</span> <span>class</span><span> ExpertWCF : IExpertWCF
    {

        </span><span>private</span> <span>string</span> ConnectionString = ConfigurationManager.ConnectionStrings[<span>"</span><span>ApplicationServices</span><span>"</span><span>].ConnectionString;

        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 创建workFlow
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="rfe"></span>
        <span>public</span> <span>void</span><span> CreateWorkFlow(RequestForExpert rfe)
        {
            ExpertProcessHost host </span>= <span>new</span><span> ExpertProcessHost();</span>
<span>            host.CreateAndRun(rfe);
        }


        </span><span>///</span> <span><summary></summary></span>
        <span>///</span><span> 投票
        </span><span>///</span> <span></span>
        <span>///</span> <span><param name="instanceId"></span>
        <span>///</span> <span><param name="userId"></span>
        <span>///</span> <span><param name="selUserId"></span>
        <span>public</span> <span>void</span> Vote(Guid instanceId, <span>string</span> userId, <span>string</span><span> selUserId)
        {</span>
            ExpertProcessHost host = <span>new</span><span> ExpertProcessHost();
            host.Vote(instanceId, projectId, userId, selUserId);
        }
}</span>

方法都很简单，一个创建工作流的方法，一个投票的方法，实例化ExpertProcessHost 对象直接调用即可。
最后来看页面设计

首页，用于创建工作流

点击按钮会在数据库声称如下的一条数据(数据值不同),而Id列就是在投票页面要使用的InstanceId。

投票页面，输入InstanceId，点击投票即可投票，激活对应用户的书签(此处的用户为写固定，可以自行修改，同时InstanceId可以调试获得，或者从数据库的InstancesTable表中获得)，当激活所有的书签之后流程将结束，同时数据库则会自动删除此条数据。至此，Sql方式的持久化就结束了，下一篇开始将介绍XML方式的持久化操作。

源码在下一篇中。

陳述

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

您什麼時候應該使用複合索引與多個單列索引？Apr 11, 2025 am 12:06 AM

在數據庫優化中，應根據查詢需求選擇索引策略：1.當查詢涉及多個列且條件順序固定時，使用複合索引；2.當查詢涉及多個列但條件順序不固定時，使用多個單列索引。複合索引適用於優化多列查詢，單列索引則適合單列查詢。

如何識別和優化MySQL中的慢速查詢？（慢查詢日誌，performance_schema）Apr 10, 2025 am 09:36 AM

要優化MySQL慢查詢，需使用slowquerylog和performance_schema：1.啟用slowquerylog並設置閾值，記錄慢查詢；2.利用performance_schema分析查詢執行細節，找出性能瓶頸並優化。

MySQL和SQL：開發人員的基本技能Apr 10, 2025 am 09:30 AM

MySQL和SQL是開發者必備技能。 1.MySQL是開源的關係型數據庫管理系統，SQL是用於管理和操作數據庫的標準語言。 2.MySQL通過高效的數據存儲和檢索功能支持多種存儲引擎，SQL通過簡單語句完成複雜數據操作。 3.使用示例包括基本查詢和高級查詢，如按條件過濾和排序。 4.常見錯誤包括語法錯誤和性能問題，可通過檢查SQL語句和使用EXPLAIN命令優化。 5.性能優化技巧包括使用索引、避免全表掃描、優化JOIN操作和提升代碼可讀性。

描述MySQL異步主奴隸複製過程。Apr 10, 2025 am 09:30 AM

MySQL異步主從復制通過binlog實現數據同步，提升讀性能和高可用性。 1)主服務器記錄變更到binlog；2)從服務器通過I/O線程讀取binlog；3)從服務器的SQL線程應用binlog同步數據。

mysql：簡單的概念，用於輕鬆學習Apr 10, 2025 am 09:29 AM

MySQL是一個開源的關係型數據庫管理系統。 1）創建數據庫和表：使用CREATEDATABASE和CREATETABLE命令。 2）基本操作：INSERT、UPDATE、DELETE和SELECT。 3）高級操作：JOIN、子查詢和事務處理。 4）調試技巧：檢查語法、數據類型和權限。 5）優化建議：使用索引、避免SELECT*和使用事務。

MySQL：數據庫的用戶友好介紹Apr 10, 2025 am 09:27 AM

MySQL的安裝和基本操作包括：1.下載並安裝MySQL，設置根用戶密碼；2.使用SQL命令創建數據庫和表，如CREATEDATABASE和CREATETABLE；3.執行CRUD操作，使用INSERT,SELECT,UPDATE,DELETE命令；4.創建索引和存儲過程以優化性能和實現複雜邏輯。通過這些步驟，你可以從零開始構建和管理MySQL數據庫。

InnoDB緩衝池如何工作，為什麼對性能至關重要？Apr 09, 2025 am 12:12 AM

InnoDBBufferPool通過將數據和索引頁加載到內存中來提升MySQL數據庫的性能。 1)數據頁加載到BufferPool中，減少磁盤I/O。 2)臟頁被標記並定期刷新到磁盤。 3)LRU算法管理數據頁淘汰。 4)預讀機制提前加載可能需要的數據頁。

MySQL：初學者的數據管理易用性Apr 09, 2025 am 12:07 AM

MySQL適合初學者使用，因為它安裝簡單、功能強大且易於管理數據。 1.安裝和配置簡單，適用於多種操作系統。 2.支持基本操作如創建數據庫和表、插入、查詢、更新和刪除數據。 3.提供高級功能如JOIN操作和子查詢。 4.可以通過索引、查詢優化和分錶分區來提升性能。 5.支持備份、恢復和安全措施，確保數據的安全和一致性。

See all articles