延迟队列 用法：当有消息达到延迟时间的时候会触发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