From ccb132374b02456be0476d0f87d26c06cb2781d8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=96=AF=E7=8B=82=E7=9A=84=E7=8B=AE=E5=AD=90li?= <15040126243@163.com> Date: Thu, 23 Dec 2021 15:02:25 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=9B=B4=E6=96=B0=20=E6=89=8B?= =?UTF-8?q?=E5=8A=A8=E8=8E=B7=E5=8F=96=20=E5=BB=B6=E8=BF=9F=E9=98=9F?= =?UTF-8?q?=E5=88=97=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ruoyi/common/utils/redis/QueueUtils.java | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java b/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java index c70acbad4..7850e016d 100644 --- a/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java +++ b/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java @@ -52,13 +52,20 @@ public class QueueUtils { public static void addDelayedQueueObject(String queueName, T data, long time, TimeUnit timeUnit) { RBlockingQueue queue = CLIENT.getBlockingQueue(queueName); RDelayedQueue delayedQueue = CLIENT.getDelayedQueue(queue); - // 已存在则无视 - if (delayedQueue.contains(data)) { - return; - } delayedQueue.offer(data, time, timeUnit); } + /** + * 获取一个延迟队列数据 没有数据返回 null + * + * @param queueName 队列名 + */ + public static T getDelayedQueueObject(String queueName) { + RBlockingQueue queue = CLIENT.getBlockingQueue(queueName); + RDelayedQueue delayedQueue = CLIENT.getDelayedQueue(queue); + return delayedQueue.poll(); + } + /** * 删除延迟队列数据 */