倘若我心中的山水,你眼中都看到,我便一步一莲花祈祷,怎知那浮生一片草,岁月催人老,风月花鸟一笑尘缘了。
针对多个进程访问共享资源而提供的同步方案,保证共享资源的正确性,某一时刻锁定全局资源,让进程串行化执行,能有效避免共享资源被多个进程同时访问时候出现的数据正确性问题。比如防止重复下单、解决业务层幂等问题、解决消息队列重复消费问题、解决数据不一致问题等。使用分布式锁可以保证在分布式部署的应用集群中,同一个方法在同一时间只能被一台机器上的一个线程执行。具体实现如下:
定义注解
- @Target({ElementType.PARAMETER, ElementType.METHOD})
- @Retention(RetentionPolicy.RUNTIME)
- @Documented
- public @interface RedisLock {
- /**
- * 锁的名称(唯一标识),可选为""时候使用方法的名称
- */
- String name() default "";
-
- /**
- * 重试重获取锁的次数,默认0 不重试
- */
- int retry() default 0;
-
- /**
- * 占有锁的时间,避免程序宕机导致锁无法释放
- */
- int expired() default 60;
-
- }
一个最基本的分布式锁需要满足:
互斥 :任意一个时刻,锁只能被一个线程持有。
高可用 :锁服务是高可用的。并且,即使客户端的释放锁的代码逻辑出现问题,锁最终一定还是会被释放,不会影响其他线程对共享资源的访问。
可重入:一个节点获取了锁之后,还可以再次