RabbitMQ 파악하기

메세지 브로커(broker). 메세지를 중개/관리해주는 역할을 수행.

데이터 전달, 논블럭킹 운영, 푸시 알림. 발행/구독, 비동기 처리, 작업 큐 등의 역할.

지원 프로토콜 : AMQP 0-9-1/0-9/0-8/1.0, STOMP, MQTT, HTTP

설치

OS : Mac OS X 10.10.2

RabbitMQ 버전 : 3.4.4

파일 다운로드 

wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.4.4/rabbitmq-server-mac-standalone-3.4.4.tar.gz

tar zxvf rabbitmq-server-mac-standalone-3.4.4.tar.gz

cd rabbitmq_server-3.4.4/

서버 실행

sbin/rabbitmq-server

기본적인 메세지 보내고 받기

파이썬용 AMQP 0-9-1 클라이언트 라이브러리인 Pika 설치

sudo pip install pika==0.9.8

메세지 보내는 파이썬 스크립트 : send.py

# coding=utf-8 #!/usr/bin/env python import pika # rabbitmq에 연결 connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() # hello 큐를 생성 channel.queue_declare(queue='hello') # hello 큐에 Hello World!라는 메세지를 보냄. channel.basic_publish(exchange='', routing_key='hello', body='Hello World!') print " [x] Sent 'Hello World!'" connection.close()

메세지 받는 파이썬 스크립트 : receive.py

# coding=utf-8 #!/usr/bin/env python import pika # rabbitmq에 연결 connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost')) channel = connection.channel() # hello 큐를 생성 channel.queue_declare(queue='hello') # 큐에서 메세지를 받기위한 콜백 함수 def callback(ch, method, properties, body): print " [x] Received %r" % (body,) # 큐에서 지정한 콜백함수로 메세지 받기 channel.basic_consume(callback, queue='hello', no_ack=True) # 큐에서 답변이 올때까지 기다림. print ' [*] Waiting for messages. To exit press CTRL+C' channel.start_consuming()

메세지 보내기

python send.py

메세지 받기

python receive.py

참고

http://www.rabbitmq.com/features.html

http://www.rabbitmq.com/install-standalone-mac.html

http://www.rabbitmq.com/tutorials/tutorial-one-python.html