/ddd-petstore

Primary LanguageJava

ddd-petstore

GitPod 접속

https://gitpod.io/#https://github.com/event-storming/ddd-petstore

  • 접속 후 "Terminal > Terminal열기"

유틸리티 설치(httpie)

  • httpie (curl / POSTMAN 대용)
pip install httpie
  • Kafka Download
wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz
tar -xf kafka_2.13-3.1.0.tgz
  • Run Kafka
cd kafka_2.13-3.1.0/
bin/zookeeper-server-start.sh config/zookeeper.properties &
bin/kafka-server-start.sh config/server.properties &
  • Kafka Event 컨슈밍하기 (별도 터미널)
cd kafka_2.13-3.1.0/
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic petstore

Pet Service 기동

  • 새로운 터미널을 열어 Pet 서비스를 기동한다. (8081)
cd pet-domain
mvn install
mvn spring-boot:run
  • 새로운 터미널을 열어 pet을 한 마리 등록해 줍니다.
http :8081/cats name="몽이" energy=1
  • Pet 에 먹이를 한번 줘봅니다.
http PUT "http://localhost:8081/cats/1/feed"
  • Pet 의 에너지가 상승함을 확인합니다.
http "http://localhost:8081/cats/1"
  • Pet 의 털도 한번 가꿔봅니다:
http PUT "http://localhost:8081/cats/1/groom"
  • Pet 의 외모지수가 상승함을 확인합니다.
http "http://localhost:8081/cats/1"

Store Service 기동

  • 또 다른 터미널을 열어서 Store 서비스를 기동합니다. (8083)
cd store-domain
mvn spring-boot:run
  • 유저를 한 명 등록해 줍니다.
http localhost:8083/customers id="park@naver.com" address[zipcode]="123" address[detail]="용인"

8083 유저 등록


입양하기

  • items 에 Pet 도메인에서 등록된 애완동물들이 동기화 되어 있는 것을 확인한다:
http :8083/items
  • 자동으로 등록이 안되었다면 수동으로 등록을 해줘야 한다 (두마리를 등록해본다):
http "http://localhost:8083/items" apperance=1 health=2 price[currency]="KR_WON" price[amount]="100000"
http "http://localhost:8083/items" apperance=2 health=1 price[currency]="EURO" price[amount]=200
  • 아까 등록한 두마리를 입양해본다. 이때는 한번의 Aggregate 이므로 한번에 등록이 되어야 한다.
http :8083/cartItems customer="http://localhost:8083/customers/park@naver.com" items:='["http://localhost:8083/items/1", "http://localhost:8083/items/2"]'

8083 입양

Kafka Event 송출/수신과 관련된 파일들

설정관련

  • pom.xml
  • Application.java 의 @EnableBinding(KafkaProcessor.java)
  • kafka/KafkaProcessor.java
  • resources/application.yaml

구현관련

  • AbstractEvent.java
  • PolicyHandler.java
  • domain event 들: PetReserved.java / PetUpdated.java

Gateway (8080)

cd gateway
mvn spring-boot:run

서비스가 기동된 후, gateway 로 단일화된 주소로 접근이 가능함을 확인합니다:

http localhost:8088/pets         # service url of pet domain
http localhost:8088/cartItems    # service url of store domain

Docker 배포 관련

각 프로젝트 내에는 Dockerfile 이 포함되어있습니다. 이것을 빌드하기 위해서는 우선 maven 빌드로 jar 를 만들어준 후, jar 를 Dockerfile 로 다시 빌드해줍니다:

cd pet-store
mvn package -B
docker build -t pet:v1 .
docker run pet:v1

Kubernetes 에 kafka 설치하기

Helm

Helm(패키지 인스톨러) 설치

  • Helm 3.x 설치(권장)
curl https://raw.githubusercontent.com/helm/helm/master/scripts/get-helm-3 > get_helm.sh
chmod 700 get_helm.sh
./get_helm.sh

Kafka 를 helm 으로 설치

helm repo update
helm repo add bitnami https://charts.bitnami.com/bitnami
helm install my-kafka bitnami/kafka