在分布式系统中，分布式锁是一个很常见的技术。即有很多个进程同时访问同一个共享资源没有同步访问，资源的载体可能是传统关系型数据库或者NoSQL。
如果是在单机环境中，可以使用ReentrantLock或者synchronized代码块来实现，然而这些在分布式环境下却不能满足要求。
例如有这样的一个场景：
多台服务器同时从MQ消息队列接消息，接到消息后的处理逻辑是：根据消息中的业务id去查询数据库，如果数据库中不存在，则插入，反之则更新。
这样就会出现这样一个问题：服务器A和服务器B中接收到的消息中业务id是一样的，2台服务器同时到数据库中查询，都不存在，则都会进行插入操作，最后的结果是表中有2条一样的记录(或者有主键约束的话报主建不唯一异常插入失败)，显然这不是我能所期望的！
分布式环境中多台服务器相当于多个独立的jvm环境，有多个进程(注意不是线程)对同一资源进行操作，jdk中用作同步的Lock或者synchronized就会失效。
这里就需要用到分布式锁，目前实现分布式锁的主要技术大概有：
-
基于Redis实现(或者其他缓存memcached，tair)，主要基于redis的setnx（set if not exist）命令；
-
基于Zookeeper实现；
-
基于数据库表version字段实现，乐观锁，两个线程可以同时读取到原有的version值，但是最终只有一个可以完成操作；
下面是redis实现分布式锁的方法，主要用到了Redisson，它是redis官方推荐的分布式java客户端，和Jedis相比它实现了分布式和可扩展的java数据结构，
这里有一篇对比文章：Jedis与Redisson选型对比
Redisson的介绍可以到：https://github.com/redisson/redisson/wiki/1.-%E6%A6%82%E8%BF%B0 这里去了解！
具体实现代码：
import org.redisson.Config; import org.redisson.Redisson; import org.redisson.RedissonClient; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * * @author created by dehong * @date 2018年3月4日 下午4:12:42 * */ public class RedissonManager { private static final Logger logger = LoggerFactory.getLogger(RedissonManager.class); private static RedissonClient redisson; //private static Config config; /** * 通过配置文件初始化 */ static{ logger.info("init redisson ..."); Config config = null; try { config = Config.fromYAML(RedissonManager.class.getClassLoader().getResourceAsStream("redisson.yaml")); //config = Config.fromJSON(RedissonManager.class.getClassLoader().getResourceAsStream("redisson.json")); } catch (Exception e) { logger.error("RedissonClient init failed !", e); } redisson = Redisson.create(config); } /** * 获取Redisson的实例对象 * @return */ public static Redisson getRedisson(){ if(redisson == null){ logger.info("RedissonClient init failed !"); return null; } return (Redisson) redisson; } /** * 测试Redisson是否正常 * @param args */ public static void main(String[] args) { Redisson redisson = RedissonManager.getRedisson(); System.out.println("redisson = " + redisson); } }
上面的RedissonClient初始化是用配置文件yaml的形式，也可以用json，可以去参考官方文档 https://github.com/redisson/redisson
yaml示例(单机redis节点模式)
--- singleServerConfig: idleConnectionTimeout: 10000 pingTimeout: 1000 connectTimeout: 10000 timeout: 3000 retryAttempts: 3 retryInterval: 1500 reconnectionTimeout: 3000 failedAttempts: 3 password: null subscriptionsPerConnection: 5 clientName: null address: - redis://192.168.43.84:6379 subscriptionConnectionMinimumIdleSize: 1 subscriptionConnectionPoolSize: 50 connectionMinimumIdleSize: 32 connectionPoolSize: 64 database: 0 dnsMonitoring: false dnsMonitoringInterval: 5000
工具类：
import java.util.concurrent.TimeUnit; import org.redisson.Redisson; import org.redisson.core.RLock; /** * * @author created by dehong * @date 2018年3月4日 下午4:30:11 * Redisson分布式锁 工具类 */ public class RedissonLockUtil { private static Redisson redisson = RedissonManager.getRedisson(); private static final String LOCK_FLAG = "redissonlock_"; /** * 根据name对进行上锁操作，redissonLock 阻塞事的，采用的机制发布/订阅 * @param key */ public static void lock(String key){ String lockKey = LOCK_FLAG + key; RLock lock = redisson.getLock(lockKey); //lock提供带timeout参数，timeout结束强制解锁，防止死锁 ：1分钟 lock.lock(1, TimeUnit.MINUTES); } /** * 根据name对进行解锁操作 * @param key */ public static void unlock(String key){ String lockKey = LOCK_FLAG + key; RLock lock = redisson.getLock(lockKey); //如果锁被当前线程持有，则释放 if(lock.isHeldByCurrentThread()){ lock.unlock(); } } }
注意：上面的unlock()中不加isHeldByCurrentThread()条件的话，在执行的task的时间超过timeout时，此时如果unlock，其实redisson已经主动unlock了，就会出现IllegalMonitorStateException 异常
调用：
try { //获取锁，这里的key可以上面场景中的业务id RedissonLockUtil.lock(key); //具体要执行的代码.... } catch (Exception e) { e.printStackTrace(); }finally { //释放锁 RedissonLockUtil.unlock(key); }