开发者

Java实现开箱即用的redis分布式锁

目录
  • 项目简介
    • 目的
  • 快速开始
    • 需要
    • maven 引入
    • 入门例子
  • 整合 spring
    • maven 引入
    • 指定 bean 使用
    • aop 注解使用
  • spring boot 整合
    • maven 引入
    • 使用
  • 后期 Road-MAP

    项目简介

    lock 为 Java 设计的分布式锁,开箱即用,纵享丝滑。

    开源地址:https://github.com/houbb/lock

    目的

    • 开箱即用,支持注解式和过程式调用
    • 基于 Redis 的分布式锁
    • 内置支持多种 redis 的整合方式
    • 渐进式设计,可独立于 spring 使用
    • 整合 spring
    • 整合 spring-boot

    快速开始

    需要

    jdk1.7+

    maven 3.x+

    maven 引入

    <dependency>
        <groupId>com.github.houbb</groupId>
        <artifactId>lock-core</artifactId>
        <version>1.3.0</version>
    </dependency>
    

    入门例子

    基于本地 redis 的测试案例。

    public void helloTest() {
        ILock lock = LockBs.newInstance();
        String key = "ddd";
        try {
            // 加锁
            lock.tryLock(key);
            System.out.println("业务处理");
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            // 释放锁
            lock.unlock(key);
        }
    }
    

    配置化

    为了便于拓展,LockBs 的配置支持自定义:

    LockBs.newInstance()
            .id(Ids.uuid32())   //id 生成策略
            .cache(JedisRedisServiceFactory.pooled("127.0.0.1", 6379)) //缓存策略
            .lockSupport(new RedisLockSupport())    // 锁实现策略
            .lockKeyFormat(new LockKeyFormat())     // 针对 keyzKTgyIsS 的格式化处理策略
            .lockReleaseFailHandler(new LockReleaseFailHandler())   //释放锁失败处理
            ;
    

    整合 spring

    maven 引入

    <dependency>
        <groupId>com.github.houbb</groupId>
        <art开发者_JAVAifactId>lock-spring</artifactId>
        <version>1.3.0</version>
    </dependency>
    

    指定 bean 使用

    启用分布式锁

    @EnableLock 启用分布式锁。

    @EnableRedisConfig 启用 redis 的默认配置。

    @Configurable
    @ComponentScan(basePackages = "com.github.houbb.lock.test.service")
    @EnableLock
    @EnableRedisConfig
    public class SpringConfig {
    }
    

    EnabjavascriptleLock 注解说明,和引导类对应:

    public @interface EnableLock {
    
        /**
         * 唯一标识生成策略
         * @return 结果
         */
        String id() default "lockId";
    
        /**
         * 缓存实现策略 bean 名称
         *
         * 默认引入 redis-config 中的配置
         *
         * @return 实现
         */
        String cache() default "springRedisService";
    
        /**
         * 加锁 key 格式化策略
         * @return 策略
         */
        String lockKeyFormat() default "lockKeyFormat";
    
        /**
         * 锁释放失败处理类
         * @return 结果
         */
        String lockReleaseFailHandler() default "lockReleaseFailHandler";
    
    }
    

    其中 springRedisService 使用的是 redis-config 中的实现。

    对应注解 @EnableRedisConfig,redis 的配置信息如下:

    配置说明默认值
    redis.addressredis 地址127.0.0.1
    redis.portredis 端口6379
    redis.passwordredis 密码

    使用 LockBs

    我们可以直接 LockBs 的引导类,这种适合一些更加灵活的场景。

    @ContextConfiguration(classes = SpringConfig.class)
    @RunWith(SpringJUnit4ClassRunner.class)
    public class SpringServiceRawTest {
    
        @Autowired
        private UserService userService;
    
        @Autowired
        private LockBs lockBs;
    
        @Test
        public void queryLogTest() {
            final String key = "name";
            try {
                lockBs.tryLock(key);
                final String value = userService.rawUserName(1L);
            } catch (Exception exception) {
                throw new RuntimeException(exception);
            } finally {
                lockBs.unlock(key);
            }
        }
    
    }
    

    aop 注解使用

    指定方法注解

    当然,我们可以在方法上直接指定注解 @Lock,使用更加方便。

    直接使用,AOP 切面生效即可。

    @Service
    public class UserService {
    
        @Lock
        public String queryUserName(Long userId) {
        }
    
        @Lock(value = "#user.name")
        public void queryUserName2(User user) {
        }
    }
    

    @Lock 属性说明,value 用于指定 key,支持 SPEL 表达式。

    其他属性,和引导类的方python法参数一一对应。

    public @interface Lock {
    
        /**
         * 缓存的 key 策略,支持 SpEL
         * @return 结果
         */
        String value() default "";
    
        /**
         * 时间单位
         * @return 单位
         */
        TimeUnit timeUnit() default TimeUnit.SECONDS;
    
        /**
         * 等待锁时间
         * @return 等待锁时间
         */
        long waitLockTime() default 10;
    
        /**
         * 业务加锁时间
         * @return 加锁时间
         */
        long lockTime() default 60;
    
    }
    

    spring boot 整合

    maven 引入

    <dependency>
        <groupId>com.github.houbb</groupId>
        <artifactId>lock-springboot-starter</artijavascriptfactId>
        <version>1.3.0</version>
    </dependency>
    

    使用

    同 spring

    后期 Road-MAP

    支持锁的可重入

    持有锁的线程可以多次获取锁

    分布式锁注解支持

    以上就是Java实现开箱即用的redis分布式锁的详细内容,更多关于Java redis分布式锁的资料请关注我们其它android相关文章!

    0

    上一篇:

    下一篇:

    精彩评论

    暂无评论...
    验证码 换一张
    取 消

    最新开发

    开发排行榜