diff --git a/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClient.java b/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClient.java index de8295d..36cfced 100644 --- a/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClient.java +++ b/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClient.java @@ -26,6 +26,7 @@ package org.springblade.core.redis.lock; +import org.redisson.api.RedissonClient; import org.springblade.core.tool.function.CheckedSupplier; import java.util.concurrent.TimeUnit; @@ -97,4 +98,10 @@ public interface RedisLockClient { return lock(lockName, LockType.REENTRANT, waitTime, leaseTime, TimeUnit.SECONDS, supplier); } + /** + * 获取 RedissonClient + * + * @return RedissonClient + */ + RedissonClient getRedissonClient(); } diff --git a/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClientImpl.java b/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClientImpl.java index 85d1260..0621e88 100644 --- a/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClientImpl.java +++ b/blade-starter-redis/src/main/java/org/springblade/core/redis/lock/RedisLockClientImpl.java @@ -85,4 +85,9 @@ public class RedisLockClientImpl implements RedisLockClient { return null; } + @Override + public RedissonClient getRedissonClient() { + return redissonClient; + } + }