Shulou(Shulou.com)06/01 Report--

This article mainly introduces SpringBoot2.6.3 how to integrate quartz related knowledge, detailed and easy to understand, simple and fast operation, has a certain reference value, I believe everyone will read this SpringBoot2.6.3 how to integrate quartz article will have some gains, let's take a look at it.

Quartz is used

Quartz startup requires that the database has support for a number of tables. The table creation scripts for these tables can be found as follows

How to Find Quartz Database Script

Download here, need to pay attention to download 2.2.3 this version, do not know why the higher version is not, really Buddha

Integrated Springboot

code

yml configuration

spring: application: name: demo-excel datasource: url: jdbc:mysql://rm-xxx.mysql.rds.aliyuncs.com:3306/quartz_demo? zeroDateTimeBehavior=convertToNull password: quartz_demo username: quartz_demo driver-class-name: com.mysql.cj.jdbc.Driver name: datasource1 quartz: # quartz task storage type: jdbc or memory job-store-type: jdbc #Wait for the task to complete when closing wait-for-jobs-to-complete-on-shutdown: true #Overwrite existing tasks overwrite-existing-jobs: true properties: org: quartz: scheduler: #Scheduler instance name instanceName: scheduler #Scheduler instance ID automatically generated instanceId: AUTO jobStore: class: org.springframework.scheduling.quartz.LocalDataSourceJobStore driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate # quartz correlation table prefix tablePrefix: QRTZ_ useProperties: false threadPool: class: org.quartz.simpl.SimpleThreadPool #Set the number of concurrent threads threadCount: 10 #Specify thread priority threadPriority: 5 threadsInheritContextClassLoaderOfInitializingThread: trueserver: port: 8190mybatis-plus: mapper-locations: classpath*:/mapperxml/*.xml

To accomplish the simplest task, output 1111

@Componentpublic class TestJob extends QuartzJobBean { @Override protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { //Specific logic of the task System.out.println(1111); }}

Configure the execution plan for this task

@Configurationpublic class QuartzConfig { @Bean public JobDetail jobDetail() { JobDetail jobDetail = JobBuilder.newJob(TestJob.class) .withIdentity("test", "test") .storeDurably() .build(); return jobDetail; } public Trigger trigger() { Trigger trigger = TriggerBuilder.newTrigger() .forJob(jobDetail()) .startNow() .withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ? ")) return trigger;}

Start the task and you'll see the console print 1111 every second.

advanced

The appeal task is configured in the code, so if we want to configure the task in the database, so that we can make a timed task maintenance page, we can modify the trigger rules of the timed task, and modify and delete the timed task. What should we do?

First define a table to store timed tasks

-- auto-generated definitioncreate table sys_job( id bigint not null primary key, job_name varchar(64) not null comment 'task name', job_group varchar(64) not null comment 'task group name', method_name varchar(500) null comment 'task method', method_params varchar(50) null comment 'method parameters', cron_expression varchar(255) null comment 'cron executes expression', misfire_policy varchar(20) default '3' null comment 'Planned execution error policy (1 immediately execute 2 execute once 3 abort execution)', concurrent char default '1' null comment 'whether concurrent execution (0 allowed 1 prohibited)', status char default '0' null comment 'status (0 normal 1 suspended)', create_by varchar(64) null comment 'creator', create_time datetime null comment 'create time', update_by varchar(64) null comment 'updateer', update_time datetime null comment 'update time', remark varchar(500) null comment 'Comment information') comment 'Timed Task Scheduling Table';

Insert a piece of data

INSERT INTO quartz_demo.sys_job (id, job_name, job_group, method_name, method_params, cron_expression, misfire_policy, concurrent, status, create_by, create_time, update_by, update_time, remark) VALUES (1, 'testJob2', 'test2', 'exec', null, '* * * * * ? ', '2', '1', '0', null, null, null, null, null);

At the same time, define an execution result record table

-- auto-generated definitioncreate table sys_job_log( job_log_id int auto_increment comment 'Task Log ID' primary key, job_name varchar(64) not null comment 'task name', job_group varchar(64) not null comment 'task group name', method_name varchar(500) null comment 'task method', method_params varchar(50) null comment 'method parameters', job_message varchar(500) null comment 'log information', status char default '0' null comment 'execution status (0 normal 1 failed)', exception_info varchar(2000) null comment 'exception information', create_time datetime null comment 'created time') comment 'Timed Task Scheduling Log Table';

When the project starts, read the data in this table and put it into quartz to execute

Since there is too much code, I won't list it here. The demo has been uploaded to GitHub. The project is based on springboot and mybatisplus. The code to start the load task is in com.bxoon.service.impl.SysJobServiceImpl

About "SpringBoot2.6.3 how to integrate quartz" the content of this article is introduced here, thank you for reading! I believe everyone has a certain understanding of "SpringBoot2.6.3 how to integrate quartz" knowledge. If you still want to learn more knowledge, please pay attention to the industry information channel.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.