SpringBoot2.0 基础案例(04):定时任务和异步任务的使用方式
一、定时任务
1、基本概念
按照指定时间执行的程序。
2、使用场景
数据分析 数据清理 系统服务监控
二、同步和异步
1、基本概念
同步调用
程序按照代码顺序依次执行,每一行程序都必须等待上一行程序执行完成之后才能执行;
异步调用
顺序执行时,不等待异步调用的代码块返回结果就执行后面的程序。
2、使用场景
短信通知 邮件发送 批量数据入缓存
三、SpringBoot2.0使用定时器
1、定时器执行规则注解
@Scheduled(fixedRate = 5000) :上一次开始执行时间点之后5秒再执行 @Scheduled(fixedDelay = 5000) :上一次执行完毕时间点之后5秒再执行 @Scheduled(initialDelay=1000, fixedRate=5000) :第一次延迟1秒后执行,之后按fixedRate的规则每5秒执行一次 @Scheduled(cron="/5") :通过cron表达式定义规则
2、定义时间打印定时器
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.text.SimpleDateFormat; import java.util.Date; /** * 时间定时任务 */ @Component public class TimeTask { Logger LOG = LoggerFactory.getLogger(TimeTask.class.getName()) ; private static final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss") ; /** * 每3秒打印一次系统时间 */ @Scheduled(fixedDelay = 3000) public void systemDate (){ LOG.info("当前时间::::"+format.format(new Date())); } }
3、启动类开启定时器注解
@EnableScheduling // 启用定时任务 @SpringBootApplication public class TaskApplication { public static void main(String[] args) { SpringApplication.run(TaskApplication.class,args) ; } }
四、SpringBoot2.0使用异步任务
1、编写异步任务类
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; @Component public class AsyncTask { private static final Logger LOGGER = LoggerFactory.getLogger(AsyncTask.class) ; /* * [ asyncTask1-2] com.boot.task.config.AsyncTask : ======异步任务结束1====== * [ asyncTask1-1] com.boot.task.config.AsyncTask : ======异步任务结束0====== */ // 只配置了一个 asyncExecutor1 不指定也会默认使用 @Async public void asyncTask0 () { try{ Thread.sleep(5000); }catch (Exception e){ e.printStackTrace(); } LOGGER.info("======异步任务结束0======"); } @Async("asyncExecutor1") public void asyncTask1 () { try{ Thread.sleep(5000); }catch (Exception e){ e.printStackTrace(); } LOGGER.info("======异步任务结束1======"); } }
2、指定异步任务执行的线程池
这里可以不指定,指定执行的线城池,可以更加方便的监控和管理异步任务的执行。
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.Executor; import java.util.concurrent.ThreadPoolExecutor; /** * 定义异步任务执行的线程池 */ @Configuration public class TaskPoolConfig { @Bean("asyncExecutor1") public Executor taskExecutor1 () { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 核心线程数10:线程池创建时候初始化的线程数 executor.setCorePoolSize(10); // 最大线程数20:线程池最大的线程数,只有在缓冲队列满了之后才会申请超过核心线程数的线程 executor.setMaxPoolSize(20); // 缓冲队列200:用来缓冲执行任务的队列 executor.setQueueCapacity(200); // 允许线程的空闲时间60秒:当超过了核心线程出之外的线程在空闲时间到达之后会被销毁 executor.setKeepAliveSeconds(60); // 线程池名的前缀:设置好了之后可以方便定位处理任务所在的线程池 executor.setThreadNamePrefix("asyncTask1-"); /* 线程池对拒绝任务的处理策略:这里采用了CallerRunsPolicy策略, 当线程池没有处理能力的时候,该策略会直接在 execute 方法的调用线程中运行被拒绝的任务; 如果执行程序已关闭,则会丢弃该任务 */ executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean executor.setWaitForTasksToCompleteOnShutdown(true); // 设置线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁,以确保应用最后能够被关闭,而不是阻塞住。 executor.setAwaitTerminationSeconds(600); return executor; } }
3、启动类添加异步注解
@EnableAsync // 启用异步任务 @SpringBootApplication public class TaskApplication { public static void main(String[] args) { SpringApplication.run(TaskApplication.class,args) ; } }
4、异步调用的测试接口
@RestController public class TaskController { @Resource private AsyncTask asyncTask ; @RequestMapping("/asyncTask") public String asyncTask (){ asyncTask.asyncTask0(); asyncTask.asyncTask1(); return "success" ; } }
五、源代码地址
GitHub地址:知了一笑 https://github.com/cicadasmile 码云地址:知了一笑 https://gitee.com/cicadasmile
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
如何在互联网上虚度人生?
阅读本文大概需要 4 分钟。 今天你上网了吗?在网上又花了多少个小时呢,玩了多久的游戏,看到了多久的网剧或者综艺?亦或是刷了多久的抖音短视频以及朋友圈? 不管你是在手机还是电脑上,我相信你总有办法在网上虚度人,短则一天,长则一年,反正在互联网上消磨的时光永远不会嫌多。因为,在互联网上待的时间总是快乐的,同时也是短暂的。 如果你还没有想好如何在互联网上虚度一生,那么我想给你提出这么几个建议,让你更好的在互联网上浪费你的时间。 1、打游戏 英雄联盟,DOTA2,炉石传说,绝地求生,这些你都有对吗。这么多的游戏客户端放在桌面,相信你一个都不想放过。 我相信你很快就能过完一个晚上甚至一天。我以前玩游戏的时候总是觉得时间过得很快,科学告诉我们,游戏会给人们带来兴奋的快感,以及不断的求胜欲望,促使你不断地想要赢得下一场游戏,相信有了兴奋感的催化作用,你一定能在游戏上花上更多时间。 不喜欢玩端游,那还有手游呢,王者荣耀,和平精英,自走棋全都撸一遍,上个黄金不是事啊。 你不知不觉,周末就结束了,明天又要上班了。 2、没事刷短视频 如果你的手机上还没有抖音、微视、快手三剑客,那么我建议你赶紧下载吧,比起...
- 下一篇
SpringBoot2.0 基础案例(05):多个拦截器配置和使用场景
一、拦截器简介 1、拦截器定义 拦截器,请求的接口被访问之前,进行拦截然后在之前或之后加入某些操作。拦截是AOP的一种实现策略。 拦截器主要用来按照指定规则拒绝请求。 2、拦截器中应用 Token令牌验证 请求数据校验 用户权限校验 放行指定接口 二、SpringBoot2.0拦截器用法 1、编写两个拦截器 自定义类实现HandlerInterceptor接口1)OneInterceptor 拦截器 import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.servlet.HandlerInterceptor; import org.springframework.web.servlet.ModelAndView; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; /** * 拦截器一 */ public class OneInterc...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS8编译安装MySQL8.0.19
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- SpringBoot2整合Redis,开启缓存,提高访问速度
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- Hadoop3单机部署,实现最简伪集群
- CentOS7,CentOS8安装Elasticsearch6.8.6
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果