쿠버네티스에 마이크로서비스 미팅룸 활용

• 쿠버네티스 상에 배포된 마이크로서비스들 간의 Kafka 통신을 실습한다.
• Order 서비스에서 OrderPlaced 이벤트가 발생했을때 Inventory 서비스가 OrderPlaced 이벤트를 수신하여 재고량을 변경(감소)한다.

GitPod에 클라우드 환경 설정하기

• AWS 클라우드에서 Kubernetes가 생성되어 있어야 한다.
• Kubernetes가 생성되어 있지 않으면 해당 Lab(08주 7강. AWS 클라우드에 쿠버네티스생성 실습)을 참조하여 생성한다.

GitPod에 AWS Client Single Sign-On 설정

• 먼저, https://awsacademy.instructure.com/ 에 들어가 Lab을 Start 한다.
• AWS Details 메뉴에서 AWS CLI 옆 'Show'를 클릭한다.
• 나타나는 모든 정보를 텍스트 에디터에 복사해 둔다.
• 터미널에서 아래 내용대로 설정을 진행(매칭되는 정보입력) 한다.

aws configure
AWS Access Key ID [None]: # Value 입력
AWS Secret Access Key [None]: # Value 입력
Default region name [None]: us-east-1
Default output format [None]: json

• 생성된 aws credentials 화일에 aws token을 추가한다.

vi ~/.aws/credentials
# 맨 아래에 텍스트 에디터에 있는 aws_session_token 전체 행을 추가하고 저장한다.

GitPod에 Kubernetes Client Single Sign-On 설정

• 내가 생성한 클러스터 이름으로 설정한다. (Cluster 이름이 abc-eks 일 경우)

aws eks update-kubeconfig --name abc-eks
kubectl get all  # 확인

마이크로서비스 배포하기

• 주문서비스와 상품서비스를 쿠버네티스에 배포한다.

order 서비스 배포

cd order
mvn package 
docker image build -t MY-DOCKER-ID/order:v0.1 .
docker login 
docker push 
docker push MY-DOCKER-ID/order:v0.1

cd kubernetes
# 19라인을 내 이미지 이름(MY-DOCKER-ID/order:v0.1) 으로 수정
kubectl apply -f deployment.yaml
kubectl apply -f servce.yaml

inventory 서비스 배포

cd inventory
mvn package 
docker image build -t MY-DOCKER-ID/product:v0.1 .
docker login 
docker push 
docker push MY-DOCKER-ID/product:v0.1

cd kubernetes
# 19라인을 내 이미지 이름(MY-DOCKER-ID/product:v0.1) 으로 수정
kubectl apply -f deployment.yaml
kubectl apply -f servce.yaml

쿠버네티스에 미팅룸(kafka) 설치

• 아래 커맨드를 복사하여 Kafka 설치 전, Zookeeper를 먼저 설치한다.

kubectl apply -f https://raw.githubusercontent.com/acmexii/demo/master/edu/zookeeper.yaml

• 조금 뒤 아래 커맨드로 Kafka를 이어서 설치한다.

kubectl apply -f https://raw.githubusercontent.com/acmexii/demo/master/edu/kafka.yaml

• 잠시뒤, 아래 Command로 Kubernetes에 설치된 Kafka Stack을 확인할 수 있다.

kubectl get all

Kafka 메시지 확인하기

kubectl run my-kafka-client --restart='Never' --image docker.io/bitnami/kafka:2.8.0-debian-10-r0 --command -- sleep infinity
kubectl exec --tty -i my-kafka-client -- bash

# CONSUMER:
kafka-console-consumer.sh --bootstrap-server my-kafka:9092 --topic labshoppubsub --from-beginning

마이크로서비스 테스트

• 먼저, 테스트에 필요한 클라이언트를 쿠버네티스에 설치하고 접속한다.

kubectl apply -f - <<EOF
apiVersion: v1
kind: Pod
metadata:
  name: siege
spec:
  containers:
  - name: siege
    image: apexacme/siege-nginx
EOF

• 생성한 클라이언트로 접속한다.

kubectl exec -it siege -c siege -- /bin/bash

쿠버네티스 상에서의 Pub/Sub을 테스트한다.

• 상품을 등록하고, 등록한 상품을 주문해 본다.
• 카프카 클라이언트로 토픽상에 생성되는 도메인 이벤트를 확인한다.

http http://inventory:8080/inventories id=1 stock=10
http http://order:8080/orders productId=1 qty=5
http http://inventory:8080/inventories/1