Cara menggunakan Java untuk membangunkan aplikasi dipacu peristiwa berdasarkan Rangka Kerja Axon

Cara menggunakan Java untuk membangunkan aplikasi dipacu peristiwa berdasarkan Rangka Kerja Axon

1 Pengenalan Latar Belakang
Rangka Kerja Axon ialah rangka kerja Java untuk membina aplikasi dipacu acara. Ia menyediakan fungsi teras dan alatan untuk melaksanakan CQRS (Command Query Responsibility Segregation) dan seni bina dipacu peristiwa (EDA). Rangka Kerja Axon mempunyai kebolehskalaan dan fleksibiliti yang baik, membolehkan pembangun membina dan menyelenggara aplikasi yang kompleks dengan mudah.

2. Persediaan persekitaran
Sebelum memulakan pembangunan, kita perlu menyediakan persekitaran. Mula-mula, sahkan bahawa alat binaan Java SDK dan Maven telah dipasang. Seterusnya, perkenalkan kebergantungan yang diperlukan melalui langkah-langkah berikut:

1. Tambahkan kebergantungan berikut dalam pom projek Mentakrifkan peristiwa dan arahan

   Dalam Rangka Kerja Axon, peristiwa dan arahan ialah konsep teras dalam aplikasi. Peristiwa ialah fakta yang berlaku dalam sistem, manakala arahan ialah tindakan yang digunakan untuk mengubah keadaan sistem.

2. Buat kelas Java bernama OrderCreatedEvent dan tentukan sifat di dalamnya:

<dependencies>
 <dependency>
     <groupId>org.axonframework</groupId>
     <artifactId>axon-spring-boot-starter</artifactId>
     <version>4.1.3</version>
 </dependency>
 <dependency>
     <groupId>org.axonframework</groupId>
     <artifactId>axon-test</artifactId>
     <version>4.1.3</version>
     <scope>test</scope>
 </dependency>
</dependencies>

Buat kelas Java bernama CreateOrderCommand dan takrifkannya Atribut:

spring.datasource.driverClassName=org.h2.Driver
spring.datasource.url=jdbc:h2:mem:test
spring.datasource.username=sa
spring.datasource.password=
spring.jpa.database-platform=org.hibernate.dialect.H2Dialect

1. 4. Buat punca agregat

   Pusat agregat ialah objek domain dengan identiti unik, yang bertanggungjawab untuk memproses arahan luaran dan menjana peristiwa yang sepadan. OrderCreatedEvent的Java类，并定义其中的属性：

   public class OrderCreatedEvent {
   
    private String orderId;
    private String customerName;
   
    // Getter and Setter
   }

2. 创建一个名为CreateOrderCommand的Java类，并定义其中的属性：

   public class CreateOrderCommand {
   
    private String orderId;
    private String customerName;
   
    // Getter and Setter
   }

四、创建聚合根
聚合根是一个具有唯一标识的领域对象，它负责处理外部命令并生成相应的事件。

1. 创建一个名为OrderAggregate的Java类，并定义其中的字段和方法：

   @Aggregate
   public class OrderAggregate {
   
    @AggregateIdentifier
    private String orderId;
    private String customerName;
   
    public OrderAggregate() {
    }
   
    @CommandHandler
    public OrderAggregate(CreateOrderCommand command) {
        AggregateLifecycle.apply(new OrderCreatedEvent(command.getOrderId(), command.getCustomerName()));
    }
   
    @EventSourcingHandler
    public void on(OrderCreatedEvent event) {
        this.orderId = event.getOrderId();
        this.customerName = event.getCustomerName();
    }
   }

2. 创建一个名为OrderAggregateIdentifierResolver的Java类，并实现AggregateIdentifierResolver接口：

   @Component
   public class OrderAggregateIdentifierResolver implements AggregateIdentifierResolver {
   
    @Override
    public String resolveId(Object command) {
        if (command instanceof CreateOrderCommand) {
            return ((CreateOrderCommand) command).getOrderId();
        }
        return null;
    }
   }

五、创建命令处理器
命令处理器负责处理外部命令，并将其分发给相应的聚合根。

1. 创建一个名为OrderCommandHandler的Java类，并定义其中的方法：

   @Component
   public class OrderCommandHandler {
   
    private final CommandGateway commandGateway;
   
    public OrderCommandHandler(CommandGateway commandGateway) {
        this.commandGateway = commandGateway;
    }
   
    @CommandHandler
    public void handle(CreateOrderCommand command) {
        commandGateway.send(new CreateOrderCommand(command.getOrderId(), command.getCustomerName()));
    }
   }

六、创建查询模型
查询模型负责处理外部查询，并返回适当的结果。

1. 创建一个名为OrderQueryModel的Java类，并定义其中的字段和方法：

   @Entity
   public class OrderQueryModel {
   
    @Id
    private String orderId;
    private String customerName;
   
    // Getter and Setter
   }

2. 创建一个名为OrderQueryModelRepository的Java接口，并继承CrudRepository：

   @Repository
   public interface OrderQueryModelRepository extends CrudRepository<OrderQueryModel, String> {
   }

3. 创建一个名为OrderQueryHandler的Java类，并定义其中的方法：

   @Component
   public class OrderQueryHandler {
   
    private final OrderQueryModelRepository orderQueryModelRepository;
   
    public OrderQueryHandler(OrderQueryModelRepository orderQueryModelRepository) {
        this.orderQueryModelRepository = orderQueryModelRepository;
    }
   
    @QueryHandler
    public OrderQueryModel handle(GetOrderQuery query) {
        return orderQueryModelRepository.findById(query.getOrderId()).orElse(null);
    }
   }

七、创建REST API
创建REST API以供外部调用。

1. 创建一个名为OrderController的Java类，并定义其中的方法：

   @RestController
   @RequestMapping("/orders")
   public class OrderController {
   
    private final CommandGateway commandGateway;
    private final QueryGateway queryGateway;
   
    public OrderController(CommandGateway commandGateway, QueryGateway queryGateway) {
        this.commandGateway = commandGateway;
        this.queryGateway = queryGateway;
    }
   
    @PostMapping
    public ResponseEntity<String> create(@RequestBody CreateOrderDTO createOrderDTO) {
        String orderId = UUID.randomUUID().toString();
        commandGateway.send(new CreateOrderCommand(orderId, createOrderDTO.getCustomerName()));
        return ResponseEntity.ok(orderId);
    }
   
    @GetMapping("/{orderId}")
    public ResponseEntity<OrderQueryModel> get(@PathVariable String orderId) throws ExecutionException, InterruptedException {
        OrderQueryModel order = queryGateway.query(new GetOrderQuery(orderId), ResponseTypes.instanceOf(OrderQueryModel.class)).get();
        if (order == null) {
            return ResponseEntity.notFound().build();
        }
        return ResponseEntity.ok(order);
    }
   }

2. 创建一个名为CreateOrderDTO的Java类，并定义其中的属性：

   public class CreateOrderDTO {
   
    private String customerName;
   
    // Getter and Setter
   }

3. 创建一个名为GetOrderQuery的Java类，并定义其中的属性：

   public class GetOrderQuery {
   
    private String orderId;
   
    // Getter and Setter
   }

八、启动应用程序

1. 创建一个名为Application的Java类，并添加@SpringBootApplication注解：

   @SpringBootApplication
   public class Application {
   
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
   }

2. 运行Application类的main

Buat kelas Java bernama OrderAggregate dan tentukan medan dan kaedah di dalamnya:

URL: http://localhost:8080/orders
Method: POST
Body: {"customerName": "John Doe"}

1. Buat kelas Java bernama OrderAggregateIdentifierResolver the dan Laksanakan Antara muka AggregateIdentifierResolver:

   URL: http://localhost:8080/orders/{orderId}
   Method: GET

2. 5. Buat pemproses arahan

   Pemproses arahan bertanggungjawab untuk memproses arahan luaran dan mengedarkannya kepada akar agregat yang sepadan.

Buat kelas Java bernama OrderCommandHandler dan tentukan kaedah di dalamnya:
rrreee

🎜🎜 6. Buat model pertanyaan 🎜Model pertanyaan bertanggungjawab memproses pertanyaan luaran dan mengembalikan hasil yang sesuai. 🎜🎜🎜🎜Buat kelas Java bernama OrderQueryModel dan tentukan medan dan kaedah di dalamnya: 🎜rrreee🎜🎜🎜Buat antara muka Java bernama OrderQueryModelRepository dan Inherit : 🎜rrreee🎜🎜🎜Buat kelas Java bernama OrderQueryHandler dan tentukan kaedah di dalamnya: 🎜rrreee🎜🎜🎜 7. Cipta REST API🎜Buat REST API untuk panggilan luaran. 🎜🎜🎜🎜Buat kelas Java bernama OrderController dan tentukan kaedah di dalamnya: 🎜rrreee🎜🎜🎜Buat kelas Java bernama CreateOrderDTO dan tentukan Atribut: 🎜 🎜🎜Buat kelas Java bernama GetOrderQuery dan tentukan atributnya: 🎜rrreee🎜🎜🎜 8. Mulakan aplikasi 🎜🎜🎜🎜Buat kelas bernama Application class's , dan tambahkan anotasi @SpringBootApplication: 🎜rrreee🎜🎜Jalankan kaedah utama kelas Application untuk memulakan program aplikasi. 🎜🎜🎜9 Uji aplikasi🎜Gunakan Posman atau alat yang serupa untuk menghantar permintaan HTTP untuk menguji kefungsian aplikasi. 🎜🎜🎜🎜Hantar permintaan POST untuk membuat pesanan: 🎜rrreee🎜🎜🎜Hantar permintaan GET untuk mendapatkan maklumat pesanan: 🎜rrreee🎜🎜🎜10. Ringkasan🎜Aplikasi ini memperkenalkan cara-menggunakan Javan berdasarkan Rangka Kerja Axon. Dengan mentakrifkan peristiwa dan perintah, mencipta akar agregat, pengendali arahan, model pertanyaan dan API REST, kami boleh menggunakan Rangka Kerja Axon untuk membina aplikasi dipacu peristiwa yang cekap dan berskala. 🎜

Atas ialah kandungan terperinci Cara menggunakan Java untuk membangunkan aplikasi dipacu peristiwa berdasarkan Rangka Kerja Axon. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!