RabbitMQ 完整实战

RabbitMQ 核心架构

核心组件

• Producer 生产者：发送消息

• Exchange 交换机：路由消息，不存储消息

• Queue 队列：存储消息，持久化

• Consumer 消费者：监听队列消费

四大交换机类型

1. Direct：精准匹配，一对一

2. Topic：模糊匹配，订阅模式，最常用

3. Fanout：广播模式，全部接收

4. Headers：头部匹配，几乎不用

RabbitMQ 安装部署（Linux）

RabbitMQ 依赖 Erlang 环境

# 安装依赖
apt update
apt install erlang -y

# 安装RabbitMQ
apt install rabbitmq-server -y

# 启动 & 开机自启
systemctl start rabbitmq-server
systemctl enable rabbitmq-server

# 开启可视化管理界面
rabbitmq-plugins enable rabbitmq_management

# 查看状态
systemctl status rabbitmq-server

账号配置

# 创建管理员用户
rabbitmqctl add_user admin 123456
rabbitmqctl set_user_tags admin administrator
rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

访问地址：http://服务器IP:15672

七大消息模型实战

1. 简单模式：1生产者 1队列 1消费者

2. 工作队列模式：1队列 多消费者（轮询消费）

3. 发布订阅模式（Fanout）广播

4. 路由模式（Direct）精准分发

5. 主题模式（Topic）模糊匹配

6. 死信队列模式

7. 延迟队列模式

RabbitMQ 高级特性

• 消息持久化、队列持久化

• 生产者确认、消费者手动ACK

• 死信队列 DLX、TTL 过期时间

• 延迟队列实现（订单超时关闭）

• 镜像队列高可用集群