From 213cf6fd678832bb4f2c6a8398841eea31b66589 Mon Sep 17 00:00:00 2001
From: imyzt <imyzt01@gmail.com>
Date: Tue, 23 Sep 2025 00:24:02 +0800
Subject: [PATCH] =?UTF-8?q?:bug:=20#3631=20=E4=BF=AE=E5=A4=8D`tryLock`?=
 =?UTF-8?q?=E5=92=8C`unlock`=E4=B8=AD=E9=92=88=E5=AF=B9Key=E7=9A=84?=
 =?UTF-8?q?=E5=BA=8F=E5=88=97=E5=8C=96=E6=96=B9=E5=BC=8F=E4=B8=8D=E4=B8=80?=
 =?UTF-8?q?=E8=87=B4=E5=AF=BC=E8=87=B4=E6=97=A0=E6=B3=95unlock=E7=9A=84?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../RedisTemplateSimpleDistributedLock.java   |  8 ++++--
 ...edisTemplateSimpleDistributedLockTest.java | 27 ++++++++++++++++++-
 2 files changed, 32 insertions(+), 3 deletions(-)

diff --git a/weixin-java-common/src/main/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLock.java b/weixin-java-common/src/main/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLock.java
index b2d2481ef..ab20f39ae 100644
--- a/weixin-java-common/src/main/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLock.java
+++ b/weixin-java-common/src/main/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLock.java
@@ -7,10 +7,12 @@ import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.data.redis.core.script.DefaultRedisScript;
 import org.springframework.data.redis.core.script.RedisScript;
 import org.springframework.data.redis.core.types.Expiration;
+import org.springframework.data.redis.serializer.RedisSerializer;
 
 import java.nio.charset.StandardCharsets;
 import java.util.Collections;
 import java.util.List;
+import java.util.Objects;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.Condition;
@@ -70,8 +72,10 @@ public class RedisTemplateSimpleDistributedLock implements Lock {
       value = UUID.randomUUID().toString();
       valueThreadLocal.set(value);
     }
-    final byte[] keyBytes = key.getBytes(StandardCharsets.UTF_8);
-    final byte[] valueBytes = value.getBytes(StandardCharsets.UTF_8);
+    RedisSerializer<String> keySerializer = (RedisSerializer<String>) redisTemplate.getKeySerializer();
+    RedisSerializer<String> valueSerializer = (RedisSerializer<String>) redisTemplate.getValueSerializer();
+    final byte[] keyBytes = Objects.requireNonNull(keySerializer.serialize(key));
+    final byte[] valueBytes = Objects.requireNonNull(valueSerializer.serialize(value));
     List<Object> redisResults = redisTemplate.executePipelined((RedisCallback<String>) connection -> {
       connection.set(keyBytes, valueBytes, Expiration.milliseconds(leaseMilliseconds), RedisStringCommands.SetOption.SET_IF_ABSENT);
       connection.get(keyBytes);
diff --git a/weixin-java-common/src/test/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLockTest.java b/weixin-java-common/src/test/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLockTest.java
index 4b65e31f0..b278eeafa 100644
--- a/weixin-java-common/src/test/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLockTest.java
+++ b/weixin-java-common/src/test/java/me/chanjar/weixin/common/util/locks/RedisTemplateSimpleDistributedLockTest.java
@@ -1,8 +1,10 @@
 package me.chanjar.weixin.common.util.locks;
 
 import lombok.extern.slf4j.Slf4j;
+import org.jetbrains.annotations.NotNull;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
 import org.testng.annotations.BeforeTest;
 import org.testng.annotations.Test;
 
@@ -13,9 +15,10 @@ import java.util.concurrent.atomic.AtomicInteger;
 import static org.testng.Assert.*;
 
 @Slf4j
-@Test(enabled = false)
+@Test(enabled = true)
 public class RedisTemplateSimpleDistributedLockTest {
 
+  private static final String KEY_PREFIX = "System:";
   RedisTemplateSimpleDistributedLock redisLock;
 
   StringRedisTemplate redisTemplate;
@@ -29,6 +32,28 @@ public class RedisTemplateSimpleDistributedLockTest {
     connectionFactory.setPort(6379);
     connectionFactory.afterPropertiesSet();
     StringRedisTemplate redisTemplate = new StringRedisTemplate(connectionFactory);
+    // 自定义序列化器，为 key 自动加前缀
+    redisTemplate.setKeySerializer(new StringRedisSerializer() {
+      @NotNull
+      @Override
+      public byte[] serialize(String string) {
+        if (string == null) {
+          return super.serialize(null);
+        }
+        // 添加前缀
+        return super.serialize(KEY_PREFIX + string);
+      }
+
+      @NotNull
+      @Override
+      public String deserialize(byte[] bytes) {
+        String key = super.deserialize(bytes);
+        if (key.startsWith(KEY_PREFIX)) {
+          return key.substring(KEY_PREFIX.length());
+        }
+        return key;
+      }
+    });
     this.redisTemplate = redisTemplate;
     this.redisLock = new RedisTemplateSimpleDistributedLock(redisTemplate, 60000);
     this.lockCurrentExecuteCounter = new AtomicInteger(0);