您的位置:首页 > 数据库 > Redis

基于redis的分布式锁服务实现

2016-12-18 18:49 633 查看
一般的分布式锁服务要么是基于zk的,要么是基于redis,github上看了一个人写的基于redis的实现,感觉不够完美,下面是自己重新实现的。

本锁的使用场景如下:

确定锁的key值
构建一个锁对象,构造参数有jedis对象(一般从一个pool中get得来),超时毫秒数,锁失效毫秒数
调用锁的acquire()方法
执行业务操作
调用锁的release方法

使用本锁应该要遵从以下原则:

虽然本锁是线程安全的,但是本锁仅限于同一个线程创建锁对象,获取锁,释放锁,如违背了这些原则,会抛出RuntimeException异常

业务操作的执行时间必须要控制在锁失效毫秒内,不然本锁不确定有效

常见的编程模式如下:

@Test

    public void testLock() throws InterruptedException {

        String testLockKey = "testLockKey1";

        RedisLock rlock = new RedisLock(jedis, testLockKey, 10000, 6000);

        Assert.assertTrue(rlock.acquire());

         //do somehing

        rlock.release();

    }

锁的完整代码,请去github上下载,URL为:
https://github.com/tangaiyun/redislock
说句实话,这种无锁的线程安全的代码难度颇高的,没有5年以上java编程经验的人一般看不懂这代码为何这般写,希望高手批评指正,共同进步。

锁的更多使用例子请参考单元测试代码。

如有问题请联系QQ:15520929
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: