编辑“︁RabbitMQ”︁

{{Infobox software
| name = RabbitMQ
| logo = RabbitMQ_logo.svg
| developer = Pivotal Software (现为VMware Tanzu)
| released = 2007年
| latest_release_version = 3.12.0
| latest_release_date = 2023年8月
| programming_language = Erlang
| operating_system = 跨平台
| genre = 消息代理
| license = Mozilla Public License
| website = https://www.rabbitmq.com
}}

'''RabbitMQ'''是一个开源的[[消息队列]]系统，实现了高级消息队列协议([[AMQP]])标准。作为轻量级的中间件，它支持多种消息协议，能在分布式系统中可靠地传递消息，广泛应用于[[微服务]]架构、异步任务处理和系统解耦等场景。

== 核心概念 ==

=== 基本组件 ===
RabbitMQ的核心架构包含以下关键组件：

* '''生产者(Producer)'''：发送消息的应用程序
* '''消费者(Consumer)'''：接收消息的应用程序
* '''队列(Queue)'''：存储消息的缓冲区
* '''交换机(Exchange)'''：接收生产者消息并根据规则路由到队列
* '''绑定(Binding)'''：连接交换机和队列的规则
* '''虚拟主机(Virtual Host)'''：独立的隔离环境

=== 消息流 ===
<mermaid>
graph LR
    Producer-->|Publish|Exchange
    Exchange-->|Route|Queue1
    Exchange-->|Route|Queue2
    Queue1-->Consumer1
    Queue2-->Consumer2
</mermaid>

== 交换机类型 ==

RabbitMQ提供四种主要交换机类型：

=== 直连交换机(Direct) ===
* 根据路由键(routing key)精确匹配队列
* 适用于单播消息路由

=== 扇形交换机(Fanout) ===
* 广播消息到所有绑定队列
* 忽略路由键
* 适用于发布/订阅场景

=== 主题交换机(Topic) ===
* 基于模式匹配路由键
* 支持通配符(*匹配一个单词，#匹配零或多个单词)
* 适用于多条件路由

=== 头交换机(Headers) ===
* 基于消息头属性而非路由键
* 可设置匹配条件(x-match: all/any)

== 安装与配置 ==

=== 安装方法 ===
在Ubuntu系统上安装RabbitMQ：

<syntaxhighlight lang="bash">
# 添加RabbitMQ仓库
sudo apt-get install -y curl gnupg
curl -fsSL https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc | sudo gpg --dearmor -o /usr/share/keyrings/rabbitmq-archive-keyring.gpg

# 安装服务
echo "deb [signed-by=/usr/share/keyrings/rabbitmq-archive-keyring.gpg] https://dl.bintray.com/rabbitmq-erlang/debian $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/rabbitmq.list
sudo apt-get update
sudo apt-get install -y rabbitmq-server

# 启动服务
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server
</syntaxhighlight>

=== 基本管理 ===
常用管理命令：

<syntaxhighlight lang="bash">
# 查看状态
sudo rabbitmqctl status

# 添加用户
sudo rabbitmqctl add_user myuser mypassword

# 设置权限
sudo rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*"

# 启用管理插件
sudo rabbitmq-plugins enable rabbitmq_management
</syntaxhighlight>

== 客户端开发 ==

=== Python示例 ===
使用pika库发送消息：

<syntaxhighlight lang="python">
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] Sent 'Hello World!'")

connection.close()
</syntaxhighlight>

接收消息的消费者代码：

<syntaxhighlight lang="python">
import pika

def callback(ch, method, properties, body):
    print(f" [x] Received {body}")

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

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

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

== 高级特性 ==

=== 消息确认 ===
RabbitMQ支持两种确认模式：
* 自动确认(auto-ack)：消息发送后立即确认
* 手动确认：消费者处理完成后显式确认

=== 持久化 ===
为防止消息丢失，可配置：
* 队列持久化(durable=True)
* 消息持久化(delivery_mode=2)
* 交换机持久化

=== 集群部署 ===
RabbitMQ支持集群模式提高可用性：
* 所有节点共享元数据
* 队列可镜像到多个节点
* 客户端可连接任意节点

== 应用场景 ==

=== 订单处理系统 ===
在电商平台中，RabbitMQ可用于：
1. 异步处理订单
2. 解耦支付服务和库存服务
3. 实现订单状态通知

=== 日志收集 ===
多个应用将日志发送到RabbitMQ：
1. 生产者应用发送日志消息
2. 消费者服务接收并存储日志
3. 实现日志的缓冲和异步处理

=== 微服务通信 ===
在[[Spring Cloud]]微服务架构中：
1. 服务间通过RabbitMQ通信
2. 实现事件驱动架构
3. 降低服务间直接依赖

== 性能优化 ==

* 合理设置预取计数(prefetch count)
* 使用批量确认提高吞吐量
* 优化消息大小和序列化方式
* 监控队列深度和消费者数量

== 监控与管理 ==

RabbitMQ提供多种监控方式：
* 内置管理界面(15672端口)
* Prometheus监控插件
* 命令行工具rabbitmqctl
* HTTP API接口

== 替代方案 ==

其他流行的消息中间件包括：
* [[Apache Kafka]] - 高吞吐分布式流平台
* [[RocketMQ]] - 阿里巴巴开源的分布式消息系统
* [[ActiveMQ]] - Apache的消息中间件项目

== 参见 ==
* [[AMQP]]
* [[消息队列]]
* [[微服务]]
* [[Spring Cloud]]
* [[分布式系统]]

== 参考资料 ==
* RabbitMQ官方文档
* 《RabbitMQ实战指南》
* AMQP 0-9-1协议规范

[[Category:中间件]]
[[Category:消息队列]]
[[Category:开源软件]]