SpringBoot集成Lock4j 底层使用Redission 实现分布锁

Lock4j

在分布式系统中，实现锁的功能对于保证数据一致性和避免并发冲突是非常重要的。Lock4j是一个简单易用的分布式锁框架，而Redisson是一个功能强大的分布式解决方案，可以与Lock4j进行集成。

操作步骤

第一步：添加依赖

首先，在你的Spring Boot项目的pom.xml文件中添加以下依赖：

<dependencies><!--若使用redisTemplate作为分布式锁底层，则需要引入--><dependency><groupId>com.baomidou</groupId><artifactId>lock4j-redis-template-spring-boot-starter</artifactId><version>${latest.version}</version></dependency><!--若使用redisson作为分布式锁底层，则需要引入--><dependency><groupId>com.baomidou</groupId><artifactId>lock4j-redisson-spring-boot-starter</artifactId><version>${latest.version}</version></dependency><!--若使用zookeeper作为分布式锁底层，则需要引入--><dependency><groupId>com.baomidou</groupId><artifactId>lock4j-zookeeper-spring-boot-starter</artifactId><version>${latest.version}</version></dependency>
</dependencies>

这些依赖将会引入Redisson和Lock4j以及它们的必要依赖。

第二步：配置Redis

在src/main/resources目录下创建application.yml文件，并添加以下配置：

spring:redis:host: 127.0.0.1port: 6379password: ddz123database: 0

这是一个示例配置文件，你需要根据自己的实际情况修改Redis的连接信息，如地址、端口、密码等。

第三步：使用@Lock4j注解实现分布式锁

在你的Spring Boot应用程序中，创建一个测试类，用于ApiPost的调用两次第一个会获取到锁，第二个获取锁失败会抛出异常。

    @GetMapping("/lock")@Lock4j(keys = {"#id"}, acquireTimeout = 100, expire = 10000
//            , executor = RedissonLockExecutor.class)public String getLock(String id) throws InterruptedException {Thread.sleep(10000);return id;}

自定义锁

自定义锁key的生成规则

只需要实现LockKeyBuilder接口中 buildKey() 方法即可定义自己的生成规则。

@Component
public class CustomKeyBuilder implements LockKeyBuilder {/*** 构建key** @param invocation     invocation* @param definitionKeys 定义* @return key*/@Overridepublic String buildKey(MethodInvocation invocation, String[] definitionKeys) {// 自定义锁key的生成策略return null;}
}

自定义锁失败策略

实现LockFailureStrategy接口中onLockFailure() 方法即可自定义获取锁失败返回策略。

@Component
public class GrabLockFailureStrategy implements LockFailureStrategy {/*** 锁失败事件** @param key       锁key* @param method    方法* @param arguments 自变量*/@Overridepublic void onLockFailure(String key, Method method, Object[] arguments) {throw new RuntimeException("获取锁失败了！");}
}

自定义加锁解锁逻辑

@Component
public class RedissonLockExecutor extends AbstractLockExecutor<RLock> {/*** 加锁** @param lockKey        锁标识* @param lockValue      锁值* @param expire         锁有效时间* @param acquireTimeout 获取锁超时时间* @return 锁信息*/@Overridepublic RLock acquire(String lockKey, String lockValue, long expire, long acquireTimeout) {return null;}/*** 解锁** <pre>* 为何解锁需要校验lockValue* 客户端A加锁，一段时间之后客户端A解锁，在执行releaseLock之前，锁突然过期了。* 此时客户端B尝试加锁成功，然后客户端A再执行releaseLock方法，则将客户端B的锁给解除了。* </pre>** @param key          加锁key* @param value        加锁value* @param lockInstance 锁实例* @return 是否释放成功*/@Overridepublic boolean releaseLock(String key, String value, RLock lockInstance) {return false;}
}

注意事项

在使用Spring Boot集成Lock4j和Redisson时，需要注意以下事项：

• 确保Redisson的配置正确。在redisson.yaml文件（或application.properties）中，你需要提供正确的Redis连接信息，如地址、端口、密码等。确保你的Redis服务运行正常。
• 注意锁的名称要保证唯一性。不同的锁需要使用不同的锁名称。使用相同名称的锁可能会导致不同方法之间的锁冲突。
• 考虑对方法异常进行处理。为了确保锁能够被正确释放，你可以在方法中使用try-catch-finally结构，并在finally块中释放锁。这样即使方法出现异常，也能保证锁的守护不会因异常而中断。

通过以上步骤和注意事项，你可以轻松地在Spring Boot项目中集成Lock4j，并使用Redisson作为底层实现分布式锁。这样，你可以安全地处理分布式系统中的并发问题，并保证数据的一致性。