在当今快速迭代的业务环境中，将复杂的业务流程自动化、可视化并确保其可靠执行至关重要，工作流引擎正是为此而生，它抽象了业务逻辑的执行路径，管理状态流转，并处理异常，对于强大的 .NET 平台开发者，掌握如何集成和开发工作流应用是提升系统灵活性和可维护性的关键技能，本文将深入探讨在 .NET 生态中构建工作流应用的核心概念、实践方案与专业建议。
为什么 .NET 开发者需要工作流？
想象一下：员工请假审批、订单处理、内容发布审核、客户开户流程… 这些业务场景通常涉及多个步骤、不同角色参与、条件分支和异步操作,硬编码这些逻辑会导致：
- 代码臃肿且脆弱：业务规则变化需要深入修改核心代码,风险高。
- 可维护性差：流程逻辑深埋代码中,新人难以理解和修改。
- 缺乏可视化：管理者无法直观看到流程状态和瓶颈。
- 审计困难：追踪完整的流程执行历史记录复杂。
工作流引擎通过将流程定义（描述步骤、规则、流转）与执行引擎分离，完美解决了这些问题。.NET 开发者可以利用成熟的工作流框架,快速构建响应业务变化的灵活应用。
.NET 工作流的核心选择：WF 与 Elsa Workflow
微软提供了 Windows Workflow Foundation (WF)，这是一个历史悠久且功能强大的工作流框架，内置于 .NET Framework 及后续的 .NET Core/.NET 5+ 中（作为 System.Activities 包），WF 支持两种主要范式：
- 顺序工作流 (Sequential Workflow)：步骤按预定顺序执行。
- 状态机工作流 (State Machine Workflow)：流程在不同状态间转换,响应事件触发。
WF 的优势在于深度集成、强大的持久化和跟踪能力，其学习曲线相对陡峭,配置和扩展有时略显繁琐。
近年来，Elsa Workflow 作为开源新星异军突起，迅速成为 .NET 工作流领域的热门选择，它专为现代 .NET（.NET Core 3.1+, .NET 5/6/7/8）设计,具有显著优势：
- 开发者友好：提供直观的 Fluent API、可视化设计器（Web 或 VS Code 扩展）和 REST API。
- 高度可扩展：活动（Activity）模型易于自定义，支持各种触发器（HTTP, Timer, Message等）。
- 轻量级与灵活：可按需选择持久化存储（Entity Framework Core, MongoDB, YesSQL等）和消息总线。
- 强大的可视化：内置工作流仪表板和设计器，方便设计、监控和管理流程。
- 活跃的社区：持续更新,社区支持良好。
对于大多数现代 .NET 应用开发，尤其是 Web 应用（ASP.NET Core），Elsa Workflow 通常是更推荐、更高效的起点。
实战演练：使用 Elsa Workflow 构建审批工作流
让我们通过一个具体的例子员工请假审批流程来演示如何在 ASP.NET Core 应用中集成 Elsa Workflow。
场景描述：
- 员工提交请假申请（包含天数、原因）。
- 申请自动发送给员工的直属经理审批。
- 经理可以批准或拒绝。
- 如果批准且天数 > 3天,需要部门总监二次审批。
- 最终结果（批准/拒绝）通知员工和HR系统。
步骤 1：创建项目并安装 Elsa
- 创建一个新的 ASP.NET Core Web API 或 MVC 项目。
- 使用 NuGet 安装核心包：
Install-Package Elsa Install-Package Elsa.EntityFrameworkCore.Sqlite # 使用 SQLite 持久化（可选其他存储） Install-Package Elsa.Http # 用于 HTTP 端点活动 Install-Package Elsa.Designer.Components.Web # 包含可视化设计器（可选，但推荐） Install-Package Elsa.Workflows.Management # 工作流管理 API Install-Package Elsa.Workflows.Api # 工作流 API 端点
步骤 2：配置 Elsa 服务 (Program.cs)
using Elsa.EntityFrameworkCore.Modules.Management;
using Elsa.EntityFrameworkCore.Modules.Runtime;
using Elsa.Extensions;
using Elsa.Http.Extensions;
var builder = WebApplication.CreateBuilder(args);
// 添加 Elsa 核心服务
builder.Services.AddElsa(elsa =>
{
// 配置持久化（使用 SQLite）
elsa.UseEntityFrameworkCore(ef => ef.UseSqlite());
// 添加 HTTP 活动模块
elsa.UseHttp();
// 添加工作流管理模块
elsa.UseWorkflowManagement();
// 添加工作流运行时模块
elsa.UseWorkflows();
// 配置其他活动（如 Email, Scripting 等，按需安装）
// elsa.UseEmail(...); elsa.UseJavaScriptActivities();
});
// 如果使用设计器（强烈推荐）
builder.Services.AddRazorPages();
builder.Services.AddServerSideBlazor();
var app = builder.Build();
// 配置中间件
app.UseRouting();
app.UseAuthorization();
// 映射 Elsa HTTP 端点 (用于触发工作流、管理API等)
app.MapControllers();
app.MapFallbackToPage("/_Host"); // 为 Blazor 设计器使用
// 启用 Elsa HTTP 端点中间件
app.UseWorkflowsApi();
app.UseWorkflows(); // 启用 HTTP 活动端点
app.Run();
步骤 3：设计请假审批工作流 (使用设计器或代码)
-
使用设计器 (推荐)： 启动应用，通常访问
/elsa/home或/elsa/designer，Elsa 提供了一个直观的拖拽界面来设计工作流。 -
使用 Fluent API (代码方式)：
using Elsa.Workflows; using Elsa.Workflows.Activities; using Elsa.Workflows.Contracts; using Elsa.Http; using Elsa.Http.Models; public class LeaveApprovalWorkflow : WorkflowBase { protected override void Build(IWorkflowBuilder builder) { // 1. 定义输入变量：请假天数、原因、申请人ID等 var leaveRequest = builder.WithVariable<LeaveRequest>(); // 自定义 LeaveRequest 类 // 2. 工作流开始：接收员工提交的申请 (HTTP 端点触发) var start = builder.StartWith<HttpEndpoint>(setup: activity => { activity.Path = new("/leave-requests"); activity.ParsedContent = new(leaveRequest); // 绑定请求体到变量 activity.SupportedMethods = new(new[] { HttpMethod.Post.Method }); }); // 3. 设置审批人（通常根据申请人查找其经理ID，这里简化） // 实际应用中，这里可能调用服务或查询数据库 var setApprover = start.Then<SetVariable>(setup: activity => { activity.Variable = new(Output<object>("ManagerId")); activity.Value = new("manager-id-placeholder"); // 替换为实际逻辑获取经理ID }); // 4. 发送审批请求给经理 (HTTP 调用、邮件、内部通知等) // 示例：使用 SendHttpRequest 活动调用内部审批API（通知经理） var notifyManager = setApprover.Then<SendHttpRequest>(setup: activity => { activity.Url = new("https://internal-api/notify/approval-needed"); activity.Method = new(HttpMethod.Post.Method); activity.Content = new(new { ApproverId = context.GetVariable<string>("ManagerId"), RequestId = context.WorkflowInstanceId, Details = leaveRequest.Get(context) }); }); // 5. 等待经理审批结果 (Bookmark/Event 触发) var waitForManagerDecision = notifyManager.Then<Event>(setup: activity => { activity.Name = "ManagerDecision"; activity.Kind = "ApproveOrReject"; }); // 6. 处理经理决策 var managerDecision = waitForManagerDecision.When("Approved").Then<SetVariable>(setup: activity => { activity.Variable = new(Output<string>("Decision")); activity.Value = new("ApprovedByManager"); }).Branch("Approved"); managerDecision = waitForManagerDecision.When("Rejected").Then<SetVariable>(setup: activity => { activity.Variable = new(Output<string>("Decision")); activity.Value = new("RejectedByManager"); }).Branch("Rejected"); // 7. 检查是否需要总监审批 (条件分支) var checkDirectorApproval = managerDecision.Branch("Approved").Then<If>(setup: activity => { activity.Condition = new(context => leaveRequest.Get(context).Days > 3); }); // 8a. 需要总监审批 (类似步骤4-6，等待总监决策) var directorApprovalBranch = checkDirectorApproval.When(true).Then<SendHttpRequest>(setup: activity => { // 通知总监... }).Then<Event>(setup: activity => activity.Name = "DirectorDecision") .When("Approved").Then<SetVariable>(setup: activity => activity.Value = new("ApprovedByDirector")) .When("Rejected").Then<SetVariable>(setup: activity => activity.Value = new("RejectedByDirector")) .Branch("DirectorApproval"); // 8b. 不需要总监审批，直接使用经理批准结果 var noDirectorNeeded = checkDirectorApproval.When(false).Then<SetVariable>(setup: activity => { activity.Variable = new(Output<string>("FinalDecision")); activity.Value = new(context => context.GetVariable<string>("Decision")); // 沿用经理决定 }).Branch("NoDirector"); // 9. 合并路径 (无论是否经过总监审批，最终都有结果) var finalize = directorApprovalBranch.Join().With(noDirectorNeeded.Join()).Then(); // 10. 发送最终通知 (给员工和HR系统) finalize.Then<SendHttpRequest>(setup: activity => { // 通知员工申请结果... }).Then<SendHttpRequest>(setup: activity => { // 通知HR系统结果... }); // 11. 工作流结束 finalize.Then<Finish>(); } } // 自定义请假请求类 public class LeaveRequest { public string EmployeeId { get; set; } public int Days { get; set; } public string Reason { get; set; } // ... 其他属性 }注意：此代码示例是概念性的，简化了错误处理、日志记录、实际的服务调用（查找审批人）和更健壮的状态管理,实际开发中应使用设计器或结合更细致的代码实现。
步骤 4：注册与发布工作流
- 在
Program.cs的AddElsa配置中注册你的工作流定义：elsa.AddWorkflow<LeaveApprovalWorkflow>();
- 启动应用，Elsa 会自动将工作流定义持久化到数据库。
步骤 5：触发工作流
- 员工通过调用
POST /leave-requests(如步骤3中定义的HttpEndpoint) 提交请假申请，请求体应包含LeaveRequest数据。 - Elsa 运行时引擎会自动创建该申请对应的工作流实例并开始执行。
步骤 6：处理审批事件
- 经理或总监的审批系统（可能是另一个应用或界面）在做出决定后，需要调用 Elsa 的 API 来触发相应的事件 (
ManagerDecision或DirectorDecision)，携带Approved或Rejected结果以及对应的工作流实例ID (workflowInstanceId)。 - 触发事件的 API 通常是
POST /v1/events/{eventName}/trigger(具体路径取决于你的API配置)。
步骤 7：监控与管理
- 使用 Elsa Dashboard (
/elsa/home或/elsa/dashboard) 查看运行中的工作流实例、历史记录、日志,管理工作流定义版本等。
专业见解与最佳实践
- 领域模型分离： 工作流应专注于流程控制逻辑（流转、等待、分支），将核心业务数据（如请假单、订单）存储在独立的领域实体中，工作流只持有引用ID或关键状态,避免将整个业务对象序列化到工作流变量中。
- 活动（Activity）设计： 将重复或复杂的业务操作封装成自定义活动。
FindManagerActivity、SendApprovalNotificationActivity、UpdateLeaveRequestStatusActivity,这提高了复用性和可测试性。 - 错误处理与补偿： 工作流步骤可能失败（网络超时、服务不可用），利用
TryCatch活动进行局部错误捕获和恢复，对于需要撤销操作的场景（如审批通过后支付失败），考虑实现补偿逻辑（Saga模式）。 - 版本控制： 业务规则变化意味着工作流定义需要更新，Elsa 支持工作流版本管理，发布新版本时，通常让新实例使用新版本，旧实例继续运行其原有版本直至完成，或提供迁移策略,避免直接修改正在运行的实例的定义。
- 性能与伸缩： 对于高吞吐量场景：
- 选择合适的持久化存储（SQL Server, PostgreSQL, MongoDB）。
- 利用消息队列（如 RabbitMQ, Azure Service Bus, MassTransit/Saga）解耦长时间运行或资源密集型活动。
- 考虑分布式执行，Elsa 支持多节点运行。
- 避免过度设计： 并非所有流程都需要完整的工作流引擎，简单的、线性的、极少变化的流程，用代码状态机或服务编排可能更轻量,评估引入工作流引擎的复杂性与收益。
- 利用可视化： 设计器不仅是设计工具，更是沟通桥梁，业务分析师或产品经理可以通过它理解流程，促进团队协作,确保流程图的清晰易懂。
- 测试策略： 单元测试自定义活动，使用 Elsa 提供的测试框架对工作流定义进行集成测试,模拟触发事件和检查最终状态及输出。
拥抱流程自动化的力量
将工作流引擎引入 .NET 应用开发，特别是采用像 Elsa Workflow 这样现代化、易用的框架，能显著提升应对复杂业务流程的能力，它解耦了业务逻辑与控制流，提供了可视化设计和管理界面，增强了系统的灵活性和可维护性，通过遵循领域驱动设计原则、精心设计活动、实施健壮的错误处理和版本策略，开发者可以构建出既强大又易于演进的业务流程自动化系统，掌握工作流开发，是 .NET 开发者迈向构建更智能、更自适应企业级应用的重要一步。
您的工作流实践如何？
- 您在 .NET 项目中尝试过哪些工作流框架 (WF, Elsa, 或其他)？体验如何？
- 在实现复杂审批流或业务自动化时,您遇到的最大挑战是什么？
- 对于将遗留系统中的硬编码流程迁移到工作流引擎,您有什么经验或建议分享？
- 您认为可视化设计器在团队协作中扮演了怎样的角色？
欢迎在评论区分享您的见解、遇到的难题或成功案例！让我们共同探讨 .NET 工作流开发的无限可能。
首发原创文章，作者：王坚，如若转载，请注明出处：https://idctop.com/article/14104.html
