Institute of Information Science - University of Miskolc

This page is read only. You can view the source, but not change it. Ask your administrator if you think this is wrong.

===== RabbitMQ példa ===== 

Docker környezetben futtatható példa.

<code bash>
git clone https://github.com/knehez/isi.git
cd isi/rabbitmq-python
docker-compose up -d rabbitmq
</code>

Az alábbi //docker-compose.yml// definiál egy szolgáltatást a rabbitmq hivatalos docker image-el, kiegészítve a management web-es felülettel, ami a 15672-es porton érhető el.

<code yml>
version: '3.7'
services:
  rabbitmq:
    image: 'rabbitmq:3-management'
    ports:
        - 5672:5672
        - 15672:15672
</code>

Indítsuk el a producert:

<code>
docker-compose up producer
</code>

Majd a cunsumert:

<code>
docker-compose up consumer
</code>

**consumer.py**

<code python>
import pika
import sys
import os

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

channel.queue_declare(queue='hello')


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


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

print(' [*] Waiting for messages. ')

while (True):
    channel.start_consuming()
</code>

**producer.py**

<code python>
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='rabbitmq'))
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()
</code>