표준 AMQP 메시지 브로커 소프트웨어
- 환경
- Mac OS X 10.10.4 (Yosemite)
- 다운로드
- Mac Standalone @ 공식 홈페이지
- 설치 후
- Web Console 활성화
sbin/rabbitmq-plugins enable rabbitmq_management
- RabbitMQ 실행
sbin/rabbitmq-server
- Web Console 접속
- http://localhost:15672
- username : guest
- password : guest
- Web Console 활성화
REST API 서버를 이용해 간단하게 요청을 받으면 RabbitMQ에 데이터를 넣은 후, Worker를 이용해 MySQL 서버에 데이터를 넣어주는 샘플 프로젝트를 진행했다.
- Express를 이용해 간단한 REST API Server를 구축했다.
- 서버는 다음과 같이 동작한다.
- 먼저 RabbitMQ에 연결한 뒤,
amqp.connect('amqp://guest:guest@localhost:5672', function(err, conn) {
- 정상적으로 연결되면 Channel을 생성한다.
conn.createChannel(function(err, ch) {
- 정상적으로 Channel이 생성되면 서버가 실행되고,
localhost:8080/queue/{message}에 POST Request를 보내면expressTest라는 Queue에 메시지를 전송한다.
- 먼저 RabbitMQ에 연결한 뒤,
- Worker는 다음과 같이 동작한다.
- 서버와 마찬가지로, 먼저 RabbitMQ에 연결한 뒤,
amqp.connect('amqp://guest:guest@localhost:5672', function(err, conn) {
- Channel을 생성한 뒤, Database에 연결하고, 정상적으로 연결되면 Queue에 연결해서 메시지를 받아온다.
- 메시지를 받게되면, Database에 받아온 메시지를 Insert하고, Queue에 메시지가 올때까지 기다린다.
- 서버와 마찬가지로, 먼저 RabbitMQ에 연결한 뒤,
- Worker가 죽으면? (메시지가 정상적으로 처리되었는가?)
- Message acknowledgment (ack)
- Message Consumer가 _ack_을 RabbitMQ에 전송해주면 해당 메시지를 Queue에서 제거함.
- ch.consume에서
noAck : false로 바꾸고, 메시지를 처리한 뒤ch.ack(msg)를 해주면 해결할 수 있다.
- Message acknowledgment (ack)
- RabbitMQ 서버가 죽으면? (Message durability)
- Queue를 durable 하게 설정
ch.assertQueue('expressTest', {durable: true});- 문제는, 현재 코드를 보면 expressTest Queue가
durable:false로 설정되어있음.- Queue 이름을 바꿔줘야한다.
ch.assertQueue('expressTestDurable', {durable: true});- Server와 Worker 모두에서 위와 같이 Channel을
durable: true로 바꿔줘야한다.
- 메시지를 Queue에 전송할때
persistent로 표시하자.ch.sendToQueue('expressTestDurable', new Buffer(msg), {persistent: true});- 하지만,
persistent로 표시하더라도 메시지가 지워지지 않는다는것을 보장하지는 않는다.- RabbitMQ가 메시지를 받고 저장하기까지 약간의 시간이 소요됨.
- RabbitMQ가 모든 메시지에 대해서
fsync를 하지 않음.- Cache에만 저장되고, 실제로는 Disk에 저장되지 않는 경우도 있음.
- 더 높은 보장성을 원한다면 **publisher confirm(Publisher Acknowledgements)**을 사용하면 된다.
- Queue를 durable 하게 설정