博客

RabbitMQ有哪些主要的消息传递模式？

  • Post category:云计算

RabbitMQ是一个灵活的消息代理，支持多种消息传递模式。以下是RabbitMQ主要的消息传递模式的完整攻略：

  1. 主要的消息传递模式

RabbitMQ主要的消息传递模式包括：

  • 简单模式（Simple Mode）
  • 工作队列模式（Work Queue Mode）
  • 发布订阅模式（Publish/Subscribe Mode）
  • 路由模式（Routing Mode）
  • 主题模式（Topic Mode）

这些模式都有不同的应用场景和特点，可以根据实际需求选择合适的模式。

  1. 示例说明

以下是使用工作队列模式和/订阅模式的示例说明：

工作队列模式示例：

import pika
import time

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

channel.queue_declare(queue='task_queue', durable=True)

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    time.sleep(body.count(b'.'))
    print(" [x] Done")
    ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_qos(prefetch_count=1)
channel.basic_consume(queue='task_queue', on_message_callback=callback)

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

在上面的示例中，我们使用工作队列模式创建了一个名为“task_queue”的队列，并使用Python客户端库创建了一个消费者。消费者会从队列中获取消息，并模拟处理消息的过程。在处理消息的过程中，我们使用了time.sleep()函数来模拟耗时操作。在处理完消息后，我们使用ch.basic_ack()函数向RabbitMQ发送确认消息。

发布/订阅模式示例：

import pika

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

channel.exchange_declare(exchange='logs', exchange_type='fanout')

result = channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue

channel.queue_bind(exchange='logs', queue=queue_name)

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

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

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

在上面的示例中，我们使用发布/订阅模式创建了一个名为“logs”的交换机，并使用Python客户端库创建了一个消费者。消费者会从交换机中获取消息，并打印消息的内容。我们使用channel.exchange_declare()函数创建了一个名为“logs”的交换机，并指定了交换机的类型为“fanout”。我们还使用channel.queue_bind()函数将队列绑定到交换机上，以便从交换机中获取消息。

总之，RabbitMQ支持多种消息传递模式，包括简单模式、工作队列模式、发布/订阅模式、路由模式和主题模式等。这些模式都有不同的用场景和特点，可以根据实际需求选择合适的模式。

Tags: