Pub/Sub 방식의 연동

마이크로 서비스간의 통신에서 이벤트 메세지를 Pub/Sub 하는 방법을 실습합니다.

Order 서비스에서 주문(OrderPlaced) 이벤트가 발행 되었을 때, Inventory 서비스에서 OrderPlaced 이벤트를 수신하여 재고량을 변경(감소)합니다.

이벤트스토밍 모델 준비

• 아래 모델을 새 탭에서 로딩합니다. 모델 링크
• 브라우져에 모델이 로딩되지 않으면, 우측 상단의 (사람모양) 아바타 아이콘을 클릭하여 깃헙(Github) 계정으로 로그인 후 리로드하면 아래처럼 랩에 필요한 이벤트스토밍 기본 모델이 출력됩니다.

order 서비스의 이벤트 Publish

메뉴의 CODE > ProjectIDE 를 선택하여, 연결된 브라우져 IDE를 로딩합니다.

• order 마이크로 서비스를 실행합니다.

  order 폴더를 선택 > Open In Terminal > 터미널에서 아래 커맨드를 실행합니다. 주문 서비스가 8081 포트로 실행됩니다.

mvn spring-boot:run

• 새 터미널을 추가하고 기동된 order 서비스를 호출하여 주문 1건을 요청합니다.

http localhost:8081/orders productId=1 productName=TV qty=3

• 새 터미널을 추가하고 kafka 유틸리티가 포함된 위치에 접속하기 위하여 docker 를 통하여 shell 에 진입합니다.

cd kafka
docker-compose exec -it kafka /bin/bash
cd /bin

• kafka Consumer에서 이벤트를 확인합니다.

./kafka-console-consumer --bootstrap-server localhost:9092 --topic labshoppubsub  --from-beginning

• 확인된 이벤트 결과 :

{"eventType":"OrderPlaced","timestamp":1717047846007,"id":1,"productId":"1","qty":3,"customerId":null}

Inventory 서비스의 이벤트 Subscribe

• Inventory 폴더 내 PolicyHandler.java 파일의 코드를 확인합니다.
• PolicyHandler.java --> Inventory.java (Aggregate) 의 Port Method (decreaseStock)을 호출하게 됩니다.
• Inventoy.java의 decreaseStock 내에 작성해야 할 로직은 다음과 같습니다.

repository().findById(Long.valueOf(orderPlaced.getProductId())).ifPresent(inventory->{
    
    inventory.setStock(inventory.getStock() - orderPlaced.getQty()); // do something
    repository().save(inventory);


    });

• 새 터미널을 추가하고 inventory 서비스를 실행합니다.

mvn spring-boot:run

• inventory 서비스가 8082 포트로 기동됨을 확인하고 주문을 실행합니다.

http :8082/inventories id=1 stock=10
http :8081/orders productId=1 qty=5
http :8082/inventories/1

• OrderPlaced 이벤트에 반응하여 재고량이 감소되는 것을 확인합니다.

{
    "_links": {
        "inventory": {
            "href": "http://localhost:8082/inventories/1"
        },
        "self": {
            "href": "http://localhost:8082/inventories/1"
        }
    },
    "stock": 5
}

확장미션

• delivery Bounded Context 를 생성하고, 주문에 대하여 배송 1건을 추가하는 policy를 모델링하고 구현하시오.