基于redis的延迟（优先级）消息队列
2021-07-21 18:33:19 15 举报
登录查看完整内容
将Redis的ZSET作为优先队列，用list作为待消费列表，根据路由规则，一个可配置的消息队列，模拟rabbitmq的延迟消费
作者其他创作
大纲/内容
消息对象，包含id，消息体
route1
route3
路由器将队列中的消息路由到对应的list中等待消费，一个路由器对应一个queue和list
id
zset1zset2...zset3
定时器
topic_list1topic_list2...topic_list3
元数据池(整个redis)
route2
Redis list
Redis ZSET
简单的消息持久化
基于list的一个待消费队列，每个list代表不同的主题，存放消息id
基于zset的优先队列，一个zset可以看做一类消息，存放id和score
binlog
Map结构
id(key)
body(value)
0 条评论
回复 删除
下一页
