Connection RabbitMQ

RabbitMQ là một phần mềm cho phép xây dựng Message Queue theo protocol AMQP và khá thông dụng trên thế giới. Để kết nối đến RabbitMQ trên Python, ta sẽ sử dụng thư viện pika.

Cài đặt

Có thể xem thêm về hướng dẫn cài đặt thư viện này tại https://pika.readthedocs.org/en/0.10.0/

Đơn giản cài thông qua pip là:

$ sudo pip install pika

Gởi một message đến Server - Provider

Ví dụ để gởi một message đến server

Ví dụ:

import pika

connection = pika.BlockingConnection(pika.Connectio
nParameters('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()

Để gởi một message, chúng ta cần kết nối đến server và khai báo một channel, ở đây là channel có tên là hello . Sau khi khai báo channel, tao tiến hành gởi message có nội dung Hello World! thông qua channel này, kèm theo khai báo routing_key là hello . Routing Key sẽ giúp điều hướng message này đến đúng các worker được khai báo nhận message theo routing key (Consumer)

Nhận message - Consumer

Ở bước trước, ta đã tạo một message lên queue. Ở bước này, ta sẽ khai báo một worker xử lý các message nhận được từ channel hello.

import pika

connection = pika.BlockingConnection(pika.Connectio
nParameters(host = 'localhost'))
channel = connection.channel()

channel.queue_declare(queue = 'hello')

print ' [*] Waiting for messages. To exit press CTR L+C'

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

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

channel.start_consuming()

Đoạn code này cũng có phần khai báo connection, channel. Tuy nhiên, vì là consumer nên sẽ sử dụng phương thức basic_consume để lắng nghe trên queue hello , khi có message đến sẽ gọi hàm callback() để xử lý. Trong trường hợp ví dụ này thì callback chỉ đơn giản là hiển thị chuỗi thông báo đã nhận được message.

Tìm hiểu thêm về RabbitMQ và Pika

Nội dung chương này không có ý định giới thiệu tất cả khái niệm của AMQP cũng như RabbitMQ mà chủ yếu giới thiệu thư viện pika để làm việc với RabbitMQ. Bạn có thể tiếp tục theo dõi các hướng dẫn về khái niệm của RabbitMQ và Pika tại website chính thức của RabbitMQ.

Tham khảo thêm tại: https://www.rabbitmq.com/tutorials/tutorial-one-python.html

Follower me

PreviousConnection MemcachedNextRestful client

Last updated