分布式锁及其常见实现方式

　　1。什么是分布式锁？
　　在分布式系统中，为了保证对数据的修改有最终一致性，通常使用分布式锁或者分布式事务。比如常见的多个系统同时修改商品，既依赖于现有数据也要修改数据，如果没有限制，高并发情况下很可能最终数据是错误的。
　　与单机锁不同，分布式锁更加复杂，需要考虑网络延迟、服务阻塞等，通常具有如下特点：同一时间只能有一个线程拥有锁；高可用，获取和释放锁必须可靠；高性能，获取和释放锁必须快速完成；可重入，已获取锁的线程可以再次获取锁而不会发生死锁；过期失效，避免死锁；阻塞（根据业务需要）。2。基于数据库实现分布式锁2。1基于表主键唯一实现分布式锁
　　利用数据库主键唯一的特性，可以基于唯一主键保证多次操作只有一次成功。在数据库中创建一个表，表中包含方法名等字段，并在方法名字段上创建唯一索引，想要执行某个方法，就使用这个方法名向表中插入数据，成功插入则获取锁，执行完成后删除对应的行数据释放锁。释放锁时，直接删除数据库记录即可。
　　此方案存在的问题是强依赖数据库，容易形成热点，数据库锁表导致的超时会影响性能，或者数据库宕机会导致服务不可用。并且，数据库本身没有失效机制，如果任务崩溃会导致数据库中的锁不能被释放。数据库插入操作本身没有阻塞机制，故无法实现分布式锁的阻塞等待，任务线程可能需要重复尝试插入。由于唯一主键的存在，持有锁的线程也无法重复获得锁，其他线程竞争锁的过程中也无法根据优先级进行分配。2。2基于表字段版本号做分布式锁
　　在数据库中为表增加一个版本号字段，每次操作时判断版本号，只有版本号一致才能进行对应的修改，修改后版本号加1，通过CAS的方式进行修改。
　　此实现会增加数据库操作的次数，高并发情况下可能性能不好。2。3基于数据库排他锁做分布式锁
　　forupdate是一种行级锁，又叫排它锁，一旦用户对某个行施加了行级加锁，则该用户可以查询也可以更新被加锁的数据行，其它用户只能查询但不能更新被加锁的数据行。我们可以认为获得排他锁的线程即获得分布式锁，任务执行完成后通过commit来释放锁。forupdate语句会在执行成功后立即返回，在执行失败时一直处于阻塞状态，直到成功。
　　注意：InnoDB引擎在加锁的时候，只有通过索引进行检索的时候才会使用行级锁，否则会使用表级锁。这里我们希望使用行级锁，就要给要执行的方法字段名添加索引，值得注意的是，这个索引一定要创建成唯一索引，否则会出现多个重载方法之间无法同时被访问的问题。重载方法的话建议把参数类型也加上。
　　但是MySQL会对查询进行优化，即便在条件中使用了索引字段，但是否使用索引来检索数据是由MySQL通过判断不同执行计划的代价来决定的，如果MySQL认为全表扫效率更高，比如对一些很小的表，它就不会使用索引，这种情况下InnoDB将使用表锁，而不是行锁。3。基于Redis实现分布式锁3。1setnx（）、expire（）方法实现分布式锁
　　setnx的含义就是SETifNotExists，主要有两个参数setnx（key，value）。该方法是原子的，如果key不存在，则设置当前key成功，返回1；如果当前key已经存在，则设置当前key失败，返回0。setnx命令不能设置key的超时时间，只能通过expire（）来设置。
　　锁的实现步骤：调用setnx（lockkey，1）获取锁。如果返回1，则获取锁成功。调用expire（）命令对lockkey设置超时时间。执行完业务代码后，通过delete命令删除lockkey。
　　这个方案如果在第一步setnx执行成功后，在expire（）命令执行成功前，发生了宕机的现象，那么就依然会出现死锁的问题。3。2setnx（）、get（）、getset（）方法实现分布式锁
　　这个方案是对上一个方案的优化版本。
　　getset（）命令主要有两个参数getset（key，newValue）。该方法是原子的，对key设置newValue这个值，并且返回key原来的旧值。假设key原来是不存在的，那么首次执行的返回值是null。
　　锁的实现步骤：调用setnx（lockkey，当前时间过期超时时间）获取锁。如果返回1，则获取锁成功。如果返回0，则获取锁失败，进一步调用get方法判断。get（lockkey）获取上次设置的过期时间oldExpireTime。如果oldExpireTime小于当前系统时间，则认为这个锁已经超时，进一步调用getset方法判断。getset（lockkey，newExpireTime当前时间过期超时时间）设置新的过期时间newExpireTime，并返回之前的值currentExpireTime。如果currentExpireTime与oldExpireTime相等，则获取锁成功，不相等则说明锁被其他请求抢走了。执行完业务代码后，要判断下锁有没有超时，如果没有超时通过delete命令删除lockkey，如果超时了则不处理（可能已被抢走）。
　　这个方案在任务处理超时或发生宕机时，无需担心锁超时问题，下次请求可以判断出实际上锁已经超时了。4。基于ZooKeeper实现分布式锁
　　zookeeper由多个节点构成（单数），采用zab一致性协议。因此可以将zk看成一个单点结构，对其修改数据其内部自动将所有节点数据进行修改而后才提供查询服务。
　　zookeeper数据是目录树的形式，每个目录称为znode，znode中可存储数据（一般不超过1M），还可以在其中增加子节点。
　　子节点有三种类型。序列化节点，每在该节点下增加一个节点自动给该节点的名称上自增。临时节点，一旦创建这个znode的客户端与服务器失去联系，这个znode也将自动删除。普通节点。
　　zookeeper提供了Watch机制，client可以监控每个节点的变化，当产生变化会给client产生一个事件。
　　可以利用临时节点与watch机制实现分布式锁。每个锁占用一个普通节点lock，当需要获取锁时在lock目录下创建一个临时节点，创建成功则表示获取锁成功，失败则watchlock节点，有删除操作后再去争锁。临时节点好处在于当进程挂掉后锁的节点自动删除不会发生死锁。
　　缺点在于所有取锁失败的进程都监听父节点，很容易发生羊群效应，即当释放锁后所有等待进程一起来创建节点，并发量很大。
　　一个可行的优化方案是上锁改为创建临时有序节点，每个上锁的节点均能创建节点成功，只是其序号不同。只有序号最小的可以拥有锁，如果这个节点序号不是最小的则watch序号比本身小的前一个节点（公平锁）。watch事件到来后，再次判断是否序号最小。取锁成功则执行代码，最后释放锁（删除该节点）。
　　性能上可能没有缓存服务那么高，因为每次在创建锁和释放锁的过程中，都要动态创建、销毁临时节点来实现锁功能。zookeeper中创建和删除节点只能通过Leader服务器来执行，然后将数据同步到所有的Follower机器上。5。总结
　　分布式锁比较复杂，也比较容易发生死锁。目前主流的实现方式包括：基于数据库实现分布式锁。基于Redis实现分布式锁。基于ZooKeeper实现分布式锁。
　　分布式锁及其常见实现方式程序之心