[Spring Cloud] Spring Cloud Bus와 RabbitMQ를 사용하여 Config 정보 반영하기

Configuration 서버에서 어떠한 값을 변경시켰을 때 microservices에 반영시키기 위해서 이전에는 actuator를 사용했다.

하지만 이 방법은 여러 개의 마이크로서비스가 존재한다면 각각의 마이크로서비스마다 수동으로 refresh 시켜주어야하기 때문에 상당히 번거롭다.

 

이러한 방법을 개선시켜주는 것이 Spring Cloud Bus 이다. 

 

❓Spring Cloud Bus란 ?

분산시스템의 노드(microservice)를 메시지 브로커(RabbitMQ)와 연결하여 상태 및 구성에 대한 변경사항을 연결된 노드에게 전달해주는 프레임워크이다. 

 

💡 메시지 브로커란?

👉 애플리케이션, 시스템 및 서비스가 서로 간에 통신하고 정보를 교환할 수 있도록 해주는 소프트웨어로 메시지를 검증, 저장, 라우팅하고 이를 적절한 대상에게 전달한다.

 

 

RabbitMQ 사용하기 

 

 

💡 RabbitMQ란?

 

AMQP(Advanced Message Queuing Protocol)를 따르는 오픈소스 메시지 브로커로서 Message Queue를 통해 원하는 사용자에게 메시지를 전달한다.

• Producer : 메시지를 보낸다.
• Broker : 중개자 역할을 수행하며 웹 애플리케이션 서버의 로드 및 전달 시간을 줄여준다. 
• Consumer : 메시지를 수신한다.

 

 

RabbitMQ를 예제에서 사용하면 위와 같다. 

 

 

AMQP 사용하기 

 

RabbitMQ 설치를 마친 후이다. 

 

1️⃣ Dependencies 추가 ➔ Config server, Users Microservice, Gateway Service

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

 

2️⃣ application.yml 수정 ➔ Config server, Users Microservice, Gateway Service

spring:
  application:
    name: apigateway-service
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest

 

RabbitMQ에 접속하기 위한 정보를 추가한다. 

management:
  endpoints:
    web:
      exposure:
        include: refresh, beans, health, httptrace, busrefresh

busrefresh를 추가한다.

config-server에 변경 요청사항이 들어오면 RabbitMQ에 요청사항을 받았음을 통보한다.

RabbitMQ에 등록된 다른 마이크로서비스에게 그 정보를 일괄적으로 push한다.

 

3️⃣ 테스트 하기 

1. Start RabbitMQ Server
2. Start Spring Cloud Config Service
3. Start Eureka Discovery Service
4. Start Spring Cloud Gateway Service
5. Start Users Microservice

 

 

Spring Cloud Bus 테스트

RabbitMQ를 실행시킨 후 주소창에 127.0.0.1:15672를 입력하면 잘 접속되는 것을 확인할 수 있다.

 

config-service를 실행시키면 RabbitMQ가 잘 등록되었고, 5672번으로 접속되는 것을 확인할 수 있다. 

---

현재, config-service에 있는 application.yml파일이다.

이 파일에 있는 token.secret 값을 다른 마이크로서비스에서도 사용할 수 있게끔 해볼 것이다.

 

 

Postman을 이용하여 유저 등록을 한 후 로그인을 해서 token 값을 얻는다.

token 값을 health_check 후 확인해보면 user_token_native_application_changed_#1 을 가져오는 것을 알 수 있다. 

---

이제 #1을 #2로 변경하여 변경된 사항이 제대로 반영되는지 확인해보자. 

 

busrefresh를 전달하게 되면 반환값으로 204 No Content을 얻게 된다. 

user-service를 업데이트했으므로 로그를 확인해보면 갱신되었다는 내용을 출력하는 것을 볼 수 있다. 

 

user-service에서 호출했지만 apigateway-service에서도 동일한 메시지를 출력하는 것을 확인할 수 있다.

이를 통해 user microservice에 변경되었음을 알렸을 때 rabbitMQ에 연결되어 있는 다른 클라이언트 모든 곳에 해당하는 메시지가 푸시 기능으로 전달되었음을 알 수 있다. 

 

 

 

참고

https://www.ibm.com/kr-ko/topics/message-brokers

https://www.rabbitmq.com/tutorials/tutorial-one-java.html

https://www.cloudamqp.com/blog/part1-rabbitmq-for-beginners-what-is-rabbitmq.html