refactor(benchmark):优化基准测试脚本与抽象类定义- 将 Bench 类改为抽象类并定义抽象方法

- 改进 GitHub Actions 中的日志解析逻辑
- 修正不同测试类型对应的日志文件名匹配问题
- 增强对测试结果时间与 OPS 的提取准确性
- 支持 asyncGet、asyncSet、concurrentGet 和 concurrentSet 测试类型
- 提高脚本对不同日志格式的兼容性

Author: smthing

.github/workflows/benchmark.yml

@@ -75,9 +75,22 @@ jobs:
             local client_count=$2
             local log_file="${file_prefix}_${client_count}.log"
             
-            if [ -f "$log_file" ] && grep -q "${file_prefix#*_} cost:" "$log_file"; then
-              local time=$(grep "${file_prefix#*_} cost:" "$log_file" | awk '{print $5}')
-              local ops=$(grep "${file_prefix#*_} ops/s:" "$log_file" | awk '{print $5}')
+            if [ -f "$log_file" ]; then
+              # 提取时间 (cost)
+              local time_line=$(grep "\] ${file_prefix#*_} cost:" "$log_file" | head -1)
+              local time="-"
+              if [ -n "$time_line" ]; then
+                # 处理不同的格式：xxxms 或 xxx
+                time=$(echo "$time_line" | awk '{print $NF}' | sed 's/ms$//' | sed 's/[^0-9\-]*//g')
+              fi
+              
+              # 提取OPS
+              local ops_line=$(grep "\] ${file_prefix#*_} ops/s:" "$log_file" | head -1)
+              local ops="-"
+              if [ -n "$ops_line" ]; then
+                ops=$(echo "$ops_line" | awk '{print $NF}' | sed 's/[^0-9\-]*//g')
+              fi
+              
               echo "$time/$ops"
             else
               echo "-/-"
@@ -98,10 +111,33 @@ jobs:
             echo "|------------|------------------------|-----------------------|" >> benchmark-report.md
             
             for client_count in 1 8 128 1024; do
-              redisun_data=$(extract_data "redisun_${test_type}" "$client_count")
-              redisson_data=$(extract_data "redisson_${test_type}" "$client_count")
-              jedis_data=$(extract_data "jedis_${test_type}" "$client_count")
-              lettuce_data=$(extract_data "lettuce_${test_type}" "$client_count")
+              # 修正文件前缀以匹配实际的日志文件名
+              case "${test_type}" in
+                "concurrent_set")
+                  redisun_data=$(extract_data "redisun_concurrentSet" "$client_count")
+                  redisson_data=$(extract_data "redisson_concurrentSet" "$client_count")
+                  jedis_data=$(extract_data "jedis_concurrentSet" "$client_count")
+                  lettuce_data=$(extract_data "lettuce_concurrentSet" "$client_count")
+                  ;;
+                "async_set")
+                  redisun_data=$(extract_data "redisun_asyncSet" "$client_count")
+                  redisson_data=$(extract_data "redisson_asyncSet" "$client_count")
+                  jedis_data=$(extract_data "jedis_asyncSet" "$client_count")
+                  lettuce_data=$(extract_data "lettuce_asyncSet" "$client_count")
+                  ;;
+                "concurrent_get")
+                  redisun_data=$(extract_data "redisun_concurrentGet" "$client_count")
+                  redisson_data=$(extract_data "redisson_concurrentGet" "$client_count")
+                  jedis_data=$(extract_data "jedis_concurrentGet" "$client_count")
+                  lettuce_data=$(extract_data "lettuce_concurrentGet" "$client_count")
+                  ;;
+                "async_get")
+                  redisun_data=$(extract_data "redisun_asyncGet" "$client_count")
+                  redisson_data=$(extract_data "redisson_asyncGet" "$client_count")
+                  jedis_data=$(extract_data "jedis_asyncGet" "$client_count")
+                  lettuce_data=$(extract_data "lettuce_asyncGet" "$client_count")
+                  ;;
+              esac
               
               redisun_time=$(echo $redisun_data | cut -d'/' -f1)
               redisun_ops=$(echo $redisun_data | cut -d'/' -f2)

src/test/java/tech/smartboot/redisun/bench/Bench.java

@@ -4,14 +4,22 @@
  * @author 三刀
  * @version v1.0 10/23/25
  */
-public class Bench {
+public abstract class Bench {
     // 为了在GitHub Actions环境中更快地运行测试，减少测试数据量
     protected static final int SET_COUNT = 50000;
 
     protected static final int CONCURRENT_CLIENT_COUNT = Integer.parseInt(System.getProperty("client.count", "1"));
 
     protected static final String ADDRESS = "redis://127.0.0.1:6379";
-    
+
     // 预热次数
     protected static final int WARMUP_COUNT = 1000;
+
+    public abstract void asyncSet() throws Throwable;
+
+    public abstract void asyncGet() throws Throwable;
+
+    public abstract void concurrentSet() throws Throwable;
+
+    public abstract void concurrentGet() throws Throwable;
 }