5、如何处理异常情况？比如一个线程把一个商品上了锁，但是由于各种原因，没有完成操作（在上面的业务场景里就是没有将库存-1写入数据库），自然没有释放锁，这个情况笔者加入了锁超时机制，利用redis的expire命令为key设置超时时长，过了超时时间redis就会将这个key自动删除，即强制释放锁（可以认为超时释放锁是一个异步操作，由redis完成，应用程序只需要根据系统特点设置超时时间即可） 。
talk is cheap,show me the code
在代码实现层面，注解有并发的方法和参数，通过动态代理获取注解的方法和参数，在代理中加锁，执行完被代理的方法后释放锁 。
几个注解定义：
cachelock是方法级的注解，用于注解会产生并发问题的方法:
@Target(ElementType.PARAMETER)@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface LockedObject { //不需要值}LockedComplexObject也是参数级的注解，用于注解自定义类型的参数：
【基于redis分布式锁实现“秒杀”】@Target(ElementType.PARAMETER)@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface LockedComplexObject { String field() default "";//含有成员变量的复杂对象中需要加锁的成员变量，如一个商品对象的商品ID}CacheLockInterceptor实现InvocationHandler接口，在invoke方法中获取注解的方法和参数，在执行注解的方法前加锁，执行被注解的方法后释放锁：
public class CacheLockInterceptor implements InvocationHandler{ public static int ERROR_COUNT = 0; private Object proxied; public CacheLockInterceptor(Object proxied) { this.proxied = proxied; } @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { CacheLock cacheLock = method.getAnnotation(CacheLock.class); //没有cacheLock注解，pass if(null == cacheLock){ System.out.println("no cacheLock annotation");return method.invoke(proxied, args); } //获得方法中参数的注解 Annotation[][] annotations = method.getParameterAnnotations(); //根据获取到的参数注解和参数列表获得加锁的参数 Object lockedObject = getLockedObject(annotations,args); String objectValue = https://www.isolves.com/it/sjk/Redis/2019-08-21/lockedObject.toString(); //新建一个锁 RedisLock lock = new RedisLock(cacheLock.lockedPrefix(), objectValue); //加锁 boolean result = lock.lock(cacheLock.timeOut(), cacheLock.expireTime()); if(!result){//取锁失败 ERROR_COUNT += 1; throw new CacheLockException("get lock fail"); } try{ //加锁成功，执行方法 return method.invoke(proxied, args); }finally{ lock.unlock();//释放锁 } } /** ** @param annotations * @param args * @return * @throws CacheLockException */ private Object getLockedObject(Annotation[][] annotations,Object[] args) throws CacheLockException{ if(null == args || args.length == 0){ throw new CacheLockException("方法参数为空，没有被锁定的对象"); } if(null == annotations || annotations.length == 0){ throw new CacheLockException("没有被注解的参数"); } //不支持多个参数加锁，只支持第一个注解为lockedObject或者lockedComplexObject的参数 int index = -1;//标记参数的位置指针 for(int i = 0;i < annotations.length;i++){ for(int j = 0;j < annotations[i].length;j++){ if(annotations[i][j] instanceof LockedComplexObject){//注解为LockedComplexObject index = i; try { return args[i].getClass().getField(((LockedComplexObject)annotations[i][j]).field()); } catch (NoSuchFieldException | SecurityException e) { throw new CacheLockException("注解对象中没有该属性" + ((LockedComplexObject)annotations[i][j]).field()); } } if(annotations[i][j] instanceof LockedObject){ index = i; break; } } //找到第一个后直接break，不支持多参数加锁 if(index != -1){ break; } } if(index == -1){ throw new CacheLockException("请指定被锁定参数"); } return args[index]; }}最关键的RedisLock类中的lock方法和unlock方法：
/** * 加锁 * 使用方式为： * lock(); * try{ * executeMethod(); * }finally{ * unlock(); * } * @param timeout timeout的时间范围内轮询锁 * @param expire 设置锁超时时间 * @return 成功 or 失败 */ public boolean lock(long timeout,int expire){ long nanoTime = System.nanoTime(); timeout *= MILLI_NANO_TIME; try { //在timeout的时间范围内不断轮询锁 while (System.nanoTime() - nanoTime < timeout) { //锁不存在的话，设置锁并设置锁过期时间，即加锁 if (this.redisClient.setnx(this.key, LOCKED) == 1) { this.redisClient.expire(key, expire);//设置锁过期时间是为了在没有释放 //锁的情况下锁过期后消失，不会造成永久阻塞 this.lock = true; return this.lock; } System.out.println("出现锁等待"); //短暂休眠，避免可能的活锁 Thread.sleep(3, RANDOM.nextInt(30)); }} catch (Exception e) { throw new RuntimeException("locking error",e); } return false; } public void unlock() { try { if(this.lock){ redisClient.delKey(key);//直接删除 } } catch (Throwable e) { } }
推荐阅读
- 分布式系统常见概念
- Redis深度历险，最全命令总结
- 如何基于 MySQL 主从模式搭建上万并发的系统架构？
- 分布式系统：Zookeeper一致性级别分析
- 推荐一款nginx+redis+ehcache高并发与高可用缓存架构
- Redis 核心原理和架构
- 关于redis学会这8点就够了
- Redis实现统计网站访问人数的功能
- 如何做可靠的分布式锁，Redlock真的可行么
- 了解分布式架构，让你的软件架构之路越走越顺