v1.9.2

Author: doki-byte

README.md

@@ -8,11 +8,11 @@
 
 ## 更新说明
 
-###  v1.9.1
+###  v1.9.2
 
 感谢师傅们提供的修改建议，目前已更新一下功能：
 
-1. 修复note笔记显示逻辑;;
+1. 新增redis命令执行功能;
 
 ## 工具介绍
 
@@ -113,6 +113,7 @@ cd /D EasyToolsFiles\tools\gui_webshell\Godzilla && loader.vbs [可选参数]
 #### Redis
 
 ![image-20250706200748776](images/image-20250706200748776.png)
+![image-20251020123650](images/image-20251020123650.png)
 
 ### 编码解码
 
@@ -150,7 +151,7 @@ cd /D EasyToolsFiles\tools\gui_webshell\Godzilla && loader.vbs [可选参数]
 
 ### 便携发包
 
-类似于postman，支持环境变量、get、post、del、put等各种常用功能  
+类似于postman，支持环境变量、get、post、del、put等各种常用功能
 
 ![image-20250917151543513.png](images/image-20250917151543513.png)
 

app/connect/redis/internal/define/define.go

@@ -20,6 +20,21 @@ type SSHConfig struct {
 	SSHPassword string `json:"ssh_password"`
 }
 
+// CommandResult 命令执行结果
+type CommandResult struct {
+	Success  bool        `json:"success"`  // 是否成功
+	Data     interface{} `json:"data"`     // 执行结果数据
+	Error    string      `json:"error"`    // 错误信息
+	Duration int64       `json:"duration"` // 执行耗时(毫秒)
+}
+
+// CommandHistory 命令历史记录
+type CommandHistory struct {
+	Command   string `json:"command"`   // 命令
+	Success   bool   `json:"success"`   // 是否成功
+	Timestamp int64  `json:"timestamp"` // 执行时间戳
+}
+
 var (
 	// DefaultKeyLen 键列表的默认查询长度
 	DefaultKeyLen int64 = 100

app/connect/redis/internal/service/connection.go

@@ -3,13 +3,90 @@ package service
 import (
 	"EasyTools/app/connect/redis/internal/define"
 	"EasyTools/app/connect/redis/internal/helper"
+	"context"
 	"encoding/json"
 	"errors"
-	uuid "github.com/satori/go.uuid"
+	"fmt"
+	"net"
 	"os"
 	"path/filepath"
+	"time"
+
+	"github.com/go-redis/redis/v8"
+	uuid "github.com/satori/go.uuid"
+	"golang.org/x/crypto/ssh"
 )
 
+// ConnectionTest 测试连接
+func ConnectionTest(conn *define.Connection) error {
+	if conn.Addr == "" {
+		return errors.New("连接地址不能为空")
+	}
+	if conn.Port == "" {
+		conn.Port = "6379"
+	}
+
+	// 创建 Redis 客户端配置
+	redisOpts := &redis.Options{
+		Addr:     fmt.Sprintf("%s:%s", conn.Addr, conn.Port),
+		Password: conn.Password,
+		DB:       0, // 默认数据库
+	}
+
+	var rdb *redis.Client
+	var sshClient *ssh.Client
+
+	// 如果是 SSH 连接，先建立 SSH 隧道
+	if conn.Type == "ssh" && conn.SSHAddr != "" {
+		sshConfig := &ssh.ClientConfig{
+			User: conn.SSHUsername,
+			Auth: []ssh.AuthMethod{
+				ssh.Password(conn.SSHPassword),
+			},
+			HostKeyCallback: ssh.InsecureIgnoreHostKey(),
+			Timeout:         10 * time.Second,
+		}
+
+		// 建立 SSH 连接
+		var err error
+		sshClient, err = ssh.Dial("tcp", fmt.Sprintf("%s:%s", conn.SSHAddr, conn.SSHPort), sshConfig)
+		if err != nil {
+			return fmt.Errorf("SSH连接失败: %v", err)
+		}
+		defer sshClient.Close()
+
+		// 通过 SSH 隧道建立 Redis 连接
+		sshConn, err := sshClient.Dial("tcp", fmt.Sprintf("%s:%s", conn.Addr, conn.Port))
+		if err != nil {
+			return fmt.Errorf("通过SSH连接Redis失败: %v", err)
+		}
+		defer sshConn.Close()
+
+		// 使用自定义拨号器
+		redisOpts.Dialer = func(ctx context.Context, network, addr string) (net.Conn, error) {
+			return sshClient.Dial(network, addr)
+		}
+		// 重置地址为本地，因为实际连接是通过 SSH 隧道
+		redisOpts.Addr = "127.0.0.1:6379"
+	}
+
+	// 创建 Redis 客户端
+	rdb = redis.NewClient(redisOpts)
+	defer rdb.Close()
+
+	// 测试连接
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+
+	// 执行 PING 命令测试连接
+	_, err := rdb.Ping(ctx).Result()
+	if err != nil {
+		return fmt.Errorf("Redis连接测试失败: %v", err)
+	}
+
+	return nil
+}
+
 // ConnectionList 连接列表
 func ConnectionList() ([]*define.Connection, error) {
 	baseDir := helper.GetAppBaseDir()