當(dāng)前位置：
首頁 >
后端技术：Java定时任务的五种创建方式
發(fā)布時間：2023/12/10
42
豆豆
生活随笔
收集整理的這篇文章主要介紹了
后端技术：Java定时任务的五种创建方式
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
Quartz表達式生成地址：http://cron.qqe2.com/
支持生成定時任務(wù)表達式和反解析，使用Quartz表達式的定時任務(wù)如下
xxl-job
springboot 的 @Scheduled
Quartz 框架
一、job 定時任務(wù)的五種創(chuàng)建方式
1、使用線程創(chuàng)建 job 定時任務(wù)
/***?TODO??使用線程創(chuàng)建?job?定時任務(wù)*?@author?王松*/ public?class?JobThread?{public?static?class?Demo01?{static?long?count?=?0;public?static?void?main(String[]?args)?{Runnable?runnable?=?new?Runnable()?{@Overridepublic?void?run()?{while?(true)?{try?{Thread.sleep(1000);count++;System.out.println(count);}?catch?(Exception?e)?{//?TODO:?handle?exception}}}};Thread?thread?=?new?Thread(runnable);thread.start();}} }2、使用 TimerTask 創(chuàng)建job定時任務(wù)
/***?TODO??使用?TimerTask?創(chuàng)建job定時任務(wù)*?@author?王松*/ public?class?JobTimerTask?{static?long?count?=?0;public?static?void?main(String[]?args)?{TimerTask?timerTask?=?new?TimerTask()?{@Overridepublic?void?run()?{count++;System.out.println(count);}};//創(chuàng)建timer對象設(shè)置間隔時間Timer?timer?=?new?Timer();//?間隔天數(shù)long?delay?=?0;//?間隔毫秒數(shù)long?period?=?1000;timer.scheduleAtFixedRate(timerTask,?delay,?period);} }3、使用線程池創(chuàng)建 job定時任務(wù)
?/***?TODO??使用線程池創(chuàng)建?job定時任務(wù)*?@author?王松*/ public?class?JobScheduledExecutorService?{public?static?void?main(String[]?args)?{Runnable?runnable?=?new?Runnable()?{@Overridepublic?void?run()?{//?task?to?run?goes?hereSystem.out.println("Hello?!!");}};ScheduledExecutorService?service?=?Executors.newSingleThreadScheduledExecutor();//?第二個參數(shù)為首次執(zhí)行的延時時間，第三個參數(shù)為定時執(zhí)行的間隔時間service.scheduleAtFixedRate(runnable,?1,?1,?TimeUnit.SECONDS);} }4.Quartz 框架
1.引入maven依賴
<dependencies><!--?quartz?--><dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.2.1</version></dependency><dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz-jobs</artifactId><version>2.2.1</version></dependency> </dependencies>2.任務(wù)調(diào)度類
public?class?MyJob?implements?Job?{@Overridepublic?void?execute(JobExecutionContext?context)?throws?JobExecutionException?{System.out.println("quartz?MyJob?date:"?+?System.currentTimeMillis());} }3.啟動類
public?class?JobQuartz?{public?static?void?main(String[]?args)?throws?SchedulerException?{//1.創(chuàng)建Scheduler的工廠SchedulerFactory?sf?=?new?StdSchedulerFactory();//2.從工廠中獲取調(diào)度器實例Scheduler?scheduler?=?sf.getScheduler();//3.創(chuàng)建JobDetail，JobDetail?jb?=?JobBuilder.newJob(MyJob.class)//job的描述.withDescription("this?is?a?ram?job")//job?的name和group.withIdentity("ramJob",?"ramGroup").build();//任務(wù)運行的時間，SimpleSchedle類型觸發(fā)器有效，3秒后啟動任務(wù)long?time=??System.currentTimeMillis()?+?3*1000L;Date?statTime?=?new?Date(time);//4.創(chuàng)建Trigger//使用SimpleScheduleBuilder或者CronScheduleBuilderTrigger?t?=?TriggerBuilder.newTrigger().withDescription("").withIdentity("ramTrigger",?"ramTriggerGroup")//.withSchedule(SimpleScheduleBuilder.simpleSchedule())//默認當(dāng)前時間啟動.startAt(statTime)//兩秒執(zhí)行一次，Quartz表達式，支持各種牛逼表達式.withSchedule(CronScheduleBuilder.cronSchedule("0/2?*?*?*?*??")).build();//5.注冊任務(wù)和定時器scheduler.scheduleJob(jb,?t);//6.啟動?調(diào)度器scheduler.start();}5. springboot 的 @Scheduled 注解
@Component @Configuration??????//1.主要用于標(biāo)記配置類，兼?zhèn)銫omponent的效果。 @EnableScheduling???//?2.開啟定時任務(wù) public?class?SaticScheduleTask?{@Scheduled(cron?=?"0/5?*?*?*?*??")??//3.添加定時任務(wù)//@Scheduled(fixedRate=5000)????????//或直接指定時間間隔，例如：5秒private?void?configureTasks()?{System.err.println("執(zhí)行靜態(tài)定時任務(wù)時間:?"?+?LocalDateTime.now());} }二、xxl-job 任務(wù)調(diào)度后臺 Admin
xxl-job 有什么用？
分布式集群的情況下，保證定時任務(wù)不被重復(fù)執(zhí)行。
執(zhí)行原理同Nginx 類型，所有定時任務(wù)通過任務(wù)調(diào)度平臺分發(fā)，也可配置負載均衡等等
首先讓我們能夠使用起來，搭建一個自己的任務(wù)
第一步: github下載源碼導(dǎo)入
下載地址：https://github.com/xuxueli/xxl-job/
當(dāng)前版本目錄結(jié)構(gòu) 2.1.1
第二步: 執(zhí)行sql
文件地址：xxl-job/doc/db/tables_xxl_job.sql
當(dāng)前2.1.1版本sql
第三步: 修改xxl-job-admin項目配置
配置文件：application.properties
修改數(shù)據(jù)庫連接
第四步: 啟動admin項目
springboot 方式啟動項目，
訪問 http://localhost:8080/xxl-job-admin/
賬號密碼：admin / 123456
任務(wù)調(diào)度中心就搭建好了
接下來需要創(chuàng)建一個服務(wù)器連接任務(wù)調(diào)度中心
三、自創(chuàng)建boot項目的任務(wù)xxl-job 示例demo
創(chuàng)建一個 boot 項目
我的目錄結(jié)構(gòu)
pom.xml
web核心及 xxl-job-core
<!--?spring-boot-starter-web?(spring-webmvc?+?tomcat)?--> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope> </dependency><!--?xxl-job-core??版本號根據(jù)自己下載的版本修改?--> <dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.1.1-SNAPSHOT</version> </dependency>logback.xml
日志配置直接拷貝
<?xml?version="1.0"?encoding="UTF-8"?> <configuration?debug="false"?scan="true"?scanPeriod="1?seconds"><contextName>logback</contextName><property?name="log.path"?value="/data/applogs/xxl-job/xxl-job-executor-sample-springboot.log"/><appender?name="console"?class="ch.qos.logback.core.ConsoleAppender"><encoder><pattern>%d{HH:mm:ss.SSS}?%contextName?[%thread]?%-5level?%logger{36}?-?%msg%n</pattern></encoder></appender><appender?name="file"?class="ch.qos.logback.core.rolling.RollingFileAppender"><file>${log.path}</file><rollingPolicy?class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><fileNamePattern>${log.path}.%d{yyyy-MM-dd}.zip</fileNamePattern></rollingPolicy><encoder><pattern>%date?%level?[%thread]?%logger{36}?[%file?:?%line]?%msg%n</pattern></encoder></appender><root?level="info"><appender-ref?ref="console"/><appender-ref?ref="file"/></root></configuration>application.properties 加入配置
需修改或自定義
xxl-job admin 地址
xxl.job.executor.appname 自定義名稱，后臺配置必須對應(yīng)
xxl.job.executor.ip 當(dāng)前電腦Ip，或部署項目的電腦Ip
xxl.job.executor.port 端口
添加boot配置類 XxlJobConfig
package?xxljob.config; import?com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import?org.slf4j.Logger; import?org.slf4j.LoggerFactory; import?org.springframework.beans.factory.annotation.Value; import?org.springframework.context.annotation.Bean; import?org.springframework.context.annotation.Configuration;/***?xxl-job?xxljob.config*/ @SuppressWarnings("ALL") @Configuration public?class?XxlJobConfig?{private?Logger?logger?=?LoggerFactory.getLogger(XxlJobConfig.class);@Value("${xxl.job.admin.addresses}")private?String?adminAddresses;@Value("${xxl.job.executor.appname}")private?String?appName;@Value("${xxl.job.executor.ip}")private?String?ip;@Value("${xxl.job.executor.port}")private?int?port;@Value("${xxl.job.accessToken}")private?String?accessToken;@Value("${xxl.job.executor.logpath}")private?String?logPath;@Value("${xxl.job.executor.logretentiondays}")private?int?logRetentionDays;@Bean(initMethod?=?"start",?destroyMethod?=?"destroy")public?XxlJobSpringExecutor?xxlJobExecutor()?{logger.info(">>>>>>>>>>>?xxl-job?xxljob.config?init.");XxlJobSpringExecutor?xxlJobSpringExecutor?=?new?XxlJobSpringExecutor();xxlJobSpringExecutor.setAdminAddresses(adminAddresses);xxlJobSpringExecutor.setAppName(appName);xxlJobSpringExecutor.setIp(ip);xxlJobSpringExecutor.setPort(port);xxlJobSpringExecutor.setAccessToken(accessToken);xxlJobSpringExecutor.setLogPath(logPath);xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);System.err.println(ip+":"+port);return?xxlJobSpringExecutor;}/***?針對多網(wǎng)卡、容器內(nèi)部署等情況，可借助?"spring-cloud-commons"?提供的?"InetUtils"?組件靈活定制注冊IP；**????? 1、引入依賴：*??????????<dependency>*?????????????<groupId>org.springframework.cloud</groupId>*?????????????<artifactId>spring-cloud-commons</artifactId>*?????????????<version>${version}</version>*?????????</dependency>**??????2、配置文件，或者容器啟動變量*??????????spring.cloud.inetutils.preferred-networks:?'xxx.xxx.xxx.'**??????3、獲取IP*??????????String?ip_?=?inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();*/ }任務(wù)job
@JobHandler(value="demoJobHandler") @Component public?class?DemoJobHandler?extends?IJobHandler?{static?int?count;@Overridepublic?ReturnT<String>?execute(String?param)?throws?Exception?{System.out.println("執(zhí)行job任務(wù)"+count++);return?SUCCESS;} }admin 后臺配置
執(zhí)行管理器下
任務(wù)管理下編輯任務(wù)
定時規(guī)則生成：http://cron.qqe2.com/
job任務(wù)名：@JobHandler注解值 >> 如:@JobHandler(value=“demoJobHandler”)
啟動
這樣就配置完成了
完成
應(yīng)用項目：https://gitee.com/wslxm/spring-boot-plus2
IT技術(shù)分享社區(qū)
個人博客網(wǎng)站：https://programmerblog.xyz
文章推薦程序員效率：畫流程圖常用的工具程序員效率：整理常用的在線筆記軟件遠程辦公：常用的遠程協(xié)助軟件，你都知道嗎？51單片機程序下載、ISP及串口基礎(chǔ)知識硬件：斷路器、接觸器、繼電器基礎(chǔ)知識
總結(jié)
以上是生活随笔為你收集整理的后端技术：Java定时任务的五种创建方式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： fibonacci数列前20项_高考数学
- 下一篇： 后端：推荐九款Java 性能优化工具，你