您好,登錄后才能下訂單哦!
參考文檔: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進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。