Problem

消息丢失

消息重复

幂等性

1. 每条消息唯一ID
2. 数据库唯一索引，eg 订单号唯一索引
3. Redis 分布式锁，同一消息同一时间只有一个消费者处理

消息乱序

分区

单队列单消费者是保证顺序的

Kafka 分区，同一个用户的消息路由到同一个分区处理，不同用户的消息可以并发同步处理

消息处理失败

死信队列