From 96ca0ff98704ac35546a120fea0224ac4373a7ed Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期二, 10 九月 2024 15:42:17 +0800 Subject: [PATCH] 清理redis中的离线次数定时任务 --- ycl-common/src/main/java/constant/RedisConstant.java | 2 +- ycl-server/src/main/java/com/ycl/task/ClearRedisTask.java | 28 ++++++++++++++++++++++++++++ ycl-server/src/main/java/com/ycl/thread/OnlineCheckThread.java | 4 ++-- 3 files changed, 31 insertions(+), 3 deletions(-) diff --git a/ycl-common/src/main/java/constant/RedisConstant.java b/ycl-common/src/main/java/constant/RedisConstant.java index b6a9361..6e66eb4 100644 --- a/ycl-common/src/main/java/constant/RedisConstant.java +++ b/ycl-common/src/main/java/constant/RedisConstant.java @@ -8,6 +8,6 @@ public final static String Check_Face_ViewConnect = "FaceViewConnectNoData"; /** 鐐逛綅鍦ㄧ嚎锛宧ash鐨刱ey */ - public final static String ONLINE_PREFIX = "ONLINE_"; + public final static String ONLINE_KEY = "ONLINE_"; } diff --git a/ycl-server/src/main/java/com/ycl/task/ClearRedisTask.java b/ycl-server/src/main/java/com/ycl/task/ClearRedisTask.java new file mode 100644 index 0000000..37b16cd --- /dev/null +++ b/ycl-server/src/main/java/com/ycl/task/ClearRedisTask.java @@ -0,0 +1,28 @@ +package com.ycl.task; + +import constant.RedisConstant; +import lombok.RequiredArgsConstructor; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Component; + +/** + * 瀹氭椂娓呯悊redis涓殑鏁版嵁 + * + * @author锛歺p + * @date锛�2024/9/10 15:26 + */ +@RequiredArgsConstructor +@Component("clearRedisTask") +public class ClearRedisTask { + + private final RedisTemplate redisTemplate; + + /** + * 娓呴櫎鍦ㄧ嚎鐩戞祴鐨剅edis璁$绾挎鏁� + * + */ + public void clearOnlineData() { + redisTemplate.delete(RedisConstant.ONLINE_KEY); + } + +} diff --git a/ycl-server/src/main/java/com/ycl/thread/OnlineCheckThread.java b/ycl-server/src/main/java/com/ycl/thread/OnlineCheckThread.java index 4003e46..a3c762d 100644 --- a/ycl-server/src/main/java/com/ycl/thread/OnlineCheckThread.java +++ b/ycl-server/src/main/java/com/ycl/thread/OnlineCheckThread.java @@ -105,13 +105,13 @@ vo.setOnline(reachable); } if (!vo.getOnline()) { - Integer outLineTimes = (Integer) redisTemplate.opsForHash().get(RedisConstant.ONLINE_PREFIX, monitor.getIp()); + Integer outLineTimes = (Integer) redisTemplate.opsForHash().get(RedisConstant.ONLINE_KEY, monitor.getIp()); if (Objects.isNull(outLineTimes)) { outLineTimes = 1; } else { outLineTimes += 1; } - redisTemplate.opsForHash().put(RedisConstant.ONLINE_PREFIX, monitor.getIp(), outLineTimes); + redisTemplate.opsForHash().put(RedisConstant.ONLINE_KEY, monitor.getIp(), outLineTimes); // 涓�澶╁唴鐩戞祴鍒扮绾�1娆′互涓婏紝鐢熸垚宸ュ崟 if (outLineTimes >= times) { WorkOrder workOrder = new WorkOrder(); -- Gitblit v1.8.0