fix:需求代码

src/main/java/com/kwan/springbootkwan/aop/RedisLockAspect.java

@@ -41,7 +41,7 @@ public class RedisLockAspect {
             if (locked) {
                 if (StringUtils.hasText(lockKey)) {
                     redisTemplate.opsForValue().set(lockKey, "locked", redisLock.expire(), TimeUnit.MILLISECONDS);
-                    redisLockRenewal.scheduleRenewal(lockKey, 20000, redisLock.expire());
+                    redisLockRenewal.scheduleRenewal(lock, lockKey, 20000, redisLock.expire());
                 }
                 return joinPoint.proceed();
             } else {

src/main/java/com/kwan/springbootkwan/schedule/RedisLockRenewal.java

@@ -7,10 +7,10 @@ import org.springframework.stereotype.Component;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Lock;
 
 @Component
 public class RedisLockRenewal {
-
     private final StringRedisTemplate redisTemplate;
     /**
      * 定时任务线程池
@@ -22,11 +22,14 @@ public class RedisLockRenewal {
         this.redisTemplate = redisTemplate;
     }
 
-    public void scheduleRenewal(String lockKey, long renewalIntervalMillis, long lockExpireMillis) {
+    public void scheduleRenewal(Lock lock, String lockKey, long renewalIntervalMillis, long lockExpireMillis) {
         scheduler.scheduleAtFixedRate(() -> {
             try {
+                boolean locked = lock.tryLock(lockExpireMillis, TimeUnit.MILLISECONDS);
+                if (locked) {
                     // 续期操作：设置新的过期时间
                     redisTemplate.expire(lockKey, lockExpireMillis, TimeUnit.MILLISECONDS);
+                }
             } catch (Exception e) {
                 // 处理续期失败的情况，可以记录日志或采取其他操作
                 e.printStackTrace();