Spring Boot + RabbitMQ

RabbitMQ for windows

동기? 비동기?

---

AMQP

• 프로그래밍에서 MQ는 프로세스 또는 프로그램 인스턴스가 데이터를 서로 교환할 때 사용하는 방법을 말합니다.
• 이러한 MQ의 오픈 소스에 기반한 표준 프로토콜이 AMQP(Advanced Message Queuing Protocol)입니다.
• AMQP 자체가 프로토콜을 의미하기 때문에 이 프로토콜을 구현한 MQ 제품들은 여러가지가 있으며 그 중 하나가 RabbitMQ입니다.

AMQP의 구성요소와 라우팅 알고리즘

AMQP의 라우팅 모델은 Exchange와 Queue 그리고 Binding으로 구성

• Exchange는 publisher(Producer)로부터 수신한 메세지를 큐에 분배하는 라우터의 역할을 합니다.
• Queue는 메시지를 메모리나 디스크에 저장했다가 Customer에게 메시지를 전달하는 역할을 합니다.
• Binding은 Exchange와 Queue의 관계를 정의한 것을 말합니다.
• Exchange Type은 메시지를 어떠한 방법으로 라우팅할지 결정하는 일종의 알고리즘을 말하며
  AMQP에서는 다음과 같이 Exchange Type을 정의하고 있습니다.

Exchange Type	정의
Direct	Exchange에 바인딩 된 큐 중에서 메시지의 라우팅 키와 매핑되어 있는 큐로 메시지를 전달합니다.. 1:1 관계로 Unicast 방식에 적합함, 주로 RR 방식으로 여러 Customers간 task 분리에 사용됩니다.
Fanout	메시지의 라우팅 키를 무시하고 Exchange에 바인딩 된 모든 큐에 메시지를 전달합니다. 1:N 관계로 메시지를 브로드캐스팅하는 용도로 사용됩니다.
Topic	Exchange에 바인딩 된 큐 중에서 메시지의 라우팅 키가 패턴에 맞는 큐에게 모두 메시지를 전달합니다. Multicast 방식에 적합합니다.
Headers	라우팅 키 대신 메시지 헤더에 여러 속성들을 더해 속성들이 매칭되는 큐에 메시지를 전달합니다.

---

이해를 돕기 위한 Exchange Type Image

• Direct Exchange

• Fanout Exchange

• Topic Exchange

---

RabbitMQ 기본 개념

RabbitMQ는 AMQP를 구현한 오픈 소스 메시지 브로커 소프트웨어로
Publisher(Producer)로부터 메시지를 받아 Customer에게 라우트하는 것이 주된 역할입니다.
이를 이용하면 작업 큐, 발행 및 구독, 라우팅, 주제, 원격 프로시저 호출 등의 모델을 구현할 수 있습니다.

RabbitMQ의 Exchange Type

RabbitMQ는 AMQP를 구현하였기 때문에 아래의 표와 같이 Exchange Type이 미리 선언된 이름으로 정의되어 있습니다.
참고로 작업 큐는 Direct exchange가 적합합니다.

이름	RabbitMQ에 기본적으로 미리 선언된 이름
Direct	(Empty String) and amq.direct
Fanout	amq.fanout
Topic	amq.topic
Headers	amq.match (and amq.headers in RabbitMQ)

시작하기

Spring AMQP 라이브러리 준비하기

RabbitMQ를 사용하기 위해서 다음 라이브러리를 pom.xml에 추가합니다.
만약 프로젝트에 이미 Spring core 등 라이브러리가 추가되어 있다면 버전에 따라 AMQP 버전을 다르게 가져가야 합니다.
AMQP 1.4.x.RELEASE는 Spring 4.x에 의존하고, AMQP 1.3.x.RELEASE는 Spring 3.x에 의존하기 때문입니다.

• pom.xml

<dependencies>
    <dependency>
        <groupId>org.springframework.amqp</groupId>
        <artifactId>spring-rabbit</artifactId>
        <version>2.0.3.RELEASE</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.3.2</version>
    </dependency>

    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-tomcat</artifactId>
        <scope>provided</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>

    <!--<dependency>-->
        <!--<groupId>ch.qos.logback</groupId>-->
        <!--<artifactId>logback-classic</artifactId>-->
        <!--<version>1.2.3</version>-->
    <!--</dependency>-->
</dependencies>

사용된 도구

• Spring Boot : 웹 프레임워크
• Maven : 의존성 관리 프로그램
• Tomcat : 웹 애플리케이션 서버
• RabbitMQ management : 모니터링

저자

• 조민국 - MinGOODdev

감사 인사

• RabbitMQ와 Spring AMQP를 이용한 간단한 작업 큐 만들기
• 도서 - Pro Spring Boot

---