docker-compose 환경 내 kafka와 sync를 위한 DOCKERIZE 적용

[cotchan]

이슈

• 현재 프로젝트 실행 시 zookeeper, kafka, api-server, chat-server 4개의 서비스가 실행됨
• 이 때 chat-server가 카프카를 사용하므로 zookeeper <- kafka <- chat-server의 의존성이 존재함
• 이를 위해 docker-compose.yml에 depends_on 속성을 기입하였지만 간헐적으로 chat-server가 kafka보다 먼저 실행되면서 disconnected 에러로 죽는 현상 발생

[cotchan]

해결

원인

• depends_on은 단지 컨테이너가 시작되는 순서만 컨트롤할 뿐, 컨테이너 안의 서비스가 "ready"(실제 실행 가능한 상태)인지 아닌지에 대해서는 관여하지 않습니다.
• depends_on은 컨테이너들을 일단 순서에 맞게 시작만 시켜놓고 그 뒤는 신경쓰지 않음

해결방법: DOCKERIZE

• 실행순서 동기화를 위해 DOCKERIZE 적용
• https://github.com/jwilder/dockerize

사용방법

• 먼저 올바른 실행순서를 위해 대기하고자 하는 컨테이너에 dockerize를 사용할 수 있게 설치해야 합니다.

ENV DOCKERIZE_VERSION v0.6.1
RUN wget https://github.com/jwilder/dockerize/releases/download/$DOCKERIZE_VERSION/dockerize-alpine-linux-amd64-$DOCKERIZE_VERSION.tar.gz \
    && tar -C /usr/local/bin -xzvf dockerize-alpine-linux-amd64-$DOCKERIZE_VERSION.tar.gz \
    && rm dockerize-alpine-linux-amd64-$DOCKERIZE_VERSION.tar.gz

• 아래 명령은 설치된 dockerize 모듈을 통해 kafka 컨테이너의 9095 포트가 연결될 때까지 즉, kafka 컨테이너가 구동 준비를 완료할 때까지 기다린 후 서버를 실행시킵니다.

#!/bin/bash

echo "wait kafka server"
dockerize -wait tcp://kafka:9095 -timeout 20s

적용예시

FROM openjdk:11 as builder

COPY ./ ./

RUN chmod +x ./gradlew

RUN ./gradlew clean :chat-server:build -x test

FROM openjdk:11

ENV DOCKERIZE_VERSION v0.6.1
RUN wget https://github.com/jwilder/dockerize/releases/download/$DOCKERIZE_VERSION/dockerize-alpine-linux-amd64-$DOCKERIZE_VERSION.tar.gz \
    && tar -C /usr/local/bin -xzvf dockerize-alpine-linux-amd64-$DOCKERIZE_VERSION.tar.gz \
    && rm dockerize-alpine-linux-amd64-$DOCKERIZE_VERSION.tar.gz

WORKDIR /app

COPY --from=builder chat-server/build/libs/*.jar ./chat-server.jar
COPY chat-server/docker-entrypoint.sh ./docker-entrypoint.sh

RUN chmod +x ./docker-entrypoint.sh
ENTRYPOINT ./docker-entrypoint.sh

• docker-entrypoint.sh

#!/bin/bash

echo "wait kafka server"
dockerize -wait tcp://kafka:9095 -timeout 20s

echo "start chat-server"
java -jar ./chat-server.jar

실행결과

• dockerize를 적용한 컨테이너 로그를 보면 아래와 같이 대기하는 것을 확인할 수 있습니다.

chat   | wait kafka server
chat   | 2022/06/19 01:39:31 Waiting for: tcp://kafka:9095
chat   | 2022/06/19 01:39:31 Problem with dial: dial tcp 172.18.0.4:9095: connect: connection refused. Sleeping 1s

---

• 참고
  • https://jupiny.com/2016/11/13/conrtrol-container-startup-order-in-compose/