zoukankan      html  css  js  c++  java
  • 使用spring整合Quartz实现—定时器

    使用spring整合Quartz实现—定时器(Maven项目做演示)

    不基于特定的基类的方法


    一,开发环境以及依赖的jar包

        Spring 4.2.6.RELEASE

        Maven 3.3.9

        Jdk 1.7

        Idea 15.04

    二,不可少的jar依赖(添加在maven项目里面的pom.xml文件里面)

       

     <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
        <version>4.2.6.RELEASE</version>
      </dependency>
     <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.1</version>
    </dependency>

    三,实现定时器时使用到的文件:

         planWorkExcute.java    --定时器执行的类

         spring-plan.xml    --配置定时器信息的xml

    四,实现定时器步骤:

       1,创建 planWorkExcute.java文件  ,在   cc.royao.plantask   包下。      

    package cc.royao.plantask;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    import org.apache.log4j.Logger;//可以删除
    import org.springframework.beans.factory.annotation.Autowired;
    
    
    public class PlanWorkExecute {
        Logger logger = Logger.getLogger(this.getClass());//logger打印日志,可以去掉
        
        
        /**
         * 定时器执行的方法
         */
        public synchronized void withdrawNoAuditTask() {
            SimpleDateFormat outFormat = new SimpleDateFormat("yyyy年MM月dd日 HH:mm:ss");
            System.out.println("开始提现免审核任务-------------------------------" + outFormat.format(new Date()));
            logger.info("开始提现免审核任务-------------------------------");
            
            System.out.println("结束提现免审核任务-------------------------------" + outFormat.format(new Date()));
            logger.info("结束提现免审核任务-------------------------------");
        }
        
    }
        

       2,创建spring-plan.xml  配置文件  注:创建一个定时器的配置文件就行,如果需要多个定时器,直接在spring-plan.xml添加 bean和定义定时器类的方法就行,不需要创建多个xml,

          · 关于那个定时器多久执行的   Cron表达式 可以参考: https://www.cnblogs.com/javahr/p/8318728.html

          ·有在线生成表达式的网址:http://cron.qqe2.com/

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    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-2.5.xsd"
    default-lazy-init="false">
    <bean id="job1" class="cc.royao.plantask.PlanWorkExecute" /><!-- 修改为你的定时类的路径 -->
    <!-- 可以创建多个定时bean  -->
    <bean id="jobDetail_1"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
        <ref bean="job1" /> 
       </property>
       <property name="targetMethod">
        <value>withdrawNoAuditTask</value><!-- 定时器类的方法名-->
       </property>
    </bean>
    
    
    <bean id="cronTrigger_1"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
        <ref bean="jobDetail_1" />  <!-- 这里对应上面bean-->
       </property>
       <property name="cronExpression">
       <value>0/2 * * * * ?</value><!-- 0 10 0 * * ? 每天0:10执行 -->
       </property>
    </bean>
    
    
    <bean
       class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
       <property name="triggers">
        <list>
           
           <ref local="cronTrigger_1" /> <!-- 每加一个定时器这里也要加-->
    
        </list>
       </property>
    </bean>
    </beans>

      3,需要在  applicationContext.xml 中引入  spring-plan.xml    以下代码重点在最下

      

    <?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:jee="http://www.springframework.org/schema/jee"
           xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
           xmlns:aop="http://www.springframework.org/schema/aop" xmlns:mvc="http://www.springframework.org/schema/mvc"
           xmlns:cache="http://www.springframework.org/schema/cache"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
                            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.2.xsd"
           default-lazy-init="true">
    
    
        <!-- 加载系统properties文件配置 -->
        <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
            <property name="locations">
                <list>
                    <value>WEB-INF/jdbc.properties</value>
                    <!-- <value>WEB-INF/sms.properties</value>  -->
                </list>
            </property>
        </bean>
    
    
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
            <property name="driverClassName">
                <value>${jdbc.driverClass}</value>
            </property>
            <!--<property name="defaultAutoCommit" value="false"/>-->
            <property name="url">
                <value>jdbc:mysql://192.168.14.239:3306/test?useUnicode=true&amp;characterEncoding=utf-8</value>
            </property>
            <property name="username">
                <value>${jdbc.username}</value>
            </property>
            <property name="password">
                <value>${jdbc.password}</value>
            </property>
            <property name="maxActive">
                <value>20</value>
            </property>
            <property name="maxIdle">
                <value>60</value>
            </property>
            <property name="maxWait">
                <value>20000</value>
                <!-- 0 -->
            </property>
            <property name="removeAbandoned">
                <value>true</value>
            </property>
            <property name="removeAbandonedTimeout">
                <value>6000000</value>
                <!-- 180 -->
            </property>
            <!-- add -->
            <property name="validationQuery" value="SELECT 1"></property>
            <property name="testWhileIdle" value="true"></property>
            <property name="testOnBorrow" value="true"></property>
            <property name="timeBetweenEvictionRunsMillis" value="3600000"></property>
            <property name="numTestsPerEvictionRun" value="50"></property>
            <property name="minEvictableIdleTimeMillis" value="120000"></property>
            <!-- add -->
        </bean>
    
        <!-- SqlSessionFactory -->
        <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
            <property name="dataSource" ref="dataSource"/>
        </bean>
    
    
        <bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
            <property name="corePoolSize" value="1"/>
            <property name="maxPoolSize" value="10"/>
            <property name="keepAliveSeconds" value="300"/>
            <property name="queueCapacity" value="50"/>
            <property name="WaitForTasksToCompleteOnShutdown" value="true"/>
        </bean>
    
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    
    
        <!--&lt;!&ndash; 自动扫描service实现 &ndash;&gt;-->
        <!--<context:component-scan base-package="com.royao">-->
        <!--<context:include-filter type="regex"-->
        <!--expression="com.royao.services.*" />-->
        <!--</context:component-scan>-->
    
        <aop:config proxy-target-class="true">
            <aop:pointcut id="serviceOperation" expression="execution(* cc.royao.mana.auth.service.*.impl.*ServiceImpl.*(..))"/>
            <aop:advisor pointcut-ref="serviceOperation" advice-ref="txAdvice"/>
        </aop:config>
    
        <!-- 配置事务通知 -->
        <tx:advice id="txAdvice" transaction-manager="transactionManager">
            <tx:attributes>
                <tx:method name="*" rollback-for="Exception"/>
            </tx:attributes>
        </tx:advice>
    
        <tx:advice id="transactionManagerAdivice" transaction-manager="transactionManager">
            <tx:attributes>
                <tx:method name="*insert*" propagation="REQUIRED"/>
                <tx:method name="*add*" propagation="REQUIRED"/>
                <tx:method name="*update*" propagation="REQUIRED"/>
                <tx:method name="*Update*" propagation="REQUIRED"/>
                <tx:method name="*del*" propagation="REQUIRED"/>
                <tx:method name="*create*" propagation="REQUIRED"/>
    
                <tx:method name="doApproved" propagation="REQUIRED"/>
                <tx:method name="batchDelFm" propagation="REQUIRED"/>
                <tx:method name="editTemplate" propagation="REQUIRED"/>
                <tx:method name="dummyDelete" propagation="REQUIRED"/>
                <tx:method name="batchDelUser" propagation="REQUIRED"/>
                <!--<tx:method name="*" propagation="REQUIRED"/>-->
            </tx:attributes>
        </tx:advice>
    
    
        <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    
            <property name="basePackage">
                <value>cc.royao.mana.auth.mapper.*</value>
            </property>
            <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
    
        </bean>
    
    
    
    
        <import resource="application-servlet.xml"/>

      <!-- 重点在这里 ,我把整个xml文件内容复制出来,怕你们不知道插入在哪里-->
    <import resource="spring-plan.xml"/>
    
    

    </beans>

    这样就ok了,有不懂的地方可以加作者的QQ1983127490

  • 相关阅读:
    解决IntelliJ IDEA 创建Maven项目速度慢问题 DarchetypeCatalog
    加快项目创建 -DarchetypeCatalog=internal
    AKS (3) 在AKS中使用Azure File
    AKS (2) SSH登录到AKS Node
    Azure Virtual Network (18) 跨租户间的VNet Peering
    Azure ARM (23) 自定义Role
    Linux学习 (5) 安装Nginx
    Linux学习 (4) MySQL设置Master-Slave
    Linux学习 (3) 安装mysql
    Linux学习 (3) 配置LVM
  • 原文地址:https://www.cnblogs.com/thirteen-zxh/p/8943765.html
Copyright © 2011-2022 走看看