bitMQ高可用需搭建镜像集群实现数据冗余，消息幂等通过唯一ID+去重表或状态机确保重复消费安全。
一、RabbitMQ高可用集群搭建1. 镜像集群架构（生产推荐）
原理：队列数据同步至多个节点，主节点故障时从节点自动切换，解决普通集群单节点故障问题。
搭建步骤（Docker环境）：
准备节点：创建3个容器，确保Erlang Cookie一致（集群通信密钥）：
bash
# 节点1（基准节点） docker run -d --hostname rabbit01 --name mq01 -p 5671:5672 -p 15671:15672 \ -e RABBITMQ_ERLANG_COOKIE=MY_COOKIE rabbitmq:3-management # 节点2 docker run -d --hostname rabbit02 --name mq02 --link mq01:rabbit01 \ -p 5672:5672 -p 15672:15672 -e RABBITMQ_ERLANG_COOKIE=MY_COOKIE rabbitmq:3-management # 节点3 docker run -d --hostname rabbit03 --name mq03 --link mq01:rabbit01 --link mq02:rabbit02 \ -p 5673:5672 -p 15673:15672 -e RABBITMQ_ERLANG_COOKIE=MY_COOKIE rabbitmq:3-management
组建集群：在节点2、3执行命令加入集群：bash
docker exec -it mq02 rabbitmqctl stop_app docker exec -it mq02 rabbitmqctl join_cluster rabbit@rabbit01 docker exec -it mq02 rabbitmqctl start_app # 节点3执行相同命令
设置镜像策略：所有队列同步至所有节点：
bash
docker exec -it mq01 rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all","ha-sync-mode":"automatic"}'
---二、消息幂等处理方案 智优达1. 唯一ID + 去重表（通用方案）
实现步骤：
生产者：每条消息生成全局唯一ID（UUID），放入消息属性：java
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder() .messageId(UUID.randomUUID().toString()) .build(); channel.basicPublish(exchange, routingKey, props, body);
消费者：处理前查询去重表，存在则忽略，否则处理并写入：java
String msgId = envelope.getProperties().getMessageId(); if (!IdempotencyHandler.isMessageProcessed(msgId)) { processMessage(body); // 业务处理 IdempotencyHandler.markMessageProcessed(msgId); // 写入去重表 } channel.basicAck(envelope.getDeliveryTag(), false);
2. 状态机（有状态业务）
示例：订单状态流转（待支付→已支付→已发货），重复的“支付成功”消息仅在状态为“待支付”时处理：
java
if (order.getStatus() == OrderStatus.PENDING_PAYMENT) { deductStock(order); // 扣库存 order.setStatus(OrderStatus.PAID); // 更新状态 }
---三、关键注意事项
集群节点数量：建议3节点（1主2从），避免脑裂（配置cluster_partition_handling=pause_minority）。
去重表性能：使用Redis代替数据库（SETNX msgId 1 EX 86400），支持高并发。
消息重试机制：结合死信队列，失败消息定时重试，避免幂等表压力。