基于Redis实现的延迟消息队列

时间:2022-01-17 10:03:47
【文件属性】:
文件名称:基于Redis实现的延迟消息队列
文件大小:24KB
文件格式:ZIP
更新时间:2022-01-17 10:03:47
java redis 队列 延迟队列 消息队列 #### 整体结构 整个延迟队列由4个部分组成: 1. JobPool用来存放所有Job的元信息。 2. DelayBucket是一组以时间为维度的有序队列,用来存放所有需要延迟的Job(这里只存放Job Id)。 3. Timer负责实时扫描各个Bucket,并将delay时间大于等于当前时间的Job放入到对应的Ready Queue。 4. ReadyQueue存放处于Ready状态的Job(这里只存放JobId),以供消费程序消费。
【文件预览】:
delay-queue-master
----src()
--------test()
--------main()
----README.md(4KB)
----pom.xml(4KB)

网友评论