RabbitMQ 기본 개념, AMQP의 정의

Producer(생산자)가 Message를 Queue에 넣어두면, Consumer가 Message를 가져와 처리하는 방식입니다.

굳이 이런 시스템이 필요할까..? 한번 더 거치게 되면 더 느려지는게 아닌가? 라는 의문이 들 수 있습니다. 위에서도 언급한바 있지만 다시 한번 말씀드리자면, Client와 동기방식으로 많은 데이터 통신을 하게 되면 병목현상이 생기게되고, 서버의 성능이 저하됩니다. 이런 현상을 막고자하여 또 하나의 미들웨어에 메시지를 위임하여 순차적으로 처리를 하는 것 입니다.

일반적으로 메시징 시스템이나 RabbitMQ 에서 사용하는 컴퓨터 용어

Producing : 메시지를 전송한다는 의미

producer : 메시지들을 전송하는 프로그램을 producer 라 부릅니다. 
Queue: mailbox를 의미하며 RabbitMQ 시스템 내에 위치. consumer 대신에 RabbitMQ가 보관하는 메시지 버퍼

외부연동 서버에서 이 비동기 처리를 쉽게 구현하기 위하여 MQ(Message Queuing)를 사용한다.

AMQP

인스턴스가 데이터를 서로 교환할 때 사용하는 방법

MQ를 오픈 소스에 기반한 표준 프로토콜이 AMQP(Advanced Message Queuing Protocol)이다.

AMQP 자체가 프로토콜을 의미하기 때문에 이 프로토콜을 구현한 MQ제품들은 여러가지가 있으며 그 중 하나가 RabbitMQ이다.

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

Exchange : Publisher(Producer)로부터 수신한 메시지를 큐에 분배하는 라우터의 역할

Queue : 메시지를 메모리나 디스크에 저장했다가 Consumer에게 메시지를 전달하는 역할

Binding : Exchange와 Queue의 관계를 정의

 Exchange Type 

 메시지를 어떠한 방법으로 라우팅할지 결정하는 일종의 알고리즘

1) Direct exchange

1:1 관계로 Unicast 방식에 적합, 운드 로빈 방식으로 여러 workers(Consumer)간 task를 분리

Exchange에 바인딩 된 Queue 중에서 메시지의 라우팅 키와 매핑되어 있는 Queue로 메시지를 전달한다. 

2) Fanout exchange

메시지의 라우팅 키를 무시하고 Exchange에 바인딩 된 모든 Queue에 메시지를 전달한다. 

1:N 관계로 메시지를 브로드캐스트하는 용도로 사용된다.

3) Topic exchange

Exchange에 바인딩 된 Queue 중에서 메시지의 라우팅 키가 패턴에 맞는 Queue에게 모두 메시지를 전달, Multicast 방식에 적합하다.

4) Headers exchange

라우팅 키 대신 메시지 헤더에 여러 속성들을 더해 속성들이 매칭되는 큐에 메시지를 전달한다.

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

RabbitMQ의  Exchange Type 

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

1) Direct exchange - (Empty string) and amq.direct

 참고) AMQP 정의 : 바인딩 된 Queue 중에서 메시지의 라우팅 키와 매핑되어 있는 Queue로 메시지를 전달(1:1)

2) Fanout exchange - amq.fanout

 참고) AMQP 정의 : 메시지의 라우팅 키를 무시하고 Exchange에 바인딩 된 모든 Queue에 메시지를 전달(1:N)

3) Topic exchange -amq.topic

 참고) AMQP 정의 : Exchange에 바인딩 된 Queue 중에서 메시지의 라우팅 키가 패턴에 맞는 Queue에게 모두 메시지를 전달(Multicast)

4) Headers exchange - amq.match (and amq.headers in RabbitMQ)

 참고) AMQP 정의 : 라우팅 키 대신 메시지 헤더에 여러 속성들을 더해 속성들이 매칭되는 큐에 메시지를 전달

https://www.evernote.com/shard/s479/sh/ddbec3f0-84fd-45c6-87d7-952a672341f1/ce289238f23c99a9b2e1a45b41c770a9

출처: http://itstory.tk/entry/Message-Queue-RabbitMQ란 [덕's IT Story]
출처: http://heowc.tistory.com/35 [허원철의 개발 블로그]

출처: https://m.blog.naver.com/tmondev/220419853534