[RMQ] Python으로 배우는 RabbitMQ 튜토리얼(1)

오픈소스/RabbitMQ

[RMQ] Python으로 배우는 RabbitMQ 튜토리얼(1) - Hello World

sangyeon 2022. 1. 11. 15:22

728x90

RabbitMQ는 메세징큐 기능을 수행하는 오픈소스이다.

카프카와 동일한 기능을 제공하는 오픈소스 제품이다.

이번 글에서는 Docker로 RabbitMQ 이미지를 다운받아 실행하여 RabbitMQ에 나와있는 튜토리얼들을 수행해보려고 한다.

https://www.rabbitmq.com/getstarted.html

여러 언어 중에 Python을 선택해 보았다.

1. 사전 준비 사항

우선 위 실습을 따라하려면 사전에 RabbitMQ가 5672 포트로 설치되어야 한다.

나 같은 경우는 Oracle Linux 장비에 Docker로 RabbitMQ를 실행하였다.

1-1. Docker로 RabbitMQ 다운받아 백그라운드로 실행

root@master:~# docker run -it --rm -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.9-management
Unable to find image 'rabbitmq:3.9-management' locally
3.9-management: Pulling from library/rabbitmq
ea362f368469: Pull complete
8128e02f0caa: Pull complete
190ad14731bd: Pull complete
77793ffcdff3: Pull complete
2ded75d28575: Pull complete
38fe6cea12ab: Pull complete
ec228f486d8e: Pull complete
6e93459f9f24: Pull complete
1a076196fb8b: Pull complete
975e2d61b91e: Pull complete
Digest: sha256:821c31bdb35240822e9a7b95eb57e2aaa9590dc367b0598b58efd15fb037fc8c
Status: Downloaded newer image for rabbitmq:3.9-management

1-2. Python3 설치 및 버전 확인

root@master:~# sudo apt-get install python3

..

root@master:~# python3 --version
Python 3.8.10

1-3. AMQP(Advanced Message Queing Protocol) 사용을 위한 PIKA 라이브러리 설치

파이썬에서 메세징 큐 프로토콜을 사용하기 위해 PIKA 라이브러리를 사용해야 한다.

root@master:~/python# apt install python3-pip
Reading package lists... Done
Building dependency tree
Reading state information... Done
...

root@master:~/python# pip install pika
Collecting pika
  Downloading pika-1.2.0-py2.py3-none-any.whl (154 kB)
     |████████████████████████████████| 154 kB 9.8 MB/s
Installing collected packages: pika
Successfully installed pika-1.2.0

root@master:~/python# python3 -c 'import pika'
> 아무런 메세지가 없다면 정상적으로 pika import가 된다는 뜻

2. Python 소스코드 작성

2-1. 메세지 제공자(Producer)

- send.py

#!/usr/bin/env python
import pika

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

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

> 1회성으로 메세지를 보내고 연결을 끊는다.

2-2. 메세지 소비자(Consumer)

- receive.py

#!/usr/bin/env python
import pika

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

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

channel.basic_consume('hello',
                      callback,
                      auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

위 예제의 그림은 아래와 같다.