第2章 RabbitMQ入门

第2章 RabbitMQ入门：从零开始理解消息队列

大家好，我是你们的老朋友。今天咱们来聊聊RabbitMQ。

说实话，我在刚接触消息队列那会儿，也被一堆概念搞得头晕。什么Exchange、Queue、Binding，听着就像绕口令。但别担心，今天我会用最接地气的方式，把这些东西讲明白。

2.1 RabbitMQ是什么？

RabbitMQ，说白了就是一个消息中转站。它负责接收生产者发来的消息，然后转发给消费者。

你可以把它想象成一个快递驿站。生产者是寄件人，消费者是收件人，RabbitMQ就是那个负责分拣和派送的驿站小哥。

我个人习惯把RabbitMQ比作「邮局」——你不需要知道信是怎么送到对方手里的，你只需要把信投进邮筒就行。剩下的，邮局帮你搞定。

核心特点：

基于AMQP协议（Advanced Message Queuing Protocol）
支持多种消息模式：点对点、发布/订阅、路由、主题
高可用、可扩展、持久化
跨语言支持（Python、Java、Go、.NET等）

我在项目中遇到过一个问题：刚开始用RabbitMQ时，总觉得它跟Redis的pub/sub差不多。后来踩了坑才发现，RabbitMQ的可靠性远高于Redis——消息确认、持久化、死信队列，这些功能在金融场景下简直是救命稻草。

2.2 核心概念：三个你必须搞懂的东西

RabbitMQ有三个核心概念：Exchange、Queue、Binding。嗯，这里要注意，很多人一开始就栽在这三个词上。

2.2.1 Queue（队列）

队列就是消息的「家」。生产者把消息扔进队列，消费者从队列里取消息。

队列的特点：

先进先出（FIFO）
可以持久化（重启后消息还在）
可以有多个消费者（但一条消息只能被一个消费者消费）

你想想看，队列就像是一个信箱。你把信放进去，邮递员（消费者）来取走。如果没人取，信就一直躺在里面。

2.2.2 Exchange（交换机）

交换机是RabbitMQ最核心、也最容易让人迷惑的概念。

生产者不直接把消息发给队列，而是发给交换机。交换机根据规则，决定把消息转发给哪个队列。

交换机有四种类型：

类型	说明	使用场景
Direct	直接匹配routing key	点对点通信
Topic	通配符匹配routing key	按主题订阅
Fanout	广播给所有绑定的队列	发布/订阅
Headers	根据消息头属性匹配	复杂路由场景

我记得刚开始用Fanout时，以为它跟广播一样简单。结果有一次生产环境出了bug，消息被重复消费了三次。排查了半天，才发现是队列绑了三个消费者，而Fanout会把消息复制给所有队列。嗯，从那以后我再也不敢乱用Fanout了。

2.2.3 Binding（绑定）

绑定就是把交换机和队列连接起来。绑定的时候，需要指定一个routing key（路由键）。

举个例子：

交换机A绑定队列B，routing key = "order.create"
生产者发消息时，指定routing key = "order.create"
交换机A看到这个key，就把消息转发给队列B

说白了，绑定就是给交换机装了一个「路由表」。交换机根据这个表，决定消息该去哪。

避坑指南：我曾经犯过一个低级错误——创建了交换机，也创建了队列，但忘了绑定。结果消息发出去就石沉大海了。所以记住：没有绑定的交换机，消息就是无家可归的孤儿。

2.3 安装与启动

安装RabbitMQ其实很简单。我个人习惯用Docker，省心省力。

2.3.1 使用Docker安装

# 拉取镜像
docker pull rabbitmq:3.12-management

# 启动容器
docker run -d \
  --name rabbitmq \
  -p 5672:5672 \
  -p 15672:15672 \
  rabbitmq:3.12-management

这里要注意：

5672是AMQP协议端口（程序连接用）
15672是管理界面端口（浏览器访问用）

启动后，打开浏览器访问 http://localhost:15672，默认用户名密码都是 guest。

2.3.2 直接安装（Linux）

# Ubuntu/Debian
sudo apt-get install rabbitmq-server

# CentOS/RHEL
sudo yum install rabbitmq-server

# 启动服务
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

警告：生产环境千万不要用guest账号！guest只能在localhost登录。我见过有人把guest暴露到公网，结果被挖矿程序盯上了。建议创建专用账号，并设置强密码。

2.4 Python客户端pika基础使用

好了，理论讲完了，咱们来点实际的。Python操作RabbitMQ，最常用的库就是pika。

2.4.1 安装pika

pip install pika

就这么简单。嗯，这里要注意版本，pika 1.x和0.x的API有些差异。我建议用最新版。

2.4.2 生产者示例

import pika

# 建立连接
connection = pika.BlockingConnection(
    pika.ConnectionParameters('localhost')
)
channel = connection.channel()

# 声明队列（如果不存在则创建）
channel.queue_declare(queue='hello')

# 发送消息
channel.basic_publish(
    exchange='',
    routing_key='hello',
    body='Hello World!'
)

print(" [x] 消息已发送")
connection.close()

这里有个细节：exchange=''表示使用默认交换机。默认交换机会直接把消息发给routing_key指定的队列。

2.4.3 消费者示例

import pika

def callback(ch, method, properties, body):
    print(f" [x] 收到消息: {body}")

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

channel.queue_declare(queue='hello')

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

print(' [*] 等待消息...')
channel.start_consuming()

你想想看，这个消费者就像是一个「守门员」。它一直盯着队列，一旦有消息进来，就立刻处理。

个人经验：我在项目中遇到过一个问题——消费者处理消息时抛异常了，但auto_ack=True导致消息被自动确认，结果消息丢了。后来我改成auto_ack=False，手动确认消息。这样即使处理失败，消息也不会丢失，会重新入队。

2.4.4 手动确认消息

def callback(ch, method, properties, body):
    try:
        # 处理消息
        print(f"处理消息: {body}")
        # 手动确认
        ch.basic_ack(delivery_tag=method.delivery_tag)
    except Exception as e:
        print(f"处理失败: {e}")
        # 拒绝消息，重新入队
        ch.basic_nack(delivery_tag=method.delivery_tag, requeue=True)

channel.basic_consume(
    queue='hello',
    on_message_callback=callback,
    auto_ack=False  # 关闭自动确认
)

这样做的好处是：即使程序崩溃，消息也不会丢。RabbitMQ会等消费者确认后，才把消息从队列中删除。

2.5 小结

今天咱们聊了RabbitMQ的入门知识：

RabbitMQ是一个消息中转站，基于AMQP协议
三个核心概念：Exchange（交换机）、Queue（队列）、Binding（绑定）
安装可以用Docker，简单快捷
Python用pika库操作，生产者发消息，消费者收消息

说实话，这些只是冰山一角。RabbitMQ还有很多高级特性：死信队列、延迟队列、集群部署等等。但别急，咱们一步一步来。

下一章，我会带你深入Exchange的四种类型，看看它们在实际项目中怎么用。到时候，我会分享一个我踩过的坑——Topic交换机通配符写错了，导致消息全部路由到了死信队列。嗯，那真是一个难忘的加班夜。

今天就到这里。记住：消息队列不是银弹，但用好了，它能让你的系统优雅十倍。

📚 课程目录