Spring Application Context Async Event
👉 해당 포스트를 읽는데 도움을 줍니다.
0. 들어가면서
Spring Application Context Event 포스트를 작성하면서 생긴 궁금한 사항을 주제로 포스트를 작성하였습니다. 이번 포스트는 비동기 처리 방법에 대해서 정리해보았습니다. 크게 두 가지 주제로 예제 코드를 작성하였습니다.
- 비동기 처리 구현 방법
- 비동기 처리 시 트랜잭션 연결
1. 구현 방법
구현은 두 개의 애너테이션을 통해 손쉽게 구현 가능합니다. 아래 예제 코드를 통해서도 확인이 가능합니다.
- @EnableAsync - 어플리케이션을 실행시키는 클래스 위에 선언
- @Async - 이벤트를 수신하는 메소드 위에 선언
2. 비동기 처리 시 트랜잭션 연결
비동기 이벤트 처리 시 트랜잭션이 어떻게 연결되는지 궁금하였습니다. Spring Application Context Event with Transaction 포스트에서도 확인할 수 있듯이 일반적인 이벤트 발행은 트랜잭션이 연결됩니다. 비동기 이벤트 처리에서 만약 일반적인 이벤트 발행처럼 트랜잭션이 연결된다면 아래와 같은 이상한 상황이 벌어질 수 있습니다.
- 이벤트를 처리하는 다른 스레드의 수행 결과에 따라 트랜잭션의 커밋(commit), 롤백(rollback) 여부가 결정됩니다.
- 이벤트를 발행한 메인 스레드는 자신의 일을 모두 끝냈지만 이벤트의 처리 결과를 기다려야 합니다.
- 이벤트 처리 결과에 따라 대기 중인 메인 스레드의 커밋(commit), 롤백(rollback)이 결정됩니다.
당연히 트랜잭션이 나뉘어질 것이라고 예상되지만 정확한 결과는 테스트를 통해 확인해보도록 하겠습니다.
3. 예제 코드
예제 코드 시나리오는 Spring Application Context Event with Transaction 포스트와 동일합니다.
3.1. ActionInBlogApplication 클래스
- @EnableAsync 애너테이션을 추가합니다.
package blog.in.action;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
@EnableAsync
@SpringBootApplication
public class ActionInBlogApplication {
public static void main(String[] args) {
SpringApplication.run(ActionInBlogApplication.class, args);
}
}
3.2. DeliveryService 클래스
- 비동기 여부를 확인하기 위해 AsyncEvent 이벤트 발행 전, 후 로그를 출력합니다.
package blog.in.action.delivery.service;
import blog.in.action.common.event.AsyncEvent;
import blog.in.action.delivery.entity.Delivery;
import blog.in.action.delivery.repository.DeliveryRepository;
import java.util.Optional;
import lombok.extern.log4j.Log4j2;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Log4j2
@Service
@Transactional
public class DeliveryService {
private final ApplicationContext applicationContext;
private final DeliveryRepository deliveryRepository;
public DeliveryService(ApplicationContext applicationContext, DeliveryRepository deliveryRepository) {
this.applicationContext = applicationContext;
this.deliveryRepository = deliveryRepository;
}
public void updateDeliveryComplete(String deliveryCode) {
Optional<Delivery> optional = deliveryRepository.findByDeliveryCode(deliveryCode);
if (optional.isEmpty()) {
throw new RuntimeException(deliveryCode + " 코드에 해당하는 배송 정보가 없습니다.");
}
Delivery delivery = optional.get();
delivery.setDeliveryEndTp("*");
deliveryRepository.save(delivery);
log.info("비동기 이벤트 발행 전");
applicationContext.publishEvent(new AsyncEvent(delivery.getOrder().getId(), deliveryCode));
log.info("비동기 이벤트 발행 후");
}
}
3.3. OrderEventListener 클래스
- @Async 애너테이션을 추가합니다.
- 비동기 처리이므로 별도 콜 스택(call stack)에서 동작합니다.
- try-catch 구문으로 묶지 않아도 주문 서비스에서 발생시킨 예외가 배달 서비스로 이어지지 않습니다.
package blog.in.action.order.listner;
import blog.in.action.common.event.AsyncEvent;
import blog.in.action.order.service.OrderService;
import lombok.extern.log4j.Log4j2;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@Log4j2
@Component
public class OrderEventListener {
private final OrderService orderService;
public OrderEventListener(OrderService orderService) {
this.orderService = orderService;
}
@Async
@EventListener
public void listenAsyncEvent(AsyncEvent event) {
log.info("비동기 이벤트 수신");
orderService.updateOrderDeliveryComplete(event.getOrderId(), event.getDeliveryCode());
}
}
3.4. OrderService 클래스
- 이전 포스트와 마찬가지로 조회 후 의도적인 예외를 발생시킵니다.
package blog.in.action.order.service;
import blog.in.action.order.entity.Order;
import blog.in.action.order.repository.OrderRepository;
import java.util.Optional;
import lombok.extern.log4j.Log4j2;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
@Log4j2
@Component
@Transactional
public class OrderService {
private final OrderRepository orderRepository;
public OrderService(OrderRepository orderRepository) {
this.orderRepository = orderRepository;
}
public void updateOrderDeliveryComplete(long orderId, String deliveryCode) {
Optional<Order> optional = orderRepository.findById(orderId);
if (optional.isPresent()) {
throw new RuntimeException(deliveryCode + " 배송 코드에 해당하는 주문 정보가 존재합니다.");
}
}
}
4. 테스트 코드
- 특정 배달 정보를 완료 처리합니다.
- 주문 서비스에서 예외가 발생하지만 별도 트랜잭션이 나눠지므로 배달 정보는 완료 처리됩니다.
@SpringBootTest
public class TransactionInEventTest {
// ...
@Test
public void test_updateDeliveryComplete_doNotRollback() {
deliveryService.updateDeliveryComplete(DELIVERY_CODE);
Optional<Delivery> deliveryOptional = deliveryRepository.findByDeliveryCode(DELIVERY_CODE);
assertThat(deliveryOptional).isNotEmpty();
assertThat(deliveryOptional.get().getDeliveryEndTp()).isEqualTo("*");
}
}
테스트 결과 - 로그
- 비동기 이벤트 발행 전 > 비동기 이벤트 발행 후 > 비동기 이벤트 수신 순으로 로그가 출력되었습니다.
- 이벤트를 발행한 메인 스레드는 계속 진행되고 별도의 스레드가 이벤트 처리를 수행하였음을 알 수 있습니다.
Hibernate: select delivery0_.id as id1_0_, delivery0_.delivery_code as delivery2_0_, delivery0_.delivery_end_tp as delivery3_0_, delivery0_.order_id as order_id4_0_ from tb_delivery delivery0_
Hibernate: select order0_.id as id1_1_0_, order0_.order_code as order_co2_1_0_, order0_.order_state as order_st3_1_0_ from tb_order order0_ where order0_.id=?
Hibernate: delete from tb_delivery where id=?
Hibernate: select order0_.id as id1_1_, order0_.order_code as order_co2_1_, order0_.order_state as order_st3_1_ from tb_order order0_
Hibernate: delete from tb_order where id=?
Hibernate: select next_val as id_val from hibernate_sequence for update
Hibernate: update hibernate_sequence set next_val= ? where next_val=?
Hibernate: insert into tb_order (order_code, order_state, id) values (?, ?, ?)
Hibernate: select next_val as id_val from hibernate_sequence for update
Hibernate: update hibernate_sequence set next_val= ? where next_val=?
Hibernate: insert into tb_delivery (delivery_code, delivery_end_tp, order_id, id) values (?, ?, ?, ?)
Hibernate: select delivery0_.id as id1_0_, delivery0_.delivery_code as delivery2_0_, delivery0_.delivery_end_tp as delivery3_0_, delivery0_.order_id as order_id4_0_ from tb_delivery delivery0_ where delivery0_.delivery_code=?
Hibernate: select order0_.id as id1_1_0_, order0_.order_code as order_co2_1_0_, order0_.order_state as order_st3_1_0_ from tb_order order0_ where order0_.id=?
2021-08-17 01:11:31.105 INFO 5628 --- [ main] b.i.a.delivery.service.DeliveryService : 비동기 이벤트 발행 전
2021-08-17 01:11:31.105 INFO 5628 --- [ main] b.i.a.delivery.service.DeliveryService : 비동기 이벤트 발행 후
Hibernate: update tb_delivery set delivery_code=?, delivery_end_tp=?, order_id=? where id=?
2021-08-17 01:11:31.105 INFO 5628 --- [ task-1] b.i.a.order.listner.OrderEventListener : 비동기 이벤트 수신
Hibernate: select order0_.id as id1_1_0_, order0_.order_code as order_co2_1_0_, order0_.order_state as order_st3_1_0_ from tb_order order0_ where order0_.id=?
2021-08-17 01:11:31.121 ERROR 5628 --- [ task-1] .a.i.SimpleAsyncUncaughtExceptionHandler : Unexpected exception occurred invoking async method: public void blog.in.action.order.listner.OrderEventListener.listenAsyncEvent(blog.in.action.common.event.AsyncEvent)
java.lang.RuntimeException: DELIVERY_CODE 배송 코드에 해당하는 주문 정보가 존재합니다.
at blog.in.action.order.service.OrderService.updateOrderDeliveryComplete(OrderService.java:24) ~[classes/:na]
at blog.in.action.order.service.OrderService$$FastClassBySpringCGLIB$$793adfdb.invoke(<generated>) ~[classes/:na]
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.2.4.RELEASE.jar:5.2.4.RELEASE]
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:769) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.2.4.RELEASE.jar:5.2.4.RELEASE]
...
Hibernate: select delivery0_.id as id1_0_, delivery0_.delivery_code as delivery2_0_, delivery0_.delivery_end_tp as delivery3_0_, delivery0_.order_id as order_id4_0_ from tb_delivery delivery0_ where delivery0_.delivery_code=?
Hibernate: select order0_.id as id1_1_0_, order0_.order_code as order_co2_1_0_, order0_.order_state as order_st3_1_0_ from tb_order order0_ where order0_.id=?
테스트 결과 - Junit
- 테스트 통과를 통해 메인 스레드에서 처리한 배달 정보는 롤백이 되지 않았음을 확인할 수 있습니다.
테스트 결과 - SQL
SELECT *
FROM tb_order o
INNER JOIN tb_delivery d ON o.id = d.order_id;
CLOSING
관련된 글을 정리하다보니 @EnableAsync, @Async 두 애너테이션은 Spring Application Context Event 와 관련된 애너테이션은 아닌 것 같습니다.
여러 가지 활용 방법이 있고 그 중 하나가 Spring Application Context Event 인 것 같습니다.
나중에 시간이 되면 다양한 활용 용도에 대해서 정리해야겠습니다.
댓글남기기