SpringCloud + RabbitMQ：入坑必看攻略（二）

后端

2023-09-27 12:25:03

引言

上文我们探索了消息队列的基本概念，了解了使用 RabbitMQ 的优势。接下来，我们将深入探讨 RabbitMQ 的核心组件和工作原理，手把手带你构建分布式系统。

队列、交换机与路由

队列（Queue）： 消息的存储和接收容器，每个队列都有一个唯一的名称。

交换机（Exchange）： 接收生产者发送的消息，并根据路由规则将消息分发到不同的队列。

路由（Routing）： 交换机根据消息头中的特定字段将消息定向到指定队列。

工作模式

RabbitMQ 支持多种消息分发模式，其中最常用的是：

发布订阅（Publish/Subscribe）： 生产者将消息发送到交换机，交换机将消息广播给所有订阅该交换机的队列。

消费者与生产者

消费者（Consumer）： 从队列中接收消息并进行处理。

生产者（Producer）： 向交换机发送消息。

上手指南

创建队列： rabbitmqadmin declare queue queue-name
创建交换机： rabbitmqadmin declare exchange exchange-name exchange-type（其中 exchange-type 可以是 direct、topic、fanout 等）
绑定交换机与队列： rabbitmqadmin declare binding exchange-name queue-name routing-key（routing-key 用于指定消息路由规则）
发送消息： 使用生产者连接发送消息到交换机
接收消息： 使用消费者连接接收队列中的消息

实例演示

// 生产者
connection = ConnectionFactory().newConnection()
channel = connection.createChannel()
channel.basic_publish(
    exchange='my-exchange',
    routing_key='my-routing-key',
    body='Hello RabbitMQ!'
)
channel.close()
connection.close()

// 消费者
connection = ConnectionFactory().newConnection()
channel = connection.createChannel()
channel.queue_declare(queue='my-queue')
channel.basic_consume(
    queue='my-queue',
    on_message_callback=print_message,
    auto_ack=True
)
channel.start_consuming()