本文共 1537 字，大约阅读时间需要 5 分钟。

主要是基于redis（利用setnx方法、或者lua脚本）信号变量来控制锁或者MySQL数据库的乐观锁进行处理。

一、基于redis的方式的分布式锁

setnx（set if not exists）是当不存在时进行设置，如果值已经存在则不进行设置。

根据这个特性，如果对要锁定的对象加上key，便可以实现分布式锁。

思路是：通过拦截的方式（系统设计），在拦截器中try catch,finaly中进行移除key，释放key资源；同时获取资源失败的进行限时时间内轮询获取资源key；redis中设置key时，需要加上失效时间，防止释放不成功的情况，出现永久阻塞。

可以看一下核心代码

@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface CacheLock {	String lockedPrefix() default "";//redis 锁key的前缀	long timeOut() default 2000;//锁时间	int expireTime() default 100000;//key在redis里存在的时间，1000S}

更多的参考，有具体的实现代码，

优化：防止所有请求都去抢占锁的情况，可以增加本地队列资源作为第一层锁，控制本地队列锁的长度（最大多少资源抢redis锁），如果长度超过服务降级。首先最大时间内先抢着进入队列，再队列内进行时间内抢真实资源。这样每个实例系统是一个队列内的线程抢占，达到了一定的限流的作用。

更多信息参考：

实现代码地址：

另外一个基于lua脚本，也是脚本中处理一些逻辑，代替setnx，原则上也是保证资源唯一获取，lua脚本是单线程执行的。

应用例子：生成唯一ID

二、基于MySQL数据库的乐观锁

这个更多的是利用数据库的锁，但是对数据库会造成压力。

可以利用乐观锁，生成唯一ID,先获取blocksize的数值进行分配,当分配完后再去数据库拿取新的block,去数据库取时加代码锁

public long newId() {		int value = RESIDUE_UPDATER.getAndIncrement(this);		if (value >= blockSize) {			synchronized (this) {				value = residue;				if (value >= blockSize) {					LOCAL_UPDATER.set(this, service.getNewBlock(name, residue));					RESIDUE_UPDATER.set(this, 0);				}				return newId();			}		}		return local + value;	}

public long getNewBlock(String name, int step) {		long ret;		Long dbId = null;		while (true) {			try {				dbId = getDBId(name, step) - step;			} catch (Exception e) {				log.warn("获取数据库ID错误(name={},step={},err={}", name, step, e.getLocalizedMessage());			}			if (dbId != null) {				ret = dbId;				break;			}		}		return ret;	}

转载地址：http://wwodi.baihongyu.com/