Redisson延迟队列是怎么搞的？

　　昨天，记录了Spring Boot基于Redisson实现订单状态延迟处理的思路后，就想着，还是要去搞清楚 RedissonDelayedQueue 的实现思路，所以，今天就忙里偷闲，去Github下载Redisson 源码来大概查略一番。如何创建RedissonDelayedQueue队列
　　在 Test 中，可以看到这样一段代码1 2 RBlockingQueue queue1 = redisson.getBlockingQueue(＂test＂);   //按名称获取一个阻塞队列实例 RDelayedQueue dealyedQueue = redisson.getDelayedQueue(queue1);  //按名称获取一个延迟队列实例。参数是`RQueue`
　　在获取 DelayedQueue 队列时，会初始化两个队列名称redisson_delay_queue_{队列名} 和redisson_delay_queue_timeout_{队列名} ，还会创建一个QueueTransferTask 队列中转的定时任务,添加队列1 dealyedQueue.offer(3, 5, TimeUnit.SECONDS);  //第一次参数是要发送给队列的数据，第二个参数是要延迟的时间，第三个参数是延迟的时间单位
　　这里，我们直接来到 offerAsync 方法1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 public RFuture offerAsync(V e, long delay, TimeUnit timeUnit) {         if (delay < 0) {             throw new IllegalArgumentException(＂Delay can＂t be negative＂);         }                  long delayInMs = timeUnit.toMillis(delay);         long timeout = System.currentTimeMillis() + delayInMs;               long randomId = ThreadLocalRandom.current().nextLong();         return commandExecutor.evalWriteNoRetryAsync(getRawName(), codec, RedisCommands.EVAL_VOID,                 ＂local value = struct.pack(＂dLc0＂, tonumber(ARGV[2]), string.len(ARGV[3]), ARGV[3]);＂                + ＂redis.call(＂zadd＂, KEYS[2], ARGV[1], value);＂               + ＂redis.call(＂rpush＂, KEYS[3], value);＂               // if new object added to queue head when publish its startTime                // to all scheduler workers                + ＂local v = redis.call(＂zrange＂, KEYS[2], 0, 0); ＂               + ＂if v[1] == value then ＂                  + ＂redis.call(＂publish＂, KEYS[4], ARGV[1]); ＂               + ＂end;＂,               Arrays.