delay queue:基于Redis的延迟数值系统 源码
延迟队列 用法:当有消息达到延迟时间的时候会触发peekCallback。 public class TestRedisDelayQueue { JedisCluster jedisCluster = null ; RedisDelayQueue queue = null ; @Before public void init () { String ip = " 192.168.2.160 " ; Set 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.zip
(预估有个10文件)
delay-queue-master
pom.xml
1KB
LICENSE
11KB
src
test
java
com
meipian
redis
test
暂无评论