526互联

设计思路-消费MQ

发布时间 2023-11-14 16:33:09作者: 意犹未尽

消费端收到消息

持久化到redis或者数据库，状态为待处理。然后ack确认

再处理通过线程池异步消费消息，提高吞吐量

1.如redis

先通过zset放入redis  

消费成功删除redis

未删除的等redis过期的补偿队列进行补偿