diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 1c5cb75..6343379 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -4,15 +4,10 @@
-
-
-
+
-
-
-
-
-
+
+
@@ -109,6 +104,9 @@
+
+
+
@@ -203,7 +201,7 @@
-
+
@@ -317,7 +315,23 @@
1719539540887
-
+
+
+ 1719540603770
+
+
+
+ 1719540603770
+
+
+
+ 1719540643218
+
+
+
+ 1719540643218
+
+
@@ -397,7 +411,8 @@
-
+
+
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java
index 655a7dc..a63fc7d 100644
--- a/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java
@@ -4,6 +4,7 @@ import lombok.Builder;
import lombok.Data;
import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
/**
* redis链接参数
@@ -24,16 +25,11 @@ public class RedisRequest {
/**
* 端口
*/
- @NotBlank(message = "端口号不能为空")
- private String itemPort;
- /**
- * 连接数据库名称
- */
- @NotBlank(message = "数据库名称不能为空")
- private String itemName;
+ @NotNull(message = "端口号不能为空")
+ private Integer port;
/**
* 连接地址
*/
@NotBlank(message = "链接地址不能为空")
- private String place;
+ private String host;
}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java b/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java
index 2310e2f..2e31648 100644
--- a/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java
@@ -1,11 +1,35 @@
package com.etl.cleaning.server;
+import com.etl.cleaning.domian.request.RedisRequest;
import lombok.Builder;
import lombok.Data;
+import redis.clients.jedis.Jedis;
/**
* redis测试连接
*/
public class RedisServerTest {
+ public static String testRedisData(RedisRequest redisRequest){
+ try {
+ // 创建Jedis对象(Redis客户端)
+ Jedis jedis = new Jedis(redisRequest.getHost(), redisRequest.getPort());
+ // 如果设置了密码,则进行认证
+ if (redisRequest.getItemPass() != null && !redisRequest.getItemPass().isEmpty()) {
+ jedis.auth(redisRequest.getItemPass());
+ }
+ // 测试连接是否成功,可以执行一个简单的命令,如ping
+ String response = jedis.ping();
+ if ("PONG".equals(response)) {
+ // 连接成功
+ return "ok";
+ } else {
+ // 连接失败或其他错误
+ return "error";
+ }
+ } catch (Exception e){
+ e.printStackTrace();
+ return "error";
+ }
+ }
}