文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

SpringBoot强大的分布式锁组件Lock4j,支持多种实现

2024-11-29 20:17

关注

1. 简介

lock4j是一个分布式锁组件,其提供了多种不同的支持以满足不同性能和环境的需求。底层通过Spring AOP技术实现,而该切面的优先级是最高的,也就是说当你的环境中有多个切面时(如:声明式事务),也不会导致失效问题。该组件具有如下2个特性:

接下来将详细介绍基于Redis的Lock4J使用。

2. 实战案例

2.1 引入依赖


  2.2.7


  com.baomidou
  lock4j-redis-template-spring-boot-starter
  ${lock4j.version}

如果你想基于redisson或者是zookeeper实现,那么你只需要引入对应的包即可。


lock4j-redisson-spring-boot-starter

lock4j-zookeeper-spring-boot-starter
配置文件
spring:
  data:
    redis:
      timeout: 10000
      connectTimeout: 20000
      host: 127.0.0.1
      password: xxxooo
  #如果你是基于zookeeper实现,那么做如下配置
  coordinate:
    zookeeper:
      zkServers: 127.0.0.1:2181,...

进过以上的配置后接下来你就可以通过注解的方式使用分布式锁了。

2.2 基本使用

@Service
public class StorageService {


  private final StorageRepository storageRepository ;
  public StorageService(StorageRepository storageRepository) {
    this.storageRepository = storageRepository ;
  }


  @Lock4j
  public void deductStorage(Long storageId, int count) {
    // TODO
  }
}

使用非常简单,只需要在你需要上锁的方法上添加@Lock4j注解即可。而这里将使用默认行为:默认获取锁超时3秒,30秒锁过期。

自定义锁key

在上面示例中没有自定义@Lock4j注解的任何属性;那么,将会使用默认的key生成方式,上面的代码将生成如下key。

# 前缀 + ":" + 完全限定类名+方法名+# (这里的#是固定的,如果你自定义了key,会在后面继续拼接)
lock4j:com.pack.test.lock4j.StorageServicedeductStorage#

当我们自定义了key后如下:

@Lock4j(key = "#storageId")
public void deductStorage(Long storageId, int count)

key支持Spring SpEL表达式,如上将生成如下的key

# 方法调用storageService.deductStorage(1, 2) ;
lock4j:com.pack.test.lock4j.StorageServicedeductStorage#1

你也可以不使用SpEL表达式。不使用SpEL表达式那么就需要使用如下语法

@Lock4j(keys = "'storageId'")
public void deductStorage(...) {}

没有使用单引号程序将会报错。

设置过期时间

默认获取锁超时3秒,30秒锁过期,可以通过如下属性配置过期时间

@Lock4j(keys = {"#storageId"}, expire = 3000, acquireTimeout = 3000)
public void deductStorage(Long storageId, int count) {}

expire: 锁过期时间(毫秒);注:锁过期时间必须要大于业务处理时间。acquireTimeout: 获取锁超时时间(毫秒)

以上是Lock4j的基本用法;下面将介绍Lock4j其它高级用法。

2.3 高级用法

全局统一配置

lock4j:
  acquire-timeout: 3000 
  expire: 30000
  primary-executor: com.baomidou.lock.executor.RedisTemplateLockExecutor
  lock-key-prefix: lock4j

primary-executor:配置加锁的实现方式;默认顺序是:
redisson > redisTemplate > zookeeper;如果你的环境中这3个都引入了,那么就是按照这个顺序,因为定义他们时使用了@Order注解声明顺序。lock-key-prefix:#锁前缀,如上面示例看到的lock4j为默认值。

自定义执行器(加锁)

我们可以通过实现LockExecutor接口定义自己的加锁实现,比如基于MySQL实现。如下:

@Component
public class JdbcLockExecutor implements LockExecutor {


  private final JdbcTemplate jdbcTemplate ;
  public JdbcLockExecutor(JdbcTemplate jdbcTemplate) {
    this.jdbcTemplate = jdbcTemplate ;
  }
  @Override
  public String acquire(String lockKey, String lockValue, long expire, long acquireTimeout) {
    // TODO; 获取锁
    return null ;
  }
  @Override
  public boolean releaseLock(String key, String value, String lockInstance) {
    // TODO; 释放锁
    return false;
  }
}

注:这里必须要注册为Spring Bean。否则将无法获取。使用如下:

@Lock4j(executor = JdbcLockExecutor.class)
public void deductStorage(Long storageId, int count) {}

加锁时会根据这里配置的executor Class对象获取Spring容器对应的bean对象。

自定义key生成器

Lock4j默认的锁key生成器为DefaultLockKeyBuilder,我们可以通过LockKeyBuilder接口实现自己的key生成方式

@Component
public class PackLockKeyBuilder implements LockKeyBuilder {


  @Override
  public String buildKey(MethodInvocation invocation, String[] definitionKeys) {
    // TODO; 生成key
    return null;
  }
}

注:这里也必须注册为bean对象。使用如下:

@Lock4j(keyBuilderStrategy = PackLockKeyBuilder.class)
public void deductStorage(Long storageId, int count) {}

内部会通过你这里配置的Class对象获取对应的Spring Bean实例对象。

自定义获取锁失败策略

当获取锁失败时如何进行处理?默认实现是DefaultLockFailureStrategy通过自定义LockFailureStrategy,实现自己的逻辑。与上面的套路一样都需要注册为bean。

@Component
public class PackLockFailureStrategy implements LockFailureStrategy {


  @Override
  public void onLockFailure(String key, Method method, Object[] arguments) {
    // TODO
  }
}

使用如下:

@Lock4j(failStrategy = PackLockFailureStrategy.class)
public void deductStorage(Long storageId, int count) {}

注:这里你也可以不指定failStrategy属性,会自动从容器中查找对应的实现Bean。

非注解实现方式(手动加锁/释放锁)

你也可以通过注入LockTemplate对象,由自己来完成加锁和释放锁的动作。

private final LockTemplate lockTemplate ;
  public StorageService(LockTemplate lockTemplate) {
    this.lockTemplate = lockTemplate ;
  }
  public void deductStorage(Long storageId, int count) {
    String key = "xxxx" ;
    final LockInfo lockInfo = lockTemplate.lock(key, 30000L, 5000L, RedisTemplateLockExecutor.class);
    if (null == lockInfo) {
        throw new RuntimeException("业务处理中,请稍后再试") ;
    }
    // 获取锁成功,处理业务
    try {
        // TODO
    } finally {
        // 释放锁
        lockTemplate.releaseLock(lockInfo) ;
    }
  }
}

手动加锁方式,一般适用于需要更细粒度控制锁边界,否则没必要。

来源:Spring全家桶实战案例源码内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯