delay-queue:基于Redis的延迟数值系统

时间:2024-03-31 12:13:26
【文件属性】:

文件名称:delay-queue:基于Redis的延迟数值系统

文件大小:15KB

文件格式:ZIP

更新时间:2024-03-31 12:13:26

系统开源

延迟队列 用法:当有消息达到延迟时间的时候会触发peekCallback。 public class TestRedisDelayQueue { JedisCluster jedisCluster = null ; RedisDelayQueue queue = null ; @Before public void init () { String ip = " 192.168.2.160 " ; Set< HostAndPort> nodes = new HashSet<> (); nodes . add( new HostAndPort (ip, 7701 )); nodes . add( new HostAndPort (ip, 7702 )); nodes . add( new HostAndPort (ip, 7703 )); nodes .


【文件预览】:
delay-queue-master
----pom.xml(1KB)
----LICENSE(11KB)
----src()
--------test()
--------main()
----.gitignore(450B)
----README.md(2KB)

网友评论