From e816946bb6e8f6b88045e565a3368c2367e7158a Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 15 Jul 2025 14:09:33 +0800
Subject: [PATCH] 1
---
websocketSerivce/src/main/java/org/example/controller/RunController.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/websocketSerivce/src/main/java/org/example/controller/RunController.java b/websocketSerivce/src/main/java/org/example/controller/RunController.java
index b63c4f1..83e8aec 100644
--- a/websocketSerivce/src/main/java/org/example/controller/RunController.java
+++ b/websocketSerivce/src/main/java/org/example/controller/RunController.java
@@ -6,6 +6,7 @@
import org.example.common.ServerResponse;
import org.example.pojo.User;
import org.example.util.JwtUtil;
+import org.example.util.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.context.ConfigurableApplicationContext;
@@ -16,6 +17,7 @@
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
+import java.util.Set;
@RestController
@RequestMapping("/api")
@@ -103,6 +105,12 @@
if (exitCode != 0) {
return ServerResponse.createByErrorMsg(pathName+"重启失败");
}
+
+ Set<String> keys = RedisUtil.keys(pathName);
+ keys.forEach(f->{
+ RedisUtil.delete(f);
+ });
+ log.info(pathName+"缓存清理完成，数量：" + keys.size());
return ServerResponse.createBySuccess(pathName+"重启成功");
} catch (IOException | InterruptedException e) {
e.printStackTrace();
--
Gitblit v1.9.3