基于Redisson的分布式锁注解工具

原创工具

java

发布日期: 2022-02-24

作者: duan

文章字数: 360

阅读时长: 1 分

阅读次数:

使用方法

添加依赖

  <repositories>
        <repository>
        <id>jitpack.io</id>
        <url>https://jitpack.io</url>
        </repository>
 </repositories>

  <dependency>
        <groupId>com.gitee.godchin</groupId>
        <artifactId>common</artifactId>
        <version>1.0.0</version>
    </dependency>

首先配置Redis

#Redis服务器地址
spring.redis.host=121.36.72.23
spring.redis.password=root
#Redis服务器连接端口
spring.redis.port=6379
#Redis数据库索引（默认为0）
spring.redis.database= 0

开启扫描包

@ComponentScan( basePackages = {"com.itdfq.common","com.itdfq.loginuser"})

com.itdfq.common 是工具包的包名，让项目进行扫描，com.itdfq.loginuser 是本地项目的包接口

使用注解@DisLock

public @interface DisLock {
        //锁的key，如果不填默认是包名+类名+参数名
    String key() default "";

        //过期时间
    long expire() default 600L;

        //等待获取锁时间
    long waitTime() default 10000L;
        //是否抛出异常
    boolean throwExceptionIfFailed() default true;
}

例子

在Redis中定义了study:lock:sum 的值为50,使用jMether创建100个线程并发操作，模拟用户批量下单
Redis库存

操作代码：

          Integer sum = (Integer) redisTemplate.opsForValue().get(KEY);
        if (sum > 0) {
            redisTemplate.opsForValue().set(KEY, sum - 1, EXPIRE_SECOND, TimeUnit.SECONDS);
            return Result.success("购买成功，剩余库存" + (sum - 1));
        }

使用注解加锁

 @DisLock
    public Result lockTest() {
        Integer sum = (Integer) redisTemplate.opsForValue().get(KEY);
        if (sum > 0) {
            redisTemplate.opsForValue().set(KEY, sum - 1, EXPIRE_SECOND, TimeUnit.SECONDS);
            return Result.success("购买成功，剩余库存" + (sum - 1));
        }
        return Result.fail("没有库存");
    }

创建Controller测试

/**
 * @author GodChin
 * @date 2022/2/24 10:23
 * @email 909256107@qq.com
 */
@RestController
@RequestMapping("/lock")
public class RedisLockTestController {
    @Autowired
    private RedisService lockTestService;

    @GetMapping("/submit3")
    public Result submit3() {
        return lockTestService.lockTest();
    }
}