Spring的两大调度手段

 

Spring提供了两种后台任务的方法,分别是:

  • 调度任务,@Schedule
  • 异步任务,@Async

当然,使用这两个是有条件的,需要在spring应用的上下文中声明当然,如果我们是基于java配置的,需要在配置类上加@EnableScheduling和@EnableAsync注解,例如,下面的代码片段。


  1. @EnableScheduling 
  2. @EnableAsync 
  3. public class WebAppConfig { 
  4.    …. 
  5. } 

除此之外,还是有第三方库可以调用的,例如Quartz,文章最后我们再简单提下Quartz。

@Schedule调度

先看下@Schedule怎么调用再说。


  1. public final static long ONE_DAY = 24 * 60 * 60 * 1000; 
  2. public final static long ONE_HOUR = 60 * 60 * 1000; 
  3.   
  4. @Scheduled(fixedRate = ONE_DAY) 
  5. public void scheduledTask() { 
  6.    System.out.println(" 我是一个每隔一天就会执行一次的调度任务"); 
  7.   
  8. @Scheduled(fixedDelay = ONE_HOURS) 
  9. public void scheduleTask2() { 
  10.     System.out.println(" 我是一个执行完后,隔一小时就会执行的任务"); 
  11.   
  12. @Scheduled(initialDelay=1000, fixedRate=5000) 
  13. public void doSomething() { 
  14.     // something that should execute periodically 
  15.   
  16. @Scheduled(cron = "0 0/1 * * * ? "
  17. public void ScheduledTask3() { 
  18.     System.out.println(" 我是一个每隔一分钟就就会执行的任务"); 

需要注意的是:

  • 关于@Scheduled注解,里面使用的是Cron表达式,同时我们看到了两个不一样的面孔fixedDelay& fixedRate,前者fixedDelay表示在指定间隔运行程序,例如这个程序在今晚九点运行程序,跑完这个方法后的一个小时,就会再执行一次,而后者fixedDelay是指,这个函数每隔一段时间就会被调用(我们这里设置的是一天),不管再次调度的时候,这个方法是在运行还是结束了。而前者就要求是函数运行结束后开始计时的,这就是两者区别。
  • 这个还有一个initialDelay的参数,是第一次调用前需要等待的时间,这里表示被调用后的,推迟一秒再执行,这适合一些特殊的情况。
  • 我们在serviceImpl类写这些调度任务时候,也需要在ServiceInterface的接口口中写多个接口,不然会抛出but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface or 的异常。

@Async调度

有时候我们会调用一些特殊的任务,任务会比较耗时,重要的是,我们不管他返回的后果。这时候我们就需要用这类的异步任务啦,调用后就让它去跑,不堵塞主线程,我们继续干别的。代码像下面这样:


  1. public void AsyncTask(){ 
  2.     @Async 
  3.     public void doSomeHeavyBackgroundTask(int sleepTime) { 
  4.         try { 
  5.             Thread.sleep(sleepTime); 
  6.         } catch (InterruptedException e) { 
  7.             e.printStackTrace(); 
  8.         } 
  9.     } 
  10.     @Async 
  11.     public Future<String> doSomeHeavyBackgroundTask() { 
  12.         try { 
  13.             Thread.sleep(3000); 
  14.         } catch (InterruptedException e) { 
  15.             e.printStackTrace(); 
  16.         } 
  17.         return null
  18.     } 
  19.       
  20.     public void printLog() { 
  21.          System.out.println(" i print a log ,time=" + System.currentTimeMillis()); 
  22.     } 
  23.   

我们写个简单的测试类来测试下


  1. @RunWith(SpringJUnit4ClassRunner.class) 
  2. @WebAppConfiguration 
  3. @ContextConfiguration(classes = AsycnTaskConfig.class) //要声明@EnableASync 
  4. public class AsyncTaskTest { 
  5.     @Autowired 
  6.     AsyncTask asyncTask; 
  7.     @Test 
  8.     public void AsyncTaskTest() throws InterruptedException { 
  9.         if (asyncTask != null) { 
  10.             asyncTask.doSomeHeavyBackgroundTask(4000); 
  11.             asyncTask.printLog(); 
  12.             Thread.sleep(5000); 
  13.         } 
  14.     } 

这感觉比我们手动开线程方便多了,不想异步的话直接把@Async去掉就可以了,另外如果想要返回结果,需要使用Future<>接口。如果想修改Spring Boot的默认线程池配置,可以实现AsyncConfigurer。

需要注意的是:

  • 相对于@scheduled,这个可以有参数和返回个结果,因为这个是我们调用的,而调度的任务是spring调用的。
  • 异步方法不能内部调用,只能像上面那样,外部调用,否则就会变成阻塞主线程的同步任务啦!这里,给大家展示一个活生生的大坑!例如下面的代码案例。

  1. public void AsyncTask(){ 
  2.     public void fakeAsyncTaskTest(){ 
  3.         doSomeHeavyBackgroundTask(4000); 
  4.         printLog(); 
  5.         //你会发现,当你像这样内部调用的时候,居然是同步执行的,不是异步的!! 
  6.     } 
  7.       
  8.     @Async 
  9.     public void doSomeHeavyBackgroundTask(int sleepTime) { 
  10.         try { 
  11.             Thread.sleep(sleepTime); 
  12.         } catch (InterruptedException e) { 
  13.             e.printStackTrace(); 
  14.         } 
  15.     } 
  16.       
  17.     public void printLog() { 
  18.         System.out.println(" i print a log "); 
  19.     } 

另外一点就是不要重复的扫描,这也会导致异步无效,具体的可以看这个stackoveflow的spring-async-not-working Issue。

关于异常处理,难免在这个异步执行过程中有异常发生,对于这个问题,Spring提供的解决方案如下,实现 AsyncUncaughtExceptionHandler接口。


  1. public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler { 
  2.     @Override 
  3.     public void handleUncaughtException(Throwable ex, Method method, Object… params) { 
  4.         // handle exception 
  5.     } 

写好我们的异常处理后,我们需要配置一下,告诉Spring,这个异常处理就是我们在运行异步任务时候,抛出错误时的异常终结者。


  1. @Configuration 
  2. @EnableAsync 
  3. public class AsyncConfig implements AsyncConfigurer { 
  4.     @Bean 
  5.     public AsyncTask asyncBean() { 
  6.         return new AsyncTask(); 
  7.     } 
  8.       
  9.     @Override 
  10.     public Executor getAsyncExecutor() { 
  11.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); 
  12.         executor.setCorePoolSize(7); 
  13.         executor.setMaxPoolSize(42); 
  14.         executor.setQueueCapacity(11); 
  15.         executor.setThreadNamePrefix("MyExecutor-"); 
  16.         executor.initialize(); 
  17.         return executor; 
  18.     } 
  19.       
  20.     @Override 
  21.     public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { 
  22.          return new MyAsyncUncaughtExceptionHandler(); 
  23.     } 

简单聊下Quartz登场

Spring中除了@Scheduled和@Async注解外,还有一个和Spring整合的第三方库叫Quartz,看了下官网的使用简介,也是挺逗的,现在都习惯用Maven,Gradle之类来关系这些依赖了,他还叫人下载,也是不知为何,详情点击->http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start

估计有可能是因为没再维护了的原因吧,看了下,最新版2.2居然是Sep, 2013更新的…

Quartz居然是停更了,不过Quartz作为一个企业级应用的任务调度框架,还是一个可以的候选项目,作为其他方案的兜底方案。

这里不铺开讲,有兴趣的小伙伴们就去官网看下吧。整体用起来感觉是没有Spring自己的后台任务方便,不过也可以接受,只需要简单的配置就可以使用了。

【声明】:芜湖站长网内容转载自互联网,其相关言论仅代表作者个人观点绝非权威,不代表本站立场。如您发现内容存在版权问题,请提交相关链接至邮箱:bqsm@foxmail.com,我们将及时予以处理。

相关文章