Corak Saga dalam Microservices

Hai dev,

Perkhidmatan mikro telah merevolusikan cara kami membina sistem berskala dan fleksibel. Walau bagaimanapun, mereka juga memperkenalkan kerumitan, terutamanya apabila menguruskan transaksi yang diedarkan merentas perkhidmatan. Di situlah Corak Saga muncul—corak reka bentuk yang berkuasa untuk mengendalikan transaksi yang berjalan lama dalam perkhidmatan mikro. Dalam siaran ini, kami akan meneroka apakah Corak Saga, cara ia berfungsi dan melihatnya dalam tindakan dengan kes penggunaan Sumber Manusia (HR) dalam C#.

Apakah Corak Saga?

Corak Saga memecahkan transaksi yang besar dan diedarkan kepada satu siri langkah yang lebih kecil, setiap satu dikendalikan oleh perkhidmatan mikro tertentu. Langkah-langkah ini dilaksanakan mengikut turutan, dengan tindakan pampasan ditakrifkan untuk setiap langkah untuk melancarkan semula jika berlaku kesilapan.

Terdapat dua pendekatan utama untuk melaksanakan Corak Saga:

1. Koreografi: Setiap perkhidmatan mendengar dan bertindak balas terhadap acara, mengatur sendiri.
2. Orkestrasi: Perkhidmatan penyelaras pusat menguruskan aliran transaksi.

Mengapa Menggunakan Corak Saga?

Corak Saga amat berguna untuk seni bina perkhidmatan mikro di mana:

• Urus niaga merangkumi pelbagai perkhidmatan (cth., HR, senarai gaji, pengambilan).
• Kebolehskalaan dan penyahgandingan adalah penting.
• Adalah penting untuk menangani kegagalan separa dengan anggun.

Kes Penggunaan HR: Penyertaan Pekerja

Bayangkan sistem Sumber Manusia (HR) di mana kemasukan pekerja baharu melibatkan pelbagai perkhidmatan mikro:

1. Perkhidmatan Pengguna: Mencipta akaun pekerja.
2. Perkhidmatan Gaji: Sediakan butiran gaji.
3. Perkhidmatan Faedah: Mendaftarkan pekerja untuk faedah.

Perkhidmatan ini mesti bekerjasama untuk melengkapkan proses penerimaan. Jika Perkhidmatan Gaji gagal, sistem harus membuat asal pembuatan akaun dan pendaftaran faedah.

Melaksanakan Corak Saga dalam C

Mari kita laksanakan Corak Saga dengan orkestrasi untuk proses penerimaan pekerja.

Langkah 1: Tentukan Penyelaras Saga

Penyelaras Saga menguruskan aliran transaksi. Berikut ialah pelaksanaan asas dalam 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.");
    }
}

Langkah 2: Tentukan Perkhidmatan

Setiap perkhidmatan melaksanakan logik khusus dan tindakan pampasan.

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);
}

Pelaksanaan antara muka ini akan berinteraksi dengan pangkalan data atau API lain.

Langkah 3: Laksanakan Saga

Begini cara anda boleh menggunakan Penyelaras 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.");
    }
}

Kelebihan Corak Saga

1. Ketahanan: Membolehkan pemulihan daripada kegagalan dalam proses yang berjalan lama.
2. Skalabiliti: Menyatukan perkhidmatan sambil mengekalkan integriti transaksi.
3. Fleksibiliti: Menyokong aliran kerja yang pelbagai dengan menyesuaikan logik pampasan.

Fikiran Akhir

Corak Saga ialah corak reka bentuk kritikal untuk mengekalkan ketekalan data dalam sistem teragih seperti perkhidmatan mikro. Dalam contoh HR kami, ia memastikan keseluruhan proses penerimaan sama ada berjaya diselesaikan atau dikembalikan dengan anggun, memelihara integriti sistem.

Dengan memanfaatkan corak seperti Saga, kami boleh mereka sistem teguh yang mengendalikan kerumitan transaksi yang diedarkan.

Teruskan pengekodan

Atas ialah kandungan terperinci Corak Saga dalam Microservices. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!