国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

SpringBoot配置ShedLock分布式定時任務

瀏覽:3日期:2023-03-09 18:48:28
什么是ShedLock

ShedLock是一個在分布式環境中使用的定時任務框架,用于解決在分布式環境中的多個實例的相同定時任務在同一時間點重復執行的問題,解決思路是通過對公用的數據庫中的某個表進行記錄和加鎖,使得同一時間點只有第一個執行定時任務并成功在數據庫表中寫入相應記錄的節點能夠成功執行而其他節點直接跳過該任務。當然不只是數據庫,目前已經實現的支持數據存儲類型除了經典的關系型數據庫,還包括MongoDB,Zookeeper,Redis,Hazelcast。

如何使用

ShedLock采用非侵入式編程的思想,通過注解的方式來實現相應的功能。

要使用ShedLock,請執行以下操作

啟用并配置計劃鎖定 注釋您的計劃任務 配置鎖提供程序1.啟用并配置計劃鎖定

首先,引入依賴

< dependency > < groupId > net.javacrumbs.shedlock </ groupId > < artifactId > shedlock-spring </ artifactId > < version > 2.5.0 </ version ></ dependency >

現在我們需要將庫集成到Spring中。為了啟用計劃鎖定,請使用@EnableSchedulerLock注釋

@Configuration @EnableScheduling @EnableSchedulerLock(defaultLockAtMostFor = “ PT30S ”) 類 MySpringConfiguration { ... }

注釋您的計劃任務

import net.javacrumbs.shedlock.core.SchedulerLock ; ... @Scheduled(...)@ SchedulerLock(name = “ scheduledTaskName ”) public void scheduledTask(){ //做某事 }

@SchedulerLock注解一共支持五個參數,分別是

name 用來標注一個定時服務的名字,被用于寫入數據庫作為區分不同服務的標識,如果有多個同名定時任務則同一時間點只有一個執行成功lockAtMostFor 成功執行任務的節點所能擁有獨占鎖的最長時間,單位是毫秒mslockAtMostForString 成功執行任務的節點所能擁有的獨占鎖的最長時間的字符串表達,例如“PT14M”表示為14分鐘lockAtLeastFor 成功執行任務的節點所能擁有獨占所的最短時間,單位是毫秒mslockAtLeastForString 成功執行任務的節點所能擁有的獨占鎖的最短時間的字符串表達,例如“PT14M”表示為14分鐘

與Spring進行整合,ShedLock支持兩種Spring集成模式。

TaskScheduler代理

需要配置兩個Bean,一個是lockProvider,一個是scheduler

默認情況下,ShedLock在Spring周圍創建AOP代理TaskScheduler。如果未指定任務計劃程序,則會為您創建默認任務計劃程序。如果您有特殊需求,只需創建一個bean實現TaskScheduler接口,它將自動包裝到AOP代理中。

由于ShedLock使用Mongo,JDBC數據庫,Redis,Hazelcast,ZooKeeper等外部存儲進行協調。所以我選擇的是redis。

<dependency> <groupId> net.javacrumbs.shedlock </ groupId > <artifactId > shedlock-provider-redis-spring </ artifactId > <version> 2.5.0 </version></dependency > <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>

@Configuration@EnableScheduling@EnableSchedulerLock(defaultLockAtMostFor = 'PT5M')public class ShedLockConfig { @Bean public LockProvider lockProvider(RedisTemplate redisTemplate){return new RedisLockProvider(redisTemplate.getConnectionFactory()); } @Bean public TaskScheduler taskScheduler(){ return new MySpecialTask​​Scheduler(); } }

SpringBoot配置ShedLock分布式定時任務

預定方法代理

如果你有更多特殊需求,可以像這樣使用Scheduled Method代理

@EnableSchedulerLock(mode = PROXY_METHOD,defaultLockAtMostFor = “ PT30S ”)

如果PROXY_METHOD選擇了mode,則ShedLock會在每個帶@SchedulerLock注釋的方法周圍創建AOP代理。這種方法的主要優點是它不依賴于Spring調度。缺點是即使您直接調用該方法也會應用鎖定。還要注意,目前僅支持void返回方法,如果您注釋并調用具有非void返回類型的方法,則會引發異常。

SpringBoot配置ShedLock分布式定時任務

到此這篇關于SpringBoot配置ShedLock分布式定時任務的文章就介紹到這了,更多相關SpringBoot ShedLock分布式定時任務內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 国产精品欧美亚洲韩国日本不卡 | 久久亚洲国产精品一区二区 | 国产三级播放 | 免费一级毛片免费播放 | 成年人免费大片 | 成人欧美一区二区三区视频 | 国产成人午夜福在线观看 | 中文字幕人成不卡一区 | tube69xxx最新片| 欧美亚洲国产成人综合在线 | 在线亚洲综合 | 国产aaa女人十八毛片 | 日韩欧美在线一级一中文字暮 | 中国一级特黄大片毛片 | 国产麻豆一级在线观看 | 亚洲国产精品成人午夜在线观看 | 台湾三级香港三级经典三在线 | 精品视频在线播放 | 自拍偷拍亚洲区 | 日本农村寡妇一级毛片 | 国产成人在线视频播放 | 性配久久久 | 亚洲小视频 | 亚洲在线视频免费 | 久久毛片网站 | 中文一级国产特级毛片视频 | 亚洲精品欧美精品 | 男女男精品视频在线播放 | 国产亚洲高清不卡在线观看 | 一级国产交换配乱淫 | 国产一区二区久久久 | 国产精品一区二区手机在线观看 | 亚洲 欧美 日韩 丝袜 另类 | 久久综合精品不卡一区二区 | 一级做人爱a视频正版免费 一级做性色a爱片久久片 | aaa免费毛片 | 久久亚洲精品国产精品777777 | 亚洲天堂久久精品 | 怡红院免费va男人的天堂 | 久久在线 | 欧美高清色视频在线播放 |