[클라우드 네이티브] 12. Inventory 서비스의 이벤트 Subscribe

1. Inventory.java 코드 추가

 

주문이 들어오면 → 상품 ID로 재고를 찾고 → 수량만큼 차감한 후 → 다시 저장하는 코드

Path - /inventory/src/main/java/labshoppubsub/domain/Inventory.java

 

코드 추가

// Example 2: finding and process

        repository().findById(Long.valueOf(orderPlaced.getProductId())).ifPresent(inventory->{

            inventory.setStock(inventory.getStock() - orderPlaced.getQty()); // do something

            repository().save(inventory);

        });

 

2. Inventory 서비스 실행하기

 

cd inventory

mvn spring-boot:run

 

3. 재고 등록, 주문 요청, 재고 확인하기

 

8083번 포트를 사용하는 inventory 서버로 재고 등록 10개 요청 명령어

http :8083/inventories id=1 stock=10

 

4. 재고 등록, 주문 요청, 재고 확인 하기

 

- 8082번 포트를 사용하는 Order 서버로 주문 5개를 요청

http :8082/orders productId=1 qty=5

 

5. 재고 등록, 주문 요청, 재고 확인 하기

 

8083번 포트를 사용하는 inventory 서버에서 1번 품목의 재고를 확인 명령어

http :8083/inventories/1

 

6. 카프카 메시지 확인

 

명령어

cd kafka

docker-compose exec -it kafka /bin/bash

cd /bin

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