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 .