微服務中的 Saga 模式

開發者們大家好，

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

什麼是傳奇模式？

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

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

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

為什麼要使用 Saga 模式？

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

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

人力資源用例：員工入職

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

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

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

在 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.");
    }
}

Saga模式的優點

1. 彈性：能夠從長時間運行的進程中的故障中恢復。
2. 可擴充性：在維持交易完整性的同時解耦服務。
3. 靈活性：透過客製化補償邏輯支援多樣化的工作流程。

最後的想法

Saga 模式是維護微服務等分散式系統中資料一致性的關鍵設計模式。在我們的人力資源範例中，它確保了整個入職流程成功完成或優雅地回滾，從而保持系統完整性。

透過利用 Saga 這樣的模式，我們可以設計強大的系統來處理分散式事務的複雜性。

繼續編碼

以上是微服務中的 Saga 模式的詳細內容。更多資訊請關注PHP中文網其他相關文章！