分布式锁与实现(一)——基于Redis实现

概述

目前几乎很多大型网站及应用都是分布式部署的,分布式场景中的数据一致性问题一直是一个比较重要的话题。分布式的CAP理论告诉我们“任何一个分布式系统都无法同时满足一致性(Consistency)、可用性(Availability)和分区容错性(Partition tolerance),最多只能同时满足两项。”所以,很多系统在设计之初就要对这三者做出取舍。在互联网领域的绝大多数的场景中,都需要牺牲强一致性来换取系统的高可用性,系统往往只需要保证“最终一致性”,只要这个最终时间是在用户可以接受的范围内即可。

在很多场景中,我们为了保证数据的最终一致性,需要很多的技术方案来支持,比如分布式事务、分布式锁等。

选用Redis实现分布式锁原因

  • Redis有很高的性能
  • Redis命令对此支持较好,实现起来比较方便

在此就不介绍Redis的安装了,具体在Linux和Windows中的安装可以查看我前面的博客。
http://www.cnblogs.com/liuyang0/p/6504826.html

使用命令介绍

SETNX

SETNX key val
当且仅当key不存在时,set一个key为val的字符串,返回1;若key存在,则什么都不做,返回0。

expire

expire key timeout
为key设置一个超时时间,单位为second,超过这个时间锁会自动释放,避免死锁。

delete

delete key
删除key

在使用Redis实现分布式锁的时候,主要就会使用到这三个命令。

实现

使用的是jedis来连接Redis。

实现思想

  • 获取锁的时候,使用setnx加锁,并使用expire命令为锁添加一个超时时间,超过该时间则自动释放锁,锁的value值为一个随机生成的UUID,通过此在释放锁的时候进行判断。
  • 获取锁的时候还设置一个获取的超时时间,若超过这个时间则放弃获取锁。
  • 释放锁的时候,通过UUID判断是不是该锁,若是该锁,则执行delete进行锁释放。

分布式锁的核心代码如下:

  1 package com.distribute;
  2 
  3 import redis.clients.jedis.Jedis;
  4 import redis.clients.jedis.JedisPool;
  5 import redis.clients.jedis.Transaction;
  6 import redis.clients.jedis.exceptions.JedisException;
  7 
  8 import java.util.List;
  9 import java.util.UUID;
 10 
 11 /**
 12  * Created by liuyang on 2017/4/20.
 13  */
 14 public class DistributedLock {
 15     private final JedisPool jedisPool;
 16 
 17     public DistributedLock(JedisPool jedisPool) {
 18         this.jedisPool = jedisPool;
 19     }
 20 
 21     /**
 22      * 加锁
 23      *
 24      * @param locaName       锁的key
 25      * @param acquireTimeout 获取超时时间
 26      * @param timeout        锁的超时时间
 27      * @return 锁标识
 28      */
 29     public String lockWithTimeout(String locaName, long acquireTimeout, long timeout) {
 30         Jedis conn = null;
 31         String retIdentifier = null;
 32         try {
 33             // 获取连接
 34             conn = jedisPool.getResource();
 35             // 随机生成一个value
 36             String identifier = UUID.randomUUID().toString();
 37             // 锁名,即key值
 38             String lockKey = "lock:" + locaName;
 39             // 超时时间,上锁后超过此时间则自动释放锁
 40             int lockExpire = (int) (timeout / 1000);
 41 
 42             // 获取锁的超时时间,超过这个时间则放弃获取锁
 43             long end = System.currentTimeMillis() + acquireTimeout;
 44             while (System.currentTimeMillis() < end) {
 45                 if (conn.setnx(lockKey, identifier) == 1) {
 46                     conn.expire(lockKey, lockExpire);
 47                     // 返回value值,用于释放锁时间确认
 48                     retIdentifier = identifier;
 49                     return retIdentifier;
 50                 }
 51                 // 返回-1代表key没有设置超时时间,为key设置一个超时时间
 52                 if (conn.ttl(lockKey) == -1) {
 53                     conn.expire(lockKey, lockExpire);
 54                 }
 55 
 56                 try {
 57                     Thread.sleep(10);
 58                 } catch (InterruptedException e) {
 59                     Thread.currentThread().interrupt();
 60                 }
 61             }
 62         } catch (JedisException e) {
 63             e.printStackTrace();
 64         } finally {
 65             if (conn != null) {
 66                 conn.close();
 67             }
 68         }
 69         return retIdentifier;
 70     }
 71 
 72     /**
 73      * 释放锁
 74      *
 75      * @param lockName   锁的key
 76      * @param identifier 释放锁的标识
 77      * @return
 78      */
 79     public boolean releaseLock(String lockName, String identifier) {
 80         Jedis conn = null;
 81         String lockKey = "lock:" + lockName;
 82         boolean retFlag = false;
 83         try {
 84             conn = jedisPool.getResource();
 85             while (true) {
 86                 // 监视lock,准备开始事务
 87                 conn.watch(lockKey);
 88                 // 通过前面返回的value值判断是不是该锁,若是该锁,则删除,释放锁
 89                 if (identifier.equals(conn.get(lockKey))) {
 90                     Transaction transaction = conn.multi();
 91                     transaction.del(lockKey);
 92                     List<Object> results = transaction.exec();
 93                     if (results == null) {
 94                         continue;
 95                     }
 96                     retFlag = true;
 97                 }
 98                 conn.unwatch();
 99                 break;
100             }
101         } catch (JedisException e) {
102             e.printStackTrace();
103         } finally {
104             if (conn != null) {
105                 conn.close();
106             }
107         }
108         return retFlag;
109     }
110 }

测试

下面就用一个简单的例子测试刚才实现的分布式锁。
例子中使用50个线程模拟秒杀一个商品,使用--运算符来实现商品减少,从结果有序性就可以看出是否为加锁状态。

模拟秒杀服务,在其中配置了jedis线程池,在初始化的时候传给分布式锁,供其使用。

 1 import redis.clients.jedis.JedisPool;
 2 import redis.clients.jedis.JedisPoolConfig;
 3 
 4 /**
 5  * Created by liuyang on 2017/4/20.
 6  */
 7 public class Service {
 8     private static JedisPool pool = null;
 9 
10     static {
11         JedisPoolConfig config = new JedisPoolConfig();
12         // 设置最大连接数
13         config.setMaxTotal(200);
14         // 设置最大空闲数
15         config.setMaxIdle(8);
16         // 设置最大等待时间
17         config.setMaxWaitMillis(1000 * 100);
18         // 在borrow一个jedis实例时,是否需要验证,若为true,则所有jedis实例均是可用的
19         config.setTestOnBorrow(true);
20         pool = new JedisPool(config, "127.0.0.1", 6379, 3000);
21     }
22 
23     DistributedLock lock = new DistributedLock(pool);
24 
25     int n = 500;
26 
27     public void seckill() {
28         // 返回锁的value值,供释放锁时候进行判断
29         String indentifier = lock.lockWithTimeout("resource", 5000, 1000);
30         System.out.println(Thread.currentThread().getName() + "获得了锁");
31         System.out.println(--n);
32         lock.releaseLock("resource", indentifier);
33     }
34 }

 

// 模拟线程进行秒杀服务

 1 public class ThreadA extends Thread {
 2     private Service service;
 3 
 4     public ThreadA(Service service) {
 5         this.service = service;
 6     }
 7 
 8     @Override
 9     public void run() {
10         service.seckill();
11     }
12 }
13 
14 public class Test {
15     public static void main(String[] args) {
16         Service service = new Service();
17         for (int i = 0; i < 50; i++) {
18             ThreadA threadA = new ThreadA(service);
19             threadA.start();
20         }
21     }
22 }

 

结果如下,结果为有序的。

1 public void seckill() {
2     // 返回锁的value值,供释放锁时候进行判断
3     //String indentifier = lock.lockWithTimeout("resource", 5000, 1000);
4     System.out.println(Thread.currentThread().getName() + "获得了锁");
5     System.out.println(--n);
6     //lock.releaseLock("resource", indentifier);
7 }

从结果可以看出,有一些是异步进行的。

在分布式环境中,对资源进行上锁有时候是很重要的,比如抢购某一资源,这时候使用分布式锁就可以很好地控制资源。
当然,在具体使用中,还需要考虑很多因素,比如超时时间的选取,获取锁时间的选取对并发量都有很大的影响,上述实现的分布式锁也只是一种简单的实现,主要是一种思想。

下一次我会使用zookeeper实现分布式锁,使用zookeeper的可靠性是要大于使用redis实现的分布式锁的,但是相比而言,redis的性能更好。

上面的代码可以在我的GitHub中进行查看,地址如下:
https://github.com/yangliu0/DistributedLock

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/254530.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

浅析软件项目管理中十个误区(来自:http://manager.csdn.net/n/20051213/30907.html)

随着计算机硬件水平的不断提高&#xff0c;计算机软件的规模和复杂度也随之增加。计算机软件开发从“个人英雄”时代向团队时代迈进&#xff0c;计算机软件项目的管理也从“作坊式”管理向“软件工厂式”管理迈进。这就要求软件开发人员特别是软件项目管理人员更深一步地理解和…

俩孩随笔

俩孩随笔 有人给我贴了技术男加奶爸的标签&#xff0c;不过这两项都不是我的强项。我深知自己最大的长处在哪&#xff1a;普通&#xff0c;扔人堆里&#xff0c;不是认不出来&#xff0c;而是压根看不着。想把事情做好&#xff0c;常常会用力过度。工作平平淡淡&#xff0c;需…

Inpainting图像修复halcon算子,持续更新

目录harmonic_interpolationinpainting_anisoinpainting_cedinpainting_ctinpainting_mcfinpainting_textureharmonic_interpolation 功能&#xff1a;对一个图像区域执行谐波插值。 inpainting_aniso 功能&#xff1a;通过各向异性扩散执行图像修复。 inpainting_ced 功能…

算法(伪代码)的书写

q ⇒ Queue&#xff08;队列&#xff09;, s ⇒ Set&#xff08;集合&#xff09;pq ⇒ PriorityQueue&#xff08;优先队列&#xff09;d ⇒ distance1. initialization 变量&#xff0c;数据结构的定义&#xff0c;及初始值的赋值&#xff1b;比如著名的 Dijkstra &#xff0…

第八次作业——系统设计与团队分配(个人)

团队作业地址&#xff1a;https://www.cnblogs.com/clio-hhhhhhl/p/9079157.html 个人码云地址&#xff1a;https://gitee.com/Cliohl/events 团队码云地址&#xff1a;https://gitee.com/Cliohl/zhuoyue 项目进展&#xff1a; 上礼拜进展&#xff1a;把部分前端页面实现出来&a…

深入理解Activity启动流程(二)–Activity启动相关类的类图

本文原创作者:Cloud Chou. 欢迎转载&#xff0c;请注明出处和本文链接 本系列博客将详细阐述Activity的启动流程&#xff0c;这些博客基于Cm 10.1源码研究。 在介绍Activity的详细启动流程之前&#xff0c;先为大家介绍Activity启动时涉及到的类&#xff0c;这样大家可以有大概…

Lines色线halcon算子,持续更新

目录bandpass_imagelines_colorlines_facetlines_gaussbandpass_image 功能&#xff1a;使用带通滤波器提取边缘。 lines_color 功能&#xff1a;检测色线和它们的宽度。 lines_facet 功能&#xff1a;使用面模型检测线。 lines_gauss 功能&#xff1a;检测线和它们的宽…

疑问+软件

问题 1学好软件工程需要打好哪些基础&#xff1f; 2怎样学好软件工程&#xff1f; 3软件工程的发展前景如何&#xff1f; 4软件工程具体能从事哪些职业&#xff1f; 5怎样准确的找到自己的定位&#xff1f; 软件 1支付宝 优点&#xff1a;支付便捷&#xff0c;转账方便&#xf…

成功的项目管理

内容提要 第一讲 项目与项目管理 1.项目的基本概念 2.项目管理的概念 3.项目管理的重要性 第二讲 项目管理的最新发展 1.现代项目管理的创立过程 2.现代项目管理的发展趋势 3.项目管理流行的原因 第三讲 信息时代的项目管理 1.信息时代的特点 2.信息时代项目管理的特点 3.按项目…

5月23日

11.1 LAMP架构介绍一、LAMP架构介绍LAMP是LinuxApache(httpd)MySQLPHP的简写&#xff0c;即把Apache、MySQL以及PHP安装在linux系统上&#xff0c;组成一个运行环境来运行PHP脚本语言&#xff0c;通常是网站。比如Google、淘宝、百度、51cto博客、猿课论坛等就是用PHP语言写出来…

Kotlin入门简介

Kotlin的“简历” 来自于著名的IDE IntelliJ IDEA(Android Studio基于此开发) 软件开发公司 JetBrains(位于东欧捷克)起源来自JetBrains的圣彼得堡团队&#xff0c;名称取自圣彼得堡附近的一个小岛(Kotlin Island)一种基于JVM的静态类型编程语言语法简单&#xff0c;不啰嗦 1 2…

LaTeX基础一:安装与基本操作

一、安装 1.首先下载texlive2015.iso文件。再在解压的镜像文件中运行install-tl-advanced.bat批处理命令。注意要关闭杀毒软件&#xff0c;否则可能会出现错误。2.可以修改一下安装路径&#xff0c;只要更改一个&#xff0c;其他也随之更改&#xff1a;3.把不要安装的语言包去掉…

Match图像匹配halcon算子,持续更新

目录exhaustive_matchexhaustive_match_mggen_gauss_pyramidmonotonyexhaustive_match 功能&#xff1a;模板和图像的匹配。 exhaustive_match_mg 功能&#xff1a;在一个分辨率塔式结构中匹配模板和图像。 gen_gauss_pyramid 功能&#xff1a;计算一个高斯金字塔。 mono…

c++虚函数的前奏--函数指针与回调

声明函数指针并实现回调程序员常常需要实现回调。本文将讨论函数指针的基本原则并说明如何使用函数指针实现回调。注意这里针对的是普通的函数&#xff0c;不包括完全依赖于不同语法和语义规则的类成员函数&#xff08;类成员指针将在另文中讨论&#xff09;。 声明函数指针 …

你的微信,到底「连接」多少人?

作为一个技术人&#xff0c;用微信这么多年&#xff0c;也加了不少的好友和技术群。大半个月前&#xff0c;大概是5月初的时候&#xff0c;萌生了这个想法。 前后磕磕绊绊&#xff0c;经过了来美帝出差前期差点饿死、项目紧急期等艰难阶段以及各种自学、温习和设计&#xff0c;…

团队项目第一周总结

团队项目第一周总结 今天是周一&#xff0c;项目的进展周期已经进行了一周&#xff0c;做一个大概的总结吧。 周的工作先是定下团队的项目方向&#xff0c;大家技术程度各有不同&#xff0c;因此想大一统的定下一个有些稍稍的花费时间。定好《基于大数据的日志分析》这个题目后…

电路宽度测量halcon例子

一个halcon处理的例子 目录处理要求&#xff1a;原图&#xff1a;处理程序&#xff1a;处理结果&#xff1a;处理要求&#xff1a; 根据客户给的宽度&#xff0c;计算出电路宽度太窄的为NG 原图&#xff1a; 处理程序&#xff1a; read_image (Image, 1.png) rgb1_to_gray(I…

深入理解C/C++函数指针

函数指针数组的妙用 笔者在开发某软件过程中遇到这样一个问题&#xff0c;前级模块传给我二进制数据&#xff0c;输入参数为 char* buffer和 int length&#xff0c;buffer是数据的首地址&#xff0c;length表示这批数据的长度。数据的特点是&#xff1a;长度不定&#xff0c…

iOS显示性能优化过程讲解

点我跳转原文地址 卡顿的原理 iOS系统界面滑动流畅性的保持主要是依靠CPU和GPU两大处理硬件间通力合作的结果&#xff0c;一个视图的显示需要先经过CPU创建、布局计算、对图片解码、文本绘制&#xff0c;然后CPU将计算的结果交给GPU&#xff0c;GPU可能需要对图形进行变换、合成…

asp.net web api集成微信服务(使用Senparc微信SDK)

/// <summary>/// 微信请求转发控制器/// </summary>[RoutePrefix("weixin")]public class WeixinController : ApiController{#region 创建微信菜单/// <summary>/// 创建微信菜单/// </summary>/// <returns></returns>[HttpP…