From 04cd58e03e1adc90e9deccf1beb8546c913a3991 Mon Sep 17 00:00:00 2001
From: lijing03 <1481281891@qq.com>
Date: Thu, 4 Jun 2026 17:00:05 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=B0=E5=BD=95=E5=88=86=E5=B8=83=E5=BC=8F?=
=?UTF-8?q?=E9=94=81=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
caf-boot-starters/caf-boot-starter-lock/pom.xml | 4 ++++
.../caf/lock/config/LockServiceAutoConfiguration.java | 10 ++++++----
2 files changed, 10 insertions(+), 4 deletions(-)
diff --git a/caf-boot-starters/caf-boot-starter-lock/pom.xml b/caf-boot-starters/caf-boot-starter-lock/pom.xml
index 3ec12539..e839e256 100644
--- a/caf-boot-starters/caf-boot-starter-lock/pom.xml
+++ b/caf-boot-starters/caf-boot-starter-lock/pom.xml
@@ -44,6 +44,10 @@
io.iec.edp
caf-lock-extension-jpa
+
+ io.iec.edp
+ caf-msu-api
+
org.springframework.boot
diff --git a/caf-boot-starters/caf-boot-starter-lock/src/main/java/io/iec/edp/caf/lock/config/LockServiceAutoConfiguration.java b/caf-boot-starters/caf-boot-starter-lock/src/main/java/io/iec/edp/caf/lock/config/LockServiceAutoConfiguration.java
index 03ce6594..102e4b88 100644
--- a/caf-boot-starters/caf-boot-starter-lock/src/main/java/io/iec/edp/caf/lock/config/LockServiceAutoConfiguration.java
+++ b/caf-boot-starters/caf-boot-starter-lock/src/main/java/io/iec/edp/caf/lock/config/LockServiceAutoConfiguration.java
@@ -23,6 +23,7 @@ import io.iec.edp.caf.lock.service.api.api.DistributedLockFactory;
import io.iec.edp.caf.lock.service.api.api.LockExtension;
import io.iec.edp.caf.lock.service.api.api.LockService;
import io.iec.edp.caf.lock.service.api.repositories.BatchLockRepo;
+import io.iec.edp.caf.lock.service.api.repositories.DistributedLockRepo;
import io.iec.edp.caf.lock.service.api.repositories.LockRepo;
import io.iec.edp.caf.lock.service.memory.MemoryLockFactory;
import io.iec.edp.caf.lock.service.memory.MemoryLockFactoryImpl;
@@ -32,6 +33,7 @@ import io.iec.edp.caf.lock.service.redis.DistributedLockServiceImpl;
import io.iec.edp.caf.lock.service.redis.DistributedLocksFactory;
import io.iec.edp.caf.lockservice.api.IDistributedLockFactory;
import io.iec.edp.caf.lockservice.api.ILockService;
+import io.iec.edp.caf.msu.api.entity.MsuProperties;
import org.redisson.api.RedissonClient;
import org.redisson.config.ClusterServersConfig;
import org.redisson.config.Config;
@@ -75,9 +77,9 @@ public class LockServiceAutoConfiguration {
@Bean
@ConditionalOnExpression("#{!'false'.equals(environment['redis.enabled'])}")
- public DistributedLockFactory getStandardDistributedLockFactory(RedissonClient redisson,RedisLockProperties redisLockProperties) {
+ public DistributedLockFactory getStandardDistributedLockFactory(RedissonClient redisson, RedisLockProperties redisLockProperties, MsuProperties configuration, DistributedLockRepo distributedLockRepo) {
Config config =getRedissonConfig(redisson,redisLockProperties);
- return new DistributedLockFactoryImpl(config);
+ return new DistributedLockFactoryImpl(config,configuration,distributedLockRepo);
}
@Bean
@@ -103,9 +105,9 @@ public class LockServiceAutoConfiguration {
@Bean
// @ConditionalOnMissingBean
@ConditionalOnExpression("#{!'false'.equals(environment['redis.enabled'])}")
- public IDistributedLockFactory getOldStandardDistributedLockFactory(RedissonClient redisson, RedisLockProperties redisLockProperties) {
+ public IDistributedLockFactory getOldStandardDistributedLockFactory(RedissonClient redisson, RedisLockProperties redisLockProperties, MsuProperties configuration, DistributedLockRepo distributedLockRepo) {
Config config = getRedissonConfig(redisson,redisLockProperties);
- return new DistributedLocksFactory(config);
+ return new DistributedLocksFactory(config,configuration,distributedLockRepo);
}
@Bean
--
Gitee