RabbitMQ 消息队列【第30讲：普通集群模式】
本文介绍了 RabbitMQ 普通集群的特点和局限性。普通集群通过多节点共享元数据实现连接分散，减轻单机压力，但队列数据仅存储在声明节点上，不具备数据冗余能力。当队列所在节点宕机时，该队列将不可用。因此普通集群只能解决连接分散问题，无法实现真正的高可用。文章通过具体场景说明这个容易被误解的特性，并指出要实现高可用需要使用镜像队列（将在下篇文章介绍）。关键结论：普通集群是"能用"而非"高可用"的解决方案。
辰风沐阳 阅读 123 2026-07-18
RabbitMQ 消息队列【第29讲：为什么需要集群】
本文分析了 RabbitMQ 单机部署的三大风险：单点故障导致系统全停、单机性能容量瓶颈、无法应对流量洪峰。通过集群部署可以分散连接和存储压力，实现节点故障时系统仍可工作。但普通集群模式下，队列数据仍只存储在一个节点上，该节点故障时队列仍不可用。文章指出集群虽能提升可用性和扩展性，但普通集群方案存在局限性，无法彻底解决高可用问题，为后续讲解更完善的集群方案做铺垫。
辰风沐阳 阅读 102 2026-07-17
RabbitMQ 消息队列【第28讲：消息追踪与问题排查】
用户投诉下单后未收到短信通知，排查发现订单数据正常但消息丢失。RabbitMQ 消息流转涉及 Producer→Exchange→Queue→Consumer 多个环节，需逐层排查。建议优先通过 Producer/Consumer 日志、RabbitMQ 管理界面（检查Exchange/Queue状态）定位问题，常见问题包括路由错误、队列名不符、未ACK等。复杂场景可使用 Tracing 插件追踪消息轨迹，但多数问题通过常规工具即可解决。核心思路是沿消息流向有序排查，优先验证代码和配置而非中间件本身。
辰风沐阳 阅读 121 2026-07-16
RabbitMQ 消息队列【第27讲：消费幂等性】
RabbitMQ 消息重复投递可能导致业务异常（如重复扣库存、加积分），解决核心在于实现幂等性——同一消息多次处理结果一致。提出三种方案：1. 唯一业务ID+去重表检查；2. 利用数据库唯一索引；3. 通过状态机流转判断。方案各有适用场景，可组合使用。强调幂等性是业务层责任，与MQ机制无关。最终实现重复消息不影响业务逻辑的目标。
辰风沐阳 阅读 131 2026-07-14
RabbitMQ 消息队列【第26讲：消息可靠性投递（下）】
本文讨论了 RabbitMQ 中消息重复的问题及其解决方案。消息重复的原因包括生产者重发、消费者 ACK 丢失、消费者重启以及重试机制。RabbitMQ 能通过配置（如Confirm、Return、持久化、ACK）保证消息不丢失，但无法天然避免消息重复消费。解决重复消费需要业务层实现幂等性，确保同一条消息无论处理多少次结果都一致。RabbitMQ 的职责是消息传递，而业务去重需由消费者自行处理。
辰风沐阳 阅读 138 2026-07-13
RabbitMQ 消息队列【第25讲：消息可靠性投递（上）】
本文介绍了 RabbitMQ 消息传递过程中可能丢失的四个环节及解决方案：1. Producer 到 Exchange 环节通过 Publisher Confirm 机制确保消息送达；2. Exchange 到Queue 环节通过 Return 机制处理路由失败；3. Queue 存储环节通过队列和消息持久化防止重启丢失；4. Consumer 处理环节通过手动 ACK 保证消费完成。完整可靠性方案会带来性能开销，建议根据业务重要性选择配置级别，如订单支付类关键业务需开启所有保障机制，而日志收集等场景可使用默认配置。
辰风沐阳 阅读 136 2026-07-12
RabbitMQ 消息队列【第24讲：延迟队列实现方案】
本文介绍了延迟队列的三种实现方案及其适用场景。延迟队列用于管理未来某个时间点执行的任务，如订单超时取消、会议提醒等。经典方案是 RabbitMQ 的TTL+DLX 组合，适合固定时长的延迟需求；RabbitMQ 官方延迟插件更灵活但需额外安装；Redis 方案则适合已有 Redis 的项目，但需自行实现定时任务。作者建议根据项目现状选择最简单可行的方案，多数情况下 TTL+DLX 已能满足需求，避免为简单需求引入复杂方案。
辰风沐阳 阅读 136 2026-07-11
RabbitMQ 消息队列【第23讲：死信队列 DLX】
本文介绍了 RabbitMQ 死信队列（DLX）的实现与应用。主要内容包括： 死信概念：消息过期、消费者拒收或队列满时，消息会变成死信，需通过死信队列处理。 DLX 机制：死信队列是一个普通 Exchange，用于接收死信并路由到指定队列，无需额外代码。 实现步骤： 声明死信 Exchange 和队列（如dlx_exchange和timeout_queue）。 业务队列绑定 DLX 参数（x-dead-letter-exchange和路由键）。 消息过期后自动转发至死信队列，触发取消订单等逻辑。
辰风沐阳 阅读 159 2026-07-10
RabbitMQ 消息队列【第22讲：消息过期 TTL】
本文介绍了如何利用消息队列实现电商订单30分钟未支付自动取消的功能。传统定时任务扫表方案存在延迟、资源浪费和数据库压力问题，而基于 RabbitMQ 的 TTL（Time To Live）机制可以更高效地实现这一需求。TTL 允许为消息设置过期时间，超过时间未消费的消息将被丢弃或转入死信队列。文章详细说明了两种 TTL 设置方式（单条消息设置和队列级别设置），并给出了代码示例。同时指出单纯 TTL 的局限性，为后续介绍死信队列（DLX）解决方案做了铺垫。
辰风沐阳 阅读 140 2026-07-09
RabbitMQ 消息队列【第21讲：日志分级系统实战】
本文介绍了如何利用 RabbitMQ 的 Topic Exchange 实现日志分级处理系统。系统将日志分为 info、warning、error 三个级别，分别对应不同的处理方式：存储分析、监控统计和实时告警。通过模块.级别的路由规则（如order.error），配合通配符绑定（.error、.warning、*.info和#），实现日志的精准分流到不同队列。文章提供了 PHP 代码示例展示 Exchange 声明、队列绑定、消息发布和消费逻辑，并验证了不同级别日志能正确路由到对应队列。
辰风沐阳 阅读 138 2026-07-08