4.WokflowCore之Saga事务

步步为营DotNet

发布于 2026-06-16 21:47:28

10

Saga事务

Saga可以封装一系列步骤，并可以为每个步骤进行补偿操作。

//Task2会抛出异常，则会触发undotask2和undotask1
builder
    .StartWith(context => Console.WriteLine("Begin"))
    .Saga(saga => saga
        .StartWith<Task1>()
            .CompensateWith<UndoTask1>()//补偿操作
        .Then<Task2>()
            .CompensateWith<UndoTask2>()
        .Then<Task3>()
            .CompensateWith<UndoTask3>()
    )
    .Then(context => Console.WriteLine("End"));

saga事务的重试

//该案例会5s重试一次
builder
    .StartWith(context => Console.WriteLine("Begin"))
    .Saga(saga => saga
        .StartWith<Task1>()
            .CompensateWith<UndoTask1>()
        .Then<Task2>()
            .CompensateWith<UndoTask2>()
        .Then<Task3>()
            .CompensateWith<UndoTask3>()
    )
    .OnError(Models.WorkflowErrorHandling.Retry, TimeSpan.FromSeconds(5))
    .Then(context => Console.WriteLine("End"));

补偿整个saga事务

builder
    .StartWith(context => Console.WriteLine("Begin"))
        .Saga(saga => saga
            .StartWith<Task1>()
            .Then<Task2>()
            .Then<Task3>()
    )
        .CompensateWith<UndoEverything>()//补充整个saga事务
    .Then(context => Console.WriteLine("End"));

给补偿步骤传参

builder
    .StartWith<SayHello>()
        .CompensateWith<PrintMessage>(compensate => 
        {
            compensate.Input(step => step.Message, data => "undoing...");
        })

ut(step => step.Message, data => “undoing…”); })

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2025-09-04，如有侵权请联系 cloudcommunity@tencent.com 删除

事务