轻松掌握 RabbitMQ 发布订阅模式，让消息传递不再是难题

后端

2023-04-15 17:56:40

RabbitMQ 发布订阅模式：消息传递的魔法揭秘

什么是 RabbitMQ？

RabbitMQ 是一个强大的消息队列工具，用于在分布式系统中可靠、有效地传递消息。它提供了一种异步通信机制，使应用程序能够在不直接交互的情况下交换信息。

消息队列的基本概念

消息队列： 一个临时存储消息的存储库，就像一个邮局，暂时保管邮件直到接收者取走。
交换机： 根据路由键将消息路由到适当队列的 "分类员"。
队列： 消息的最终目的地，就像收件人的邮箱。
生产者： 发送消息到消息队列的实体。
消费者： 从消息队列接收消息的实体。
路由键： 生产者发送消息时指定的标识符，告诉交换机将消息路由到哪个队列。

RabbitMQ 发布订阅模式

发布订阅模式是一种消息传递模式，允许多个消费者订阅同一个队列中的消息，就像一群人同时收听同一广播电台。这种模式具有以下优点：

解耦性： 生产者和消费者之间完全分离，不会相互影响。
可扩展性： 可以轻松添加更多消费者来处理消息，从而随着系统规模的增长提高吞吐量。
可靠性： RabbitMQ 提供可靠的消息传递机制，确保消息不会丢失或重复传递。

RabbitMQ 发布订阅模式实战

安装 RabbitMQ

下载并安装 RabbitMQ 软件。
在终端中运行以下命令启动服务器： rabbitmq-server

创建队列和交换机

$ rabbitmqadmin declare queue my-queue
$ rabbitmqadmin declare exchange my-exchange topic

生产者代码

import pika

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

channel.basic_publish(
    exchange='my-exchange',
    routing_key='news',
    body='Hello, world!'
)

connection.close()

消费者代码

import pika

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

channel.queue_declare(queue='my-queue')

def callback(ch, method, properties, body):
    print("Received message: %r" % body)

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

channel.start_consuming()