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