建站
咨詢
售后
建站咨詢
新聞中心
大家好，我是冰河~~
成都創(chuàng)新互聯(lián)公司堅(jiān)信：善待客戶，將會(huì)成為終身客戶。我們能堅(jiān)持多年，是因?yàn)槲覀円恢笨芍档眯刨?。我們從不忽悠初訪客戶，我們用心做好本職工作，不忘初心，方得始終。10余年網(wǎng)站建設(shè)經(jīng)驗(yàn)成都創(chuàng)新互聯(lián)公司是成都老牌網(wǎng)站營銷服務(wù)商,為您提供網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、網(wǎng)站設(shè)計(jì)、H5頁面制作、網(wǎng)站制作、高端網(wǎng)站設(shè)計(jì)、微信平臺(tái)小程序開發(fā)服務(wù),給眾多知名企業(yè)提供過好品質(zhì)的建站服務(wù)。
最近有小伙伴出去面試，回來跟我說：冰河，我去XXX公司面試，面試官竟然問了我一個(gè)關(guān)于Spring中Scheduled和Async調(diào)度的問題，我竟然沒回答上來，你能不能寫一篇關(guān)于這個(gè)問題的文章呢?我：可以，安排上!于是便有了這篇文章。
好了，我們開始正文吧~~
Spring調(diào)度的兩種方式
Spring提供了兩種后臺(tái)任務(wù)的方法,分別是:
- 調(diào)度任務(wù)，@Schedule
- 異步任務(wù)，@Async
當(dāng)然，使用這兩個(gè)是有條件的，需要在spring應(yīng)用的上下文中聲明 當(dāng)然，如果我們是基于java配置的，需要在配置類上加@EnableScheduling和@EnableAsync注解，例如，下面的代碼片段。
- @EnableScheduling
- @EnableAsync
- public class WebAppConfig {
- ....
- ｝
除此之外，還是有第三方庫可以調(diào)用的，例如Quartz，文章最后我們?cè)俸唵翁嵯翾uartz。
@Schedule調(diào)度
先看下@Schedule怎么調(diào)用再說。
- public final static long ONE_DAY = 24 * 60 * 60 * 1000;
- public final static long ONE_HOUR = 60 * 60 * 1000;
- @Scheduled(fixedRate = ONE_DAY)
- public void scheduledTask() {
- System.out.println(" 我是一個(gè)每隔一天就會(huì)執(zhí)行一次的調(diào)度任務(wù)");
- }
- @Scheduled(fixedDelay = ONE_HOURS)
- public void scheduleTask2() {
- System.out.println(" 我是一個(gè)執(zhí)行完后，隔一小時(shí)就會(huì)執(zhí)行的任務(wù)");
- }
- @Scheduled(initialDelay=1000, fixedRate=5000)
- public void doSomething() {
- // something that should execute periodically
- }
- @Scheduled(cron = "0 0/1 * * * ? ")
- public void ScheduledTask3() {
- System.out.println(" 我是一個(gè)每隔一分鐘就就會(huì)執(zhí)行的任務(wù)");
- }
需要注意的是：
- 關(guān)于@Scheduled注解，里面使用的是Cron表達(dá)式，同時(shí)我們看到了兩個(gè)不一樣的面孔fixedDelay& fixedRate，前者fixedDelay表示在指定間隔運(yùn)行程序，例如這個(gè)程序在今晚九點(diǎn)運(yùn)行程序，跑完這個(gè)方法后的一個(gè)小時(shí)，就會(huì)再執(zhí)行一次，而后者fixedDelay是指，這個(gè)函數(shù)每隔一段時(shí)間就會(huì)被調(diào)用(我們這里設(shè)置的是一天)，不管再次調(diào)度的時(shí)候，這個(gè)方法是在運(yùn)行還是結(jié)束了。而前者就要求是函數(shù)運(yùn)行結(jié)束后開始計(jì)時(shí)的，這就是兩者區(qū)別。
- 這個(gè)還有一個(gè)initialDelay的參數(shù)，是第一次調(diào)用前需要等待的時(shí)間，這里表示被調(diào)用后的，推遲一秒再執(zhí)行，這適合一些特殊的情況。
- 我們?cè)趕erviceImpl類寫這些調(diào)度任務(wù)時(shí)候，也需要在ServiceInterface的接口口中寫多個(gè)接口，不然會(huì)拋出but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface or 的異常。
@Async調(diào)度
有時(shí)候我們會(huì)調(diào)用一些特殊的任務(wù)，任務(wù)會(huì)比較耗時(shí)，重要的是，我們不管他返回的后果。這時(shí)候我們就需要用這類的異步任務(wù)啦，調(diào)用后就讓它去跑，不堵塞主線程，我們繼續(xù)干別的。代碼像下面這樣:
- public void AsyncTask(){
- @Async
- public void doSomeHeavyBackgroundTask(int sleepTime) {
- try {
- Thread.sleep(sleepTime);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- @Async
- public Future
doSomeHeavyBackgroundTask() { - try {
- Thread.sleep(3000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- return null;
- }
- public void printLog() {
- System.out.println(" i print a log ,time=" + System.currentTimeMillis());
- }
- }
我們寫個(gè)簡單的測(cè)試類來測(cè)試下
- @RunWith(SpringJUnit4ClassRunner.class)
- @WebAppConfiguration
- @ContextConfiguration(classes = AsycnTaskConfig.class) //要聲明@EnableASync
- public class AsyncTaskTest {
- @Autowired
- AsyncTask asyncTask;
- @Test
- public void AsyncTaskTest() throws InterruptedException {
- if (asyncTask != null) {
- asyncTask.doSomeHeavyBackgroundTask(4000);
- asyncTask.printLog();
- Thread.sleep(5000);
- }
- }
- }
這感覺比我們手動(dòng)開線程方便多了，不想異步的話直接把@Async去掉就可以了，另外如果想要返回結(jié)果，需要使用Future<>接口。如果想修改Spring Boot的默認(rèn)線程池配置，可以實(shí)現(xiàn)AsyncConfigurer。
需要注意的是：
- 相對(duì)于@scheduled，這個(gè)可以有參數(shù)和返回個(gè)結(jié)果，因?yàn)檫@個(gè)是我們調(diào)用的，而調(diào)度的任務(wù)是spring調(diào)用的。
- 異步方法不能內(nèi)部調(diào)用，只能像上面那樣，外部調(diào)用，否則就會(huì)變成阻塞主線程的同步任務(wù)啦!這里，給大家展示一個(gè)活生生的大坑!例如下面的代碼案例。
- public void AsyncTask(){
- public void fakeAsyncTaskTest(){
- doSomeHeavyBackgroundTask(4000);
- printLog();
- //你會(huì)發(fā)現(xiàn)，當(dāng)你像這樣內(nèi)部調(diào)用的時(shí)候，居然是同步執(zhí)行的，不是異步的??！
- }
- @Async
- public void doSomeHeavyBackgroundTask(int sleepTime) {
- try {
- Thread.sleep(sleepTime);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- public void printLog() {
- System.out.println(" i print a log ");
- }
- }
另外一點(diǎn)就是不要重復(fù)的掃描，這也會(huì)導(dǎo)致異步無效，具體的可以看這個(gè)stackoveflow的spring-async-not-working Issue。
關(guān)于異常處理，難免在這個(gè)異步執(zhí)行過程中有異常發(fā)生，對(duì)于這個(gè)問題，Spring提供的解決方案如下,實(shí)現(xiàn) AsyncUncaughtExceptionHandler接口。
- public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {
- @Override
- public void handleUncaughtException(Throwable ex, Method method, Object... params) {
- // handle exception
- }
- }
寫好我們的異常處理后，我們需要配置一下，告訴Spring，這個(gè)異常處理就是我們?cè)谶\(yùn)行異步任務(wù)時(shí)候，拋出錯(cuò)誤時(shí)的異常終結(jié)者。
- @Configuration
- @EnableAsync
- public class AsyncConfig implements AsyncConfigurer {
- @Bean
- public AsyncTask asyncBean() {
- return new AsyncTask();
- }
- @Override
- public Executor getAsyncExecutor() {
- ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
- executor.setCorePoolSize(7);
- executor.setMaxPoolSize(42);
- executor.setQueueCapacity(11);
- executor.setThreadNamePrefix("MyExecutor-");
- executor.initialize();
- return executor;
- }
- @Override
- public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
- return new MyAsyncUncaughtExceptionHandler();
- }
- }
簡單聊下Quartz登場(chǎng)
Spring中除了@Scheduled和@Async注解外，還有一個(gè)和Spring整合的第三方庫叫Quartz，看了下官網(wǎng)的使用簡介，也是挺逗的，現(xiàn)在都習(xí)慣用Maven，Gradle之類來關(guān)系這些依賴了，他還叫人下載，也是不知為何，詳情點(diǎn)擊->http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start
估計(jì)有可能是因?yàn)闆]再維護(hù)了的原因吧，看了下，最新版2.2居然是Sep, 2013更新的…
Quartz居然是停更了，不過Quartz作為一個(gè)企業(yè)級(jí)應(yīng)用的任務(wù)調(diào)度框架，還是一個(gè)可以的候選項(xiàng)目，作為其他方案的兜底方案。
這里不鋪開講，有興趣的小伙伴們就去官網(wǎng)看下吧。整體用起來感覺是沒有Spring自己的后臺(tái)任務(wù)方便，不過也可以接受，只需要簡單的配置就可以使用了。
本文轉(zhuǎn)載自微信公眾號(hào)「冰河技術(shù) 」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請(qǐng)聯(lián)系冰河技術(shù) 公眾號(hào)。
名稱欄目：熱乎乎的面經(jīng)：Spring中Scheduled和Async兩種調(diào)度方式有啥區(qū)別？
文章來源：http://www.5511xx.com/article/cdphios.html
