Melaksanakan corak saga dalam sistem yang diedarkan Java

Gunakan mod SAGA untuk mengekalkan konsistensi data dalam sistem yang diedarkan Java, dan menggantikan urus niaga yang diedarkan melalui urutan transaksi tempatan dan mekanisme pampasan; 2. Adalah disyorkan untuk menggunakan saga yang dirancang di Spring Boot, dan kelas Ordersaga menyelaraskan pelaksanaan dan pengembalian pembayaran dan perkhidmatan inventori; 3. Tambah semula, idempotence, dan negeri saga yang berterusan untuk meningkatkan kebolehpercayaan; 4. Orkestrasi Pengoptimuman Proses Linear dianggap dalam senario yang didorong oleh peristiwa yang kompleks.

Apabila membina sistem yang diedarkan di Java -terutamanya yang merangkumi pelbagai microservices -anda akan sering menghadapi cabaran untuk mengekalkan konsistensi data merentasi perkhidmatan tanpa bergantung pada urus niaga yang diedarkan. Di sinilah corak saga masuk.

Apakah corak saga?

Saga adalah urutan transaksi tempatan di mana setiap perkhidmatan mengemas kini pangkalan data sendiri. Jika satu langkah gagal, saga melaksanakan urus niaga yang membatalkan perubahan yang dibuat oleh langkah -langkah sebelumnya. Ini alternatif kepada komitmen dua fasa (2pc) dan mengelakkan masalah gandingan dan prestasi yang ketat yang datang dengannya.

Terdapat dua cara utama untuk melaksanakan saga:

1. Koreografi - Setiap perkhidmatan menerbitkan acara, dan perkhidmatan lain bertindak balas kepada mereka (desentralisasi).
2. Orchestration - Orchestrator pusat (pengurus saga) memberitahu setiap perkhidmatan apa yang perlu dilakukan seterusnya (berpusat).

Untuk sistem Java, orkestra sering lebih mudah dilaksanakan dan debug , terutamanya jika anda menggunakan Spring Boot.

Cara melaksanakan orkestra saga di java

Katakan anda sedang membina aplikasi e-dagang dengan perkhidmatan ini:

• Perkhidmatan pesanan
• Perkhidmatan pembayaran
• Perkhidmatan inventori

Pengguna meletakkan pesanan → pembayaran mesti diproses → inventori mesti dikhaskan.

Jika sebarang langkah gagal, anda perlu melancarkan langkah -langkah sebelumnya (misalnya, jika inventori gagal, mengembalikan pembayaran).

1. Tentukan Orkestrator Saga

Buat kelas OrderSaga yang menyelaraskan aliran:

 @Service
Pesanan Kelas Awam {

    PaymentserviceClient Paymentservice;
    Inventory Final InventoryServiceClient InventoryService;

    void awam melaksanakan (perintah pesanan) {
        Boolean Paymentsuccess = False;
        Boolean InventorySuccess = false;

        Cuba {
            // Langkah 1: Proses pembayaran
            paymentservice.charge (order.getCustomerId (), order.getTotal ());
            Paymentsuccess = true;

            // Langkah 2: Inventori Rizab
            InventoryService.reserve (order.getItems ());
            InventorySuccess = true;

            // Kejayaan! Tandakan pesanan seperti yang disahkan
            order.setstatus (Orderstatus.confirmed);
        } menangkap (pengecualian e) {
            // mencetuskan tindakan pampasan dalam urutan terbalik
            jika (InventorySuccess) {
                InventoryService.Release (Order.GetItems ());
            }
            jika (Paymentsuccess) {
                paymentservice.refund (order.getCustomerId (), order.gettotal ());
            }

            order.setStatus (Orderstatus.Failed);
            membuang e;
        }
    }
}

2. Jadikan ia berdaya tahan dengan pengambilan semula dan idempotensi

Dalam sistem sebenar, perkhidmatan mungkin tidak tersedia buat sementara waktu. Tambahkan logik semula menggunakan Spring Relry atau Resilience4j:

 @Retry (name = "InventoryService", fallbackMethod = "HandleInVentoryFailure")
Rizab Void Public (Senarai <temat> item) {
    InventoryServiceClient.reserve (item);
}

Juga, pastikan tindakan pampasan anda (seperti bayaran balik atau pelepasan) adalah IdealPotent -mereka boleh dipanggil beberapa kali tanpa kesan sampingan.

3. Bertahan Saga Negeri (pilihan tetapi disyorkan)

Untuk sagas lama atau pemulihan kemalangan, simpan keadaan saga dalam pangkalan data (misalnya, menggunakan JPA):

 @Entity
kelas awam SAGAINSTANCE {
    @Id
    Sagaid String Private;
    rentetan peribadi OrderId;
    String swasta CurrentState; // mis, "pembayaran_done"
    swasta localdateTime createat;
}

Kemas kini keadaan ini selepas setiap langkah supaya anda boleh meneruskan jika Orchestrator terhempas.

4. Gunakan acara untuk gandingan longgar (pilihan)

Daripada panggilan HTTP langsung, menerbitkan peristiwa domain (misalnya, melalui Kafka atau Rabbitmq). Orchestrator mendengar ini dan memutuskan langkah seterusnya. Ini mengurangkan gandingan dan meningkatkan skalabiliti.

Petua utama untuk pemaju Java

• ✅ Gunakan Spring Boot Spring Cloud OpenFeign untuk panggilan perkhidmatan-ke-perkhidmatan yang bersih.
• ✅ Bungkus logik saga dalam kelas perkhidmatan khusus -bukan dalam pengawal.
• ✅ Log setiap langkah dan pampasan untuk debugging (SLF4J MDC).
• ✅ Mengendalikan masa tamat secara eksplisit -jangan biarkan saga menggantung selama -lamanya.
• ✅ Skenario Kegagalan Ujian: Simulasi gangguan perkhidmatan dan sahkan kerja pampasan.

Bilakah menggunakan koreografi vs orkestra

• Orchestration : Lebih mudah difahami, lebih mudah untuk diuji, lebih baik untuk aliran linear (seperti contoh pesanan kami).
• Koreografi : Lebih baik untuk sistem yang didorong oleh kompleks, di mana perkhidmatan berkembang secara bebas-tetapi lebih sukar untuk mengesan dan debug.

Bagi kebanyakan pasukan Java yang bermula dengan sagas, orkestra adalah cara untuk pergi .

Melaksanakan corak saga bukan tentang mengelakkan kegagalan -ini tentang merancang untuk mereka dengan anggun. Di Java, dengan ekosistem Spring Boot, ia menghairankan dengan mudah apabila anda memecahkannya ke langkah dan pampasan.

Atas ialah kandungan terperinci Melaksanakan corak saga dalam sistem yang diedarkan Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!