微服務中的 Saga 模式-C++-PHP中文網

The Saga Pattern in Microservices

開發者們大家好，

微服務徹底改變了我們建立可擴展且靈活的系統的方式。然而，它們也帶來了複雜性，特別是在管理跨服務的分散式事務時。這就是 Saga 模式 的用武之地——一種強大的設計模式，用於處理微服務中長時間運行的事務。在這篇文章中，我們將探討 Saga 模式是什麼、它是如何運作的，並透過 C# 中的人力資源 (HR) 用例來了解它的實際應用。

什麼是傳奇模式？

Saga 模式將大型分散式事務分解為一系列較小的步驟，每個步驟由特定的微服務處理。這些步驟按順序執行，並為每個步驟定義補償操作，以便在出現問題時回滾。

實作 Saga 模式有兩種主要方法：

編排：每個服務都會監聽事件並對事件做出反應，自行編排。
編排：中央協調器服務管理事務流程。

為什麼要使用 Saga 模式？

Saga 模式對於微服務架構特別有用，其中：

交易涉及多種服務（例如人力資源、薪資、招聘）。
可擴展性和解耦至關重要。
優雅地處理部分失敗至關重要。

人力資源用例：員工入職

想像一個人力資源 (HR) 系統，其中新員工入職涉及多個微服務：

使用者服務：建立員工帳戶。
薪資服務：設定薪資詳細資料。
福利服務：為員工登記福利。

這些服務必須協同工作才能完成入職流程。如果薪資服務失敗，系統應撤銷帳戶建立和福利註冊。

在 C 中實作 Saga 模式

讓我們透過編排為員工入職流程實施Saga模式。

第 1 步：定義 Saga 協調器

Saga 協調器管理事務流程。這是 C# 的基本實作：

public class SagaCoordinator
{
    private readonly IUserService _userService;
    private readonly IPayrollService _payrollService;
    private readonly IBenefitsService _benefitsService;

    public SagaCoordinator(IUserService userService, IPayrollService payrollService, IBenefitsService benefitsService)
    {
        _userService = userService;
        _payrollService = payrollService;
        _benefitsService = benefitsService;
    }

    public async Task ExecuteOnboardingSagaAsync(Employee employee)
    {
        try
        {
            Console.WriteLine("Starting onboarding saga...");

            // Step 1: Create user account
            await _userService.CreateUserAsync(employee);

            // Step 2: Set up payroll
            await _payrollService.SetupPayrollAsync(employee);

            // Step 3: Register benefits
            await _benefitsService.RegisterBenefitsAsync(employee);

            Console.WriteLine("Onboarding completed successfully!");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Error during onboarding: {ex.Message}");
            await CompensateAsync(employee);
        }
    }

    private async Task CompensateAsync(Employee employee)
    {
        Console.WriteLine("Compensating...");
        await _benefitsService.RollbackBenefitsAsync(employee);
        await _payrollService.RollbackPayrollAsync(employee);
        await _userService.DeleteUserAsync(employee);
        Console.WriteLine("Compensation complete.");
    }
}

登入後複製

第 2 步：定義服務

每個服務都實現其特定的邏輯和補償操作。

public interface IUserService
{
    Task CreateUserAsync(Employee employee);
    Task DeleteUserAsync(Employee employee);
}

public interface IPayrollService
{
    Task SetupPayrollAsync(Employee employee);
    Task RollbackPayrollAsync(Employee employee);
}

public interface IBenefitsService
{
    Task RegisterBenefitsAsync(Employee employee);
    Task RollbackBenefitsAsync(Employee employee);
}

登入後複製

這些介面的實作將與資料庫或其他 API 互動。

第 3 步：執行 Saga

以下是如何使用 Saga 協調器：

public class SagaCoordinator
{
    private readonly IUserService _userService;
    private readonly IPayrollService _payrollService;
    private readonly IBenefitsService _benefitsService;

    public SagaCoordinator(IUserService userService, IPayrollService payrollService, IBenefitsService benefitsService)
    {
        _userService = userService;
        _payrollService = payrollService;
        _benefitsService = benefitsService;
    }

    public async Task ExecuteOnboardingSagaAsync(Employee employee)
    {
        try
        {
            Console.WriteLine("Starting onboarding saga...");

            // Step 1: Create user account
            await _userService.CreateUserAsync(employee);

            // Step 2: Set up payroll
            await _payrollService.SetupPayrollAsync(employee);

            // Step 3: Register benefits
            await _benefitsService.RegisterBenefitsAsync(employee);

            Console.WriteLine("Onboarding completed successfully!");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Error during onboarding: {ex.Message}");
            await CompensateAsync(employee);
        }
    }

    private async Task CompensateAsync(Employee employee)
    {
        Console.WriteLine("Compensating...");
        await _benefitsService.RollbackBenefitsAsync(employee);
        await _payrollService.RollbackPayrollAsync(employee);
        await _userService.DeleteUserAsync(employee);
        Console.WriteLine("Compensation complete.");
    }
}

登入後複製