@Resource
    private RedissonClient redissonClient;

    public void demo(){
        //创建一个名为TEST01的阻塞队列
        RBlockingQueue<String> blockingQueue = redissonClient.getBlockingQueue("TEST01");
        //把阻塞队列（对应redis List结构）和延迟队列（对应redis ZSet结构）进行关系绑定
        RDelayedQueue<String> rDelayedQueue = redissonClient.getDelayedQueue(blockingQueue);
        //延迟队列工作原理：延迟队列里面消息到期后 会把消息从延迟队列中移除 并放入阻塞队列（实际redisson并不是严格遵守这点，有适当的优化）
        //用户从阻塞队列中获取到期的消息

        //往延迟队列里面放入一条消息 5秒后到期
        rDelayedQueue.offer("msg01",5, TimeUnit.SECONDS);
        try {
            //阻塞获取消息
            String msg = blockingQueue.take();
            System.out.println(msg);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }