Spring整合Quartz--持久化、动态添加任务

Bertha 。 2021-08-28 23:20 347阅读 0赞

### 持久化 ###

Quartz 包括了所有被支持的数据库平台的 SQL 脚本。你能在 `<quartz_home>/docs/dbTables`目录下找到那些 SQL 脚本，这里的`<quartz_home>` 是解压 Quartz 分发包后的目录。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]

application.xml

<?xml version="1.0" encoding="UTF-8" ?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/beans/spring-context.xsd">
    
    
            
            
            <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
                    
    
                    <property name="quartzProperties">
                            <value>
                                   # 指定调度器名称，实际类型为：QuartzScheduler
                                   org.quartz.scheduler.instanceName = MyScheduler
                                   # 指定连接池
                                   org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
                                   # 连接池线程数量
                                   org.quartz.threadPool.threadCount = 11
                                   # 优先级
                                   org.quartz.threadPool.threadPriority = 5
                                   # 持久化
                                   org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
                                   # quartz表的前缀
                                   org.quartz.jobStore.tablePrefix = QRTZ_
                            </value>
                    </property>
                    <property name="dataSource" ref="myDataSource"/>
            </bean>
    
            <bean id="myDataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
                <property name="url" value="jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8"/>
                <property name="username" value="root"/>
                <property name="password" value="123456"/>
                <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
                <property name="initialSize" value="1"/>
                <property name="minIdle" value="1"/>
                <property name="maxActive" value="3"/>
                <property name="maxWait" value="3000"/>
                
                <property name="timeBetweenEvictionRunsMillis" value="60000"/>
                
                <property name="minEvictableIdleTimeMillis" value="300000"/>
    
                <property name="validationQuery" value="SELECT '1'"/>
                <property name="testWhileIdle" value="true"/>
                <property name="testOnBorrow" value="false"/>
                <property name="testOnReturn" value="false"/>
            </bean>
    
    </beans>

mvc.xmml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    
        <context:component-scan base-package="pers.zhang">
            <context:include-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
        </context:component-scan>
    
        <mvc:annotation-driven/>
    
        <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver" >
            
            <property name="prefix" value="/"/>
            
            <property name="suffix" value=".jsp"/>
        </bean>
    
    
    </beans>

web.xml

<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" >
    
    <web-app>
      <display-name>Archetype Created Web Application</display-name>
    
      <servlet>
        <servlet-name>mvc</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
          <param-name>contextConfigLocation</param-name>
          <param-value>classpath:mvc.xml</param-value>
        </init-param>
        <load-on-startup>2</load-on-startup>
      </servlet>
      <servlet-mapping>
        <servlet-name>mvc</servlet-name>
        <url-pattern>/</url-pattern>
      </servlet-mapping>
    
      <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
      </listener>
      <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:applicationContext.xml</param-value>
      </context-param>
    
      <filter>
        <filter-name>encoding</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
          <param-name>encoding</param-name>
          <param-value>UTF-8</param-value>
        </init-param>
        <init-param>
          <param-name>forceEncoding</param-name>
          <param-value>true</param-value>
        </init-param>
      </filter>
      <filter-mapping>
        <filter-name>encoding</filter-name>
        <url-pattern>/*</url-pattern>
      </filter-mapping>
    
    
    </web-app>

job:

public class MyJob implements Job { 
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
            //创建工作详情
            JobDetail jobDetail = jobExecutionContext.getJobDetail();
            //获取工作的名称
            String name = jobDetail.getKey().getName();//任务明
            String group = jobDetail.getKey().getGroup();//任务group
            String data = jobDetail.getJobDataMap().getString("data");//任务中的数据
            System.out.println("job执行，job名：" + name + " group:" + group + " data:" + data + new Date());
        }
    }

pojo:

@Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class JobAndTrigger { 
    
        private String jobName;
        private String jobGroup;
        private String jobClassName;
        private String triggerName;
        private String triggerGroup;
        private BigInteger repeatInterval;
        private BigInteger timesTriggered;
        private String cronExpression;
        private String timeZoneId;
    }

Controller:

@Controller
    @RequestMapping("/quartz")
    public class TestController { 
    
        @Autowired
        Scheduler scheduler;
    
        @RequestMapping("/add")
        public String addJob(JobAndTrigger jt) throws ClassNotFoundException, SchedulerException { 
            JobDetail jobDetail = null;
            jobDetail = JobBuilder.newJob((Class<? extends Job>)Class.forName(jt.getJobClassName()))
                    .withIdentity(jt.getJobName(), jt.getJobGroup())
                    .storeDurably(true)
                    .build();
            CronTrigger cronTrigger = null;
            cronTrigger = TriggerBuilder.newTrigger()
                            .withIdentity(jt.getTriggerName(), jt.getTriggerGroup())
                            .withSchedule(CronScheduleBuilder.cronSchedule(jt.getCronExpression()))
                            .build();
            scheduler.scheduleJob(jobDetail, cronTrigger);
            return "index";
        }
    }

页面：

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
    <html>
    <body>
    <h2>Hello World!</h2>
    
    
    <form action="/quartzPro/quartz/add" method="post">
        jobName:<input type="text" name="jobName"><br/>
        jobGroup:<input type="text" name="jobGroup"><br/>
        triggerName:<input type="text" name="triggerName"><br/>
        triggerGroup:<input type="text" name="triggerGroup"><br/>
        cronExp:<input type="text" name="cronExpression"><br/>
        jobClass:<input type="text" name="jobClassName"><br/>
        <input type="submit" value="增加">
    </form>
    </body>
    </html>

测试：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]: /images/20210813/4cda8ebb875d45a985e1068d5d452bcd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]: /images/20210813/df285cc9c43f4e65963127d095571702.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 2]: /images/20210813/35055bb94594427894106587e2329428.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 3]: /images/20210813/638666d47ab9472bb8de93d7e89ae597.png