티스토리 뷰

 

 

작업환경 Ubuntu

 Python,PiP설치 (http://experiences.tistory.com/3)

RabbitMQ 설치 (http://experiences.tistory.com/2)

관리자 Page 에서 큐생성

 

pika 설치

pip3 install pika 

 

send.py 파일 만들기 (https://www.rabbitmq.com/tutorials/tutorial-one-python.html)

vi send.py

 
#!/usr/bin/env python
import pika
import sys
qbody = sys.argv[1]

#connection = pika.BlockingConnection()
connection = pika.BlockingConnection(pika.ConnectionParameters(
               'localhost'))
channel = connection.channel()
channel.queue_declare(queue='qlist')
channel.basic_publish(exchange='',
                      routing_key='qlist',
                        body=qbody)
#                      body='insert qlist data!2')
print(" [x] Sent " + qbody )
connection.close()

 

첫번째 할일은 큐에 메세지 보내기 위해 RabbitMQ서버와 연결 설정 하는것 입니다.

소스에는 localhost 연결 되어 있고 다른서버 연결시 hostname , IP 입력 하면 됩니다.

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

큐생성 ( 없으면 생성 , 있으면 그대로 이용)

channel.queue_declare(queue='qlist')

큐에 메세지 전송 (channel.basic_publish)
routing_key는 큐의 이름 ( 교환키 있어야 메세지 넣을수 있음) , body는 메세지 내용 

channel.basic_publish(exchange='', routing_key='qlist', body='insert data 1')

 

RabbitMQ서버 접속 종료

connection.close()

큐의  리스트 확인 qlist의 2개의 메세지가 있음

python2 send.py  ok1

python2 send.py  ok2

 

sudo rabbitmqctl list_queues
Listing queues ...
qlist 2

UI에서 확인

웹브라우저로 http://serverip:15672/  접속

Queues 클릭  Name 의 Qlist 클릭 Get messages 에  Messages 10기입 후 GetMessage 클릭 하면 메세지를 볼수 있다.ㅣ

 


 

 

 

 

 

'Etc > RabbitMQ' 카테고리의 다른 글

RabbitMQ 에 Python 이용하여 데이터 가져오기  (0) 2016.02.25
RabbitMQ 에 Python 이용하여 데이터 보내기  (0) 2016.02.24
RabbitMQ 설치하기  (0) 2016.02.23
댓글
댓글쓰기 폼