参考文档:http://redis.io/topics/distlock
分布式全局锁用在:分布式定时任务(执行前取锁),问医生(医生回答问题前取锁)
设计原理:使用redis SET resource_name my_random_value NX PX 30000,当键不存在时才set值,键为锁的标识,值为该锁的删除验证码,用于删除锁时使用
具体流程:1.操作前拿锁,并设置删除码。2.执行业务操作。3.通过锁键拿到锁值,如果锁值与之前设置的删除码一致,则删除该锁,如果不一致,则需要考虑锁过期,别人已经拿到锁做了相关业务,自己的业务是否需要回滚。
实际使用:
1.pom加入redis依赖:
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-redis</artifactId> </dependency>
2.application.properties 配置redis服务器
spring.application.name=provider-service #使用哨兵,不手动指定redis服务器 spring.redis.host=10.3.5.21 spring.redis.port=6379 #spring.redis.sentinel.master=master1 #spring.redis.sentinel.nodes=10.3.5.36:26379,10.3.5.38:26379 #微服务专用database 所有key需要以标准前缀(手动指定 微服务名: 或 缓存自动指定 类名完整路径) 不是该结构的key全部删除 spring.redis.database=2 spring.redis.timeout=10000
3.使用分布式全局锁
@Value("${spring.application.name}") private String appName; @Inject @Resource(name = "redisTemplate") private ValueOperations<String, String> valueOperations; @Scheduled(cron = "0 58 * * * ?") public void foo(){ if(!RedisDistributedLock.lock(valueOperations, appName+":lock_BarService.foo()", "", 60)){ System.out.println("EnableScheduling return."); return; } System.out.println("EnableScheduling "+System.currentTimeMillis()); }
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。