From 20e5bf4823ea05703df797e7b392188a17fe9411 Mon Sep 17 00:00:00 2001
From: jujiyfb <151103583+jujiyfb@users.noreply.github.com>
Date: Wed, 27 Dec 2023 10:37:32 +0800
Subject: [PATCH] Create LettuceRedisUtils.java

---
 .../stream/utils/LettuceRedisUtils.java       | 55 +++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 austin-handler/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java

diff --git a/austin-handler/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java b/austin-handler/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java
new file mode 100644
index 0000000..b70634c
--- /dev/null
+++ b/austin-handler/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java
@@ -0,0 +1,55 @@
+package com.java3y.austin.stream.utils;
+
+import com.java3y.austin.stream.callback.RedisPipelineCallBack;
+import com.java3y.austin.stream.constants.AustinFlinkConstant;
+import io.lettuce.core.LettuceFutures;
+import io.lettuce.core.RedisClient;
+import io.lettuce.core.RedisFuture;
+import io.lettuce.core.RedisURI;
+import io.lettuce.core.api.StatefulRedisConnection;
+import io.lettuce.core.api.async.RedisAsyncCommands;
+import io.lettuce.core.codec.ByteArrayCodec;
+
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author 3y
+ * @date 2022/2/22
+ * 无Spring环境下使用Redis，基于Lettuce封装
+ */
+public class LettuceRedisUtils {
+
+    /**
+     * 初始化 redisClient
+     */
+    private static RedisClient redisClient;
+
+    static {
+        RedisURI redisUri = RedisURI.Builder.redis("austin-redis")
+                .withPort(6379)
+                .withPassword("austin")
+                .build();
+        redisClient = RedisClient.create(redisUri);
+    }
+
+    private LettuceRedisUtils() {
+
+    }
+
+    /**
+     * 封装pipeline操作
+     */
+    public static void pipeline(RedisPipelineCallBack pipelineCallBack) {
+        StatefulRedisConnection<byte[], byte[]> connect = redisClient.connect(new ByteArrayCodec());
+        RedisAsyncCommands<byte[], byte[]> commands = connect.async();
+
+        List<RedisFuture<?>> futures = pipelineCallBack.invoke(commands);
+
+        commands.flushCommands();
+        LettuceFutures.awaitAll(10, TimeUnit.SECONDS,
+                futures.toArray(new RedisFuture[futures.size()]));
+        connect.close();
+    }
+
+}