AMQP
MQ(Message Queue) Protocol인 AMQP(Advanced Message Queuing Protocol)를 분석한다.
1. AMQP (Advanced Message Queuing Protocol)
AMQP는 표준 MQ Protocol으로써 App사이의 Message를 전달할 때 Message를 어떻게 Queuing하고 Routing 할지 정의하고 있다. AMQP는 다양한 Message 전달 옵션을 정의하고 있기 때문에 많은 App들이 AMQP를 이용하여 Message 전달 규칙을 설계하고 이용하고 있다. RabbitMQ는 AMQP를 제공하는 대표적인 MOM(Message-Oriented Middleware)으로써 많은 곳에서 이용되고 있다.
![[Figure 1] AMQP Architecture](images/amqp-architecture.png)
[Figure 1] AMQP Architecture
[Figure 1]은 AMQP의 Architecture를 나타내고 있다. AMQP는 Producer, Consumer, Broker로 구성되어 있다. Producer는 Message를 생산하여 전송하는 주체이고, Consumer는 Producer가 생산한 Message를 받아서 소비하는 주체이다. Broker는 Producer와 Consumer 사이에서 Message를 중개하는 역할을 수행한다. Broker는 다시 Exchange와 Queue로 구성되어 있다.
Producer는 임의의 Exchange를 선택하여 자유롭게 Message를 전송할 수 있다. Producer는 Exchange에게 Message와 함께 Message Routing을 위한 Routing Key를 같이 전달한다. Exchange는 Routing Key를 이용하여 해당 Message를 Filtering 하거나, Queue 또는 다른 Exchange에게 Routing 한다. Exchange는 자신과 연결되어 있는 Queue 또는 Exchange에게만 Message를 전달 할 수 있는데, 이러한 연결 과정을 Binding이라고 표현한다.
Queue는 Consumer에게 전달될 Message를 임시로 저장하는 곳이다. Broker는 Queue의 Message를 Consumer에게 전송 한뒤 바로 삭제하지 않고, Consumer에게 ACK Message를 받은 후에 삭제 한다. Broker는 Consumer에게 ACK Message를 받지 못하면 Broker에 설정된 일정 횟수만큼 Message를 재전송한다. 여러번 Message를 전송한 후에도 ACK Message를 받지 못하면 Message를 Queue에서 삭제하거나, 다시 Exchange로 보내어 다른 Consumer에게 전달 되도록 할 수 있다. 하나의 Queue에게 다수의 Consumer가 붙으면 Message는 Round-Robin 알고리즘에 따라 Consumer에게 전달된다. 이러한 특징은 Consumer를 쉽게 Scale-Out 할 수 있도록 만든다.
1.1 Exchange Type
Exchange는 Routing 규칙에 따라서 Fanout, Direct, Topic, Header 4가지 Type을 지원한다.
1.1.1. Direct
![[Figure 2] Direct Type Exchange](images/amqp-exchange-direct.png)
[Figure 2] Direct Type Exchange
Direct Exchange는 하나의 Queue 또는 Exchange에게 Message를 Unicast하는 Exchange이다. Unicast의 기준은 Message와 함께 전달되는 Routing Key이다. Direct Exchange와 Binding하기 위해서는 Direct Exchange에게 Routing Key를 넘겨주어야 한다. [Figure 2]에서는 Binding시 Direct Exchange에게 넘겨준 Routing Key를 Binding Key라고 표현하고 있다. Direct Exchange는 Message와 함께온 Routing Key와 동일한 Binding Key를 갖고 있는 Queue 또는 Exchange에게 해당 Message를 전달한다.
1.1.2. Fanout
[Figure 3] Direct Type Exchange
Fanout Exchange는 자신과 Binding된 모든 Queue에게 Message를 Broadcast하는 Exchange이다. [Figure 3]에서 Exchange A는 자신과 Binding된 Queue A, Queue B, Exchange B에게 자신이 받은 모든 Message를 전달하여 Brodcast를 수행한다.
1.1.3. Topic
![[Figure 4] Topic Type Exchange](images/amqp-exchange-topic.png)
[Figure 4] Topic Type Exchange
Topic Exchange는 다수의 Queue 또는 Exchange에게 Message를 Multicast하는 Exchange이다. Mulicast의 기준은 Message와 함께 전달되는 Routing Key이다. Topic Exchange와 Binding하기 위해서는 Topic Exchange에게 패턴이 포함된 Routing Key를 넘겨주어야 한다. [Figure 4]에서는 Binding시 Topic Exchange에게 넘겨준 패턴이 포함된 Routing Key를 Binding Key라고 표현하고 있다. 이용하는 패턴은 *과 #이다. *은 하나의 문자로 치환이 가능하다는 의미이다. #은 아무것도 없는 문자부터 문자열까지 어떠한 문자들과도 치환이 가능하다는 의미이다. Topic Exchange는 Message와 함께온 Routing Key에 부합하는 Binding Key가 있는 모든 Queue 또는 Exchange에게 Message를 전달한다.
1.1.4. Headers
![[Figure 5] Headers Type Exchange](images/amqp-exchange-headers.png)
[Figure 5] Headers Type Exchange
Headers Exchange는 다수의 Queue 또는 Exchange에게 Message를 Multicast하는 Exchange이다. Mulicast의 기준은 Message Header에 포함되어 있는 Key, Value 값이다. Headers Exchange와 Binding하기 위해서는 Message Header에 포함될 Key, Value 값을 넘겨주어야 한다. [Figure 5]에서 Binding시 Headers Exchange에게 넘겨주는 Message Header를 Binding Header라고 표현하고 있다. Headers Exchange는 Message Header의 Key, Value 값과 동일한 Binding Header가 있는 모든 Queue 또는 Exchange에게 Message를 전달한다.
Headers Exchange는 x-match라는 Option을 제공하는데 x-match는 ‘all’과 ‘any’ 2가지 값이 존재한다. ‘all’은 Message Header에 있는 모든 Key, Value 값이 Binding시에 전달 받은 Key, Value 값과 일치하는 경우에만 해당 Queue 또는 Exchange에게 Messsage를 전달한다. ‘any’는 Message Header에 있는 Key, Value값의 일부만 Binding시에 전달 받은 Key, Value과 일치하더라도 해당 Queue 또는 Exchange에게 Message를 전달한다.