消费端收到消息
持久化到redis或者数据库,状态为待处理。然后ack确认
再处理通过线程池异步消费消息,提高吞吐量
1.如redis
先通过zset放入redis
消费成功删除redis
未删除的等redis过期的补偿队列进行补偿
标签:消费,待处理,删除,redis,MQ,设计,思路 From: https://www.cnblogs.com/LQBlog/p/17831935.html
消费端收到消息
持久化到redis或者数据库,状态为待处理。然后ack确认
再处理通过线程池异步消费消息,提高吞吐量
1.如redis
先通过zset放入redis
消费成功删除redis
未删除的等redis过期的补偿队列进行补偿
标签:消费,待处理,删除,redis,MQ,设计,思路 From: https://www.cnblogs.com/LQBlog/p/17831935.html