RabbitMQ

异步发送/数据同步/分布式事务/削峰填谷

消息丢失

? ?生产者确认机制： 及时重发/记录日志/保存数据库定时重发

? ?消息持久化：交换机/队列/消息持久化

? ? ? 默认内存储存消息，开启持久化功能可以确保缓存在MQ消息不丢失

? ?消费者确认

? ? ? 处理消息后ack回执，manual手动/auto自动/none关闭

? ?消费者retry机制，消费者异常本地重试n次，仍然失败将消息投递到异常交换机，人工

重复消费：

? ? 网络抖动/消费者挂了

? ? ? ?唯一标识/幂等(分布式锁/数据库锁)

延迟队列：进入队列的消息被延迟消费?

? ? ?超时订单/限时优惠(当天签到)/定时发布(当天推送消息)

? ? 死信交换机+TTL

? ?死信交换机(dead-letter-exchange=dl.direct属性)

? ? ?消费者用basic.reject和basic.nack声明消费失败，且消费的requeue参数=false

? ? ?消息过期超时无人消费

? ? ?要投递的队列消息堆积满了，最早的消息可能成为死信

?ttl ：消息ttl结束仍未消费，死信(队列)

? ? 队列/消息本身 设置了存活时间；短的时间设置为准

? 延迟队列插件

消息堆积：

? ?增加消费者

? 消费者内部开启线程池加快处理速度(服务器cpu资源)

??扩大队列容积，提高堆积上限

? ? ?惰性队列：x-queue-mode=lazy数据储存在磁盘，消费时才从磁盘中读取到内存，百万条数据储存,性能稳定，受限于磁盘IO，时效性低

高可用机制：

? 普通集群：标准 节点共享部分数据：交换机/队列元信息? ?

? 镜像集群：主从，交换机 队列 队列中消息在各节点间同步备份

? ? ? 创建队列的节点为该队列的主节点，备份到其他节点(镜像节点)

? ? ? ?一个队列的主节点可能是另一个队列的镜像节点

? ? ? 主宕机后镜像节点代替新的主

? 仲裁队列3.8开始 ，主从模式 支持数据强同步raft协议

? ?