Cara menggunakan Spring Cloud Saga untuk melaksanakan transaksi yang diedarkan

Spring Cloud Saga menyediakan cara deklaratif untuk menyelaraskan transaksi yang diedarkan, memudahkan proses pelaksanaan: Tambahkan kebergantungan Maven: spring-cloud-starter-saga. Buat Orkestra Saga (@Orkestra Saga). Tulis peserta untuk melaksanakan SagaExecution untuk melaksanakan logik perniagaan dan logik pampasan (@SagaStep). Tentukan peralihan keadaan dan pelakon dalam Saga. Dengan menggunakan Spring Cloud Saga, atomicity antara operasi perkhidmatan mikro yang berbeza dipastikan.

Cara melaksanakan transaksi teragih dalam Spring Cloud Saga

Transaksi teragih adalah penting untuk memastikan integriti data antara perkhidmatan mikro yang berbeza. Spring Cloud Saga menyediakan cara deklaratif untuk menyelaraskan transaksi yang diedarkan, memudahkan proses pelaksanaan.

Dependencies

Tambah dependensi berikut dalam projek Maven:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-saga</artifactId>
    <version>3.1.5</version>
</dependency>

Create Saga

Saga ialah penyelaras transaksi yang diedarkan. Untuk mencipta Saga, anda perlu mencipta kelas dengan anotasi @SagaOrchestration: @SagaOrchestration 注释的类：

@SagaOrchestration
public class OrderSaga {

    private final SomeService someService;
    private final OtherService otherService;

    public OrderSaga(SomeService someService, OtherService otherService) {
        this.someService = someService;
        this.otherService = otherService;
    }

    // 定义 Saga 的状态转换
    // ...
}

编写参与者

参与者是 Saga 中执行实际业务逻辑的组件。它们需要实现 SagaExecution

public class SomeServiceImpl implements SagaExecution<OrderSaga> {

    // 定义业务逻辑
    // ...
}

Menulis Peserta

Pelakon ialah komponen dalam Saga yang melaksanakan logik perniagaan sebenar. Mereka perlu melaksanakan antara muka E-mel Pengesahan Pesanan

Kita boleh menggunakan Spring Cloud Saga untuk menyelaraskan operasi ini:
• Order Saga

• @SagaOrchestration
  public class OrderSaga {
  
      // 定义 Saga 的各个阶段
      @SagaStep(output = "createOrder")
      public void createOrder(SagaExecution<OrderSaga> sagaExecution) {
          // 创建订单
      }
  
      @SagaStep(input = "createOrder", output = "decrementStock")
      public void decrementStock(SagaExecution<OrderSaga> sagaExecution) {
          // 从库存中扣除商品数量
      }
  
      @SagaStep(input = "decrementStock", output = "sendEmail")
      public void sendEmail(SagaExecution<OrderSaga> sagaExecution) {
          // 发送订单确认电子邮件
      }
  }

Peserta

public class OrderServiceImpl implements SagaExecution<OrderSaga> {

    // 实现创建订单的逻辑
    @Override
    public void execute(OrderSaga saga, OrchestrationContext<OrderSaga> context) {
        // ...
    }

    // 实现补偿逻辑
    @Override
    public void compensate(OrderSaga saga, OrchestrationContext<OrderSaga> context) {
        // ...
    }
}

public class StockServiceImpl implements SagaExecution<OrderSaga> {

    // 实现扣减库存的逻辑
    @Override
    public void execute(OrderSaga saga, OrchestrationContext<OrderSaga> context) {
        // ...
    }

    // 实现补偿逻辑
    @Override
    public void compensate(OrderSaga saga, OrchestrationContext<OrderSaga> context) {
        // ...
    }
}

public class EmailServiceImpl implements SagaExecution<OrderSaga> {

    // 实现发送电子邮件的逻辑
    @Override
    public void execute(OrderSaga saga, OrchestrationContext<OrderSaga> context) {
        // ...
    }

    // 发送电子邮件不需要补偿逻辑
    @Override
    public void compensate(OrderSaga saga, OrchestrationContext<OrderSaga> context) {

    }
}

yang diedarkan dan diedarkan menggunakan Spring Cloud Saga pesanan Atomicity antara penciptaan, potongan inventori dan penghantaran e-mel.

Atas ialah kandungan terperinci Cara menggunakan Spring Cloud Saga untuk melaksanakan transaksi yang diedarkan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!