基于redis的延迟(优先级)消息队列
2021-07-21 18:33:19 16 举报
将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 条评论
下一页