Commit 08406f63 by huangfusuper

redis分布式锁注入校验

parent 43bc09e1
...@@ -4,6 +4,7 @@ import com.byit.conf.properties.RedissonProperties; ...@@ -4,6 +4,7 @@ import com.byit.conf.properties.RedissonProperties;
import com.byit.util.lock.DistributedLocker; import com.byit.util.lock.DistributedLocker;
import com.byit.util.lock.RedissLockUtil; import com.byit.util.lock.RedissLockUtil;
import com.byit.util.lock.RedissonDistributedLocker; import com.byit.util.lock.RedissonDistributedLocker;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.redisson.Redisson; import org.redisson.Redisson;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
...@@ -24,6 +25,7 @@ import org.springframework.context.annotation.Configuration; ...@@ -24,6 +25,7 @@ import org.springframework.context.annotation.Configuration;
@Configuration @Configuration
@ConditionalOnClass(Config.class) @ConditionalOnClass(Config.class)
@EnableConfigurationProperties(RedissonProperties.class) @EnableConfigurationProperties(RedissonProperties.class)
@Slf4j
public class RedissonAutoConfiguration { public class RedissonAutoConfiguration {
@Autowired @Autowired
private RedissonProperties redssionProperties; private RedissonProperties redssionProperties;
...@@ -79,7 +81,12 @@ public class RedissonAutoConfiguration { ...@@ -79,7 +81,12 @@ public class RedissonAutoConfiguration {
DistributedLocker distributedLocker(RedissonClient redissonSingle) { DistributedLocker distributedLocker(RedissonClient redissonSingle) {
RedissonDistributedLocker locker = new RedissonDistributedLocker(); RedissonDistributedLocker locker = new RedissonDistributedLocker();
locker.setRedissonClient(redissonSingle); locker.setRedissonClient(redissonSingle);
log.info("----------redis分布式锁{},被设置加载---------",locker);
RedissLockUtil.setLocker(locker); RedissLockUtil.setLocker(locker);
DistributedLocker redissLock = RedissLockUtil.getRedissLock();
if(redissLock == null) {
throw new RuntimeException("redis分布式锁设置异常,请联系调度中心开发团队!");
}
return locker; return locker;
} }
......
...@@ -10,7 +10,11 @@ public class RedissLockUtil { ...@@ -10,7 +10,11 @@ public class RedissLockUtil {
private static DistributedLocker redissLock; private static DistributedLocker redissLock;
public static void setLocker(DistributedLocker locker) { public static void setLocker(DistributedLocker locker) {
redissLock = locker; RedissLockUtil.redissLock = locker;
}
public static DistributedLocker getRedissLock(){
return RedissLockUtil.redissLock;
} }
public static void lock(String lockKey) { public static void lock(String lockKey) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment