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