Java를 사용하여 Axon Framework 기반의 이벤트 중심 애플리케이션을 개발하는 방법
1. 배경 소개
Axon Framework는 이벤트 중심 애플리케이션을 구축하기 위한 Java 프레임워크입니다. CQRS(Command Query Responsibility Segregation) 및 EDA(이벤트 중심 아키텍처)를 구현하기 위한 핵심 기능과 도구를 제공합니다. Axon Framework는 뛰어난 확장성과 유연성을 갖추고 있어 개발자가 복잡한 애플리케이션을 쉽게 구축하고 유지 관리할 수 있습니다.
2. 환경 설정
개발을 시작하기 전에 환경 설정이 필요합니다. 먼저 Java SDK 및 Maven 빌드 도구가 설치되었는지 확인합니다. 다음으로, 다음 단계를 통해 필요한 종속성을 소개합니다.
-
프로젝트의 pom에 다음 종속성을 추가합니다. 이벤트 및 명령 정의
Axon Framework에서 이벤트와 명령은 애플리케이션의 핵심 개념입니다. 이벤트는 시스템에서 발생하는 사실이고 명령은 시스템 상태를 변경하는 데 사용되는 동작입니다.
-
OrderCreatedEvent라는 Java 클래스를 생성하고 그 안에 속성을 정의합니다. <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>로그인 후 복사
CreateOrderCommand라는 Java 클래스를 생성하고 정의합니다. 속성:
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
로그인 후 복사
IV. 집계 루트 생성 OrderCreatedEvent的Java类，并定义其中的属性：
public class OrderCreatedEvent {
private String orderId;
private String customerName;
// Getter and Setter
}로그인 후 복사
创建一个名为CreateOrderCommand的Java类，并定义其中的属性：
public class CreateOrderCommand {
private String orderId;
private String customerName;
// Getter and Setter
}로그인 후 복사
四、创建聚合根
聚合根是一个具有唯一标识的领域对象，它负责处理外部命令并生成相应的事件。
创建一个名为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();
}
}로그인 후 복사
创建一个名为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;
}
}로그인 후 복사
五、创建命令处理器
命令处理器负责处理外部命令，并将其分发给相应的聚合根。
创建一个名为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()));
}
}로그인 후 복사
六、创建查询模型
查询模型负责处理外部查询，并返回适当的结果。
创建一个名为OrderQueryModel的Java类，并定义其中的字段和方法：
@Entity
public class OrderQueryModel {
@Id
private String orderId;
private String customerName;
// Getter and Setter
}로그인 후 복사
创建一个名为OrderQueryModelRepository的Java接口，并继承CrudRepository：
@Repository
public interface OrderQueryModelRepository extends CrudRepository<OrderQueryModel, String> {
}로그인 후 복사
创建一个名为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以供外部调用。
创建一个名为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);
}
}로그인 후 복사
创建一个名为CreateOrderDTO的Java类，并定义其中的属性：
public class CreateOrderDTO {
private String customerName;
// Getter and Setter
}로그인 후 복사
创建一个名为GetOrderQuery的Java类，并定义其中的属性：
public class GetOrderQuery {
private String orderId;
// Getter and Setter
}로그인 후 복사
八、启动应用程序
创建一个名为Application的Java类，并添加@SpringBootApplication注解：
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}로그인 후 복사
- 运行
Application类的main 집계 루트는 고유한 ID를 가진 도메인 개체입니다. 외부 명령을 처리하고 해당 이벤트를 생성합니다.
OrderAggregate라는 Java 클래스를 생성하고 여기에 필드와 메서드를 정의합니다.
URL: http://localhost:8080/orders
Method: POST
Body: {"customerName": "John Doe"}로그인 후 복사
OrderAggregateIdentifierResolver라는 Java 클래스를 생성하고 를 구현합니다. AggregateIdentifierResolver 인터페이스:
URL: http://localhost:8080/orders/{orderId}
Method: GET로그인 후 복사
-
5. 명령 프로세서 생성
명령 프로세서는 외부 명령을 처리하고 해당 집계 루트에 배포하는 역할을 담당합니다.
OrderCommandHandler라는 Java 클래스를 생성하고 여기에 메서드를 정의합니다.
rrreee🎜🎜🎜 6. 쿼리 모델 생성 🎜쿼리 모델은 외부 쿼리를 처리하고 적절한 결과를 반환하는 역할을 담당합니다. 🎜🎜🎜🎜
OrderQueryModel이라는 Java 클래스를 생성하고 여기에 필드와 메서드를 정의합니다. 🎜rrreee🎜🎜🎜
OrderQueryModelRepository라는 Java 인터페이스를 생성하고
CrudRepository를 상속합니다. : 🎜rrreee🎜🎜🎜
OrderQueryHandler라는 Java 클래스를 생성하고 그 안에 메서드를 정의합니다. 🎜rrreee🎜🎜🎜 7. REST API 생성🎜외부 호출을 위한 REST API 생성. 🎜🎜🎜🎜
OrderController라는 Java 클래스를 만들고 그 안에 메서드를 정의합니다. 🎜rrreee🎜🎜🎜
CreateOrderDTO라는 Java 클래스를 만들고 정의합니다. 속성: 🎜rrreee🎜 🎜🎜
GetOrderQuery라는 Java 클래스를 생성하고 해당 속성을 정의합니다. 🎜rrreee🎜🎜🎜 8. 애플리케이션을 시작합니다. 🎜🎜🎜🎜
Application의 Java 클래스라는 클래스를 생성합니다. ,
@SpringBootApplication 주석을 추가합니다. 🎜rrreee🎜🎜
Application 클래스의
main 메서드를 실행하여 응용 프로그램을 시작합니다. 🎜🎜🎜9. 애플리케이션 테스트🎜 Postman 또는 유사한 도구를 사용하여 HTTP 요청을 보내 애플리케이션 기능을 테스트합니다. 🎜🎜🎜🎜POST 요청을 보내 주문 생성: 🎜rrreee🎜🎜🎜GET 요청을 보내 주문 정보 가져오기: 🎜rrreee🎜🎜🎜10. 요약🎜이 문서에서는 Java를 사용하여 이벤트 기반 애플리케이션을 개발하는 방법을 소개합니다. Axon 프레임워크를 기반으로 합니다. 이벤트와 명령을 정의하고 집계 루트, 명령 처리기, 쿼리 모델 및 REST API를 생성함으로써 Axon Framework를 사용하여 효율적이고 확장 가능한 이벤트 기반 애플리케이션을 구축할 수 있습니다. 🎜
위 내용은 Java를 사용하여 Axon Framework 기반 이벤트 기반 애플리케이션을 개발하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
