原文网址:lock4j--分布式锁中间件--使用/实例_IT利刃出鞘的博客-CSDN博客
简介说明
本文用示例介绍分布式锁中间件lock4j 的用法。
相关网址
gitee:https://gitee.com/baomidou/lock4j
github:https://github.com/baomidou/lock4j(Star数:68)
lock4j的参考项目:https://gitee.com/kekingcn/spring-boot-klock-starter
友情提示
本人实际使用lock4j过程中遇到了很多问题,不推荐使用lock4j,推荐直接使用redisson的分布式锁。
遇到的问题有:
- 获取锁超时时并没有抛异常,而是一直等待获取到锁
- lock4j与@Transactional类似:将注解写在方法上,自动控制上锁与释放锁。
- lock4j支持Redis(RedisTemplate或Redisson)、Zookeeper作为底层
- 2.0之后支持Redisson和Zookeeper
- 建议基于Redisson
- 原因:可以利用redisson的特性:自动续期等
- 方法:引入依赖:lock4j-redisson-spring-boot-starter
- 支持SPEL
- 执行顺序
- 如果在service上有@Transactional和@lock4j,则执行顺序如下
- 上锁
- 开启事务
- 执行逻辑
- 提交/回滚事务
- 释放锁
- 如果在service上有@Transactional和@lock4j,则执行顺序如下
- 实现原理
- AOP:Advisor + methodInterception
本文以Redisson为底层使用lock4j。
依赖com.baomidou lock4j-redisson-spring-boot-starter2.2.2
整个pom.xml
配置4.0.0 org.springframework.boot spring-boot-starter-parent2.4.13 com.knife.demo demo_lock4j_SpringBoot0.0.1-SNAPSHOT demo_lock4j_SpringBoot demo_lock4j_SpringBoot 1.8 org.springframework.boot spring-boot-starter-webcom.baomidou lock4j-redisson-spring-boot-starter2.2.2 org.projectlombok lomboktrue com.github.xiaoymin knife4j-spring-boot-starter3.0.3 org.springframework.boot spring-boot-maven-pluginorg.projectlombok lombok
application.yml
spring:
redis:
host: 192.168.5.193
port: 6379
password: 222333
#lock4j:
# acquire-timeout: 3000 #默认值3s,可不设置
# expire: 30000 #默认值30s,可不设置
# primary-executor: com.baomidou.lock.executor.RedissonLockExecutor #默认redisson > redisTemplate > zookeeper,可不设置
# lock-key-prefix: lock4j #锁key前缀, 默认值lock4j,可不设置
代码
Controller
本处直接将@Lock4j写到Controller方法上,实际开发中应该写到Service的实现类的方法上。
package com.knife.demo.controller;
import com.baomidou.lock.annotation.Lock4j;
import com.knife.demo.entity.User;
import io.swagger.annotations.Api;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@Api(tags = "用户")
@RestController
@RequestMapping("user")
public class UserController {
@GetMapping("listAll")
@Lock4j
public List listAllUser() {
return null;
}
@GetMapping("find")
@Lock4j(keys = {"#user.id", "#user.name"}, expire = 60000, acquireTimeout = 1000)
public List find(User user) {
return null;
}
}
Entity
package com.knife.demo.entity;
import lombok.Data;
@Data
public class User {
private Long id;
private String name;
}
测试
访问测试页面:http://localhost:8080/doc.html
测试1:无参数、无选项运行前的Redis:(没有数据)
打断点
访问接口
进入断点
查看Redis信息(写入了数据)
放开断点,方法执行结束(Redis数据被删除)
测试2:有参数、有选项运行前的Redis:(没有数据)
打断点
访问接口(id赋值为:123,name赋值为:Tony)
进入断点
查看Redis信息(写入了数据)
放开断点,方法执行结束(Redis数据被删除)



