<?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"    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"    default-lazy-init="true">    <description>quartz配置</description>        <!-- quartz使用的数据源配置 -->    <bean id="quartzDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">        <property name="driverClassName" value="http://www.mamicode.com/${quartz.jdbc.driver}" />        <property name="url" value="http://www.mamicode.com/${quartz.jdbc.url}" />        <property name="username" value="http://www.mamicode.com/${quartz.jdbc.username}" />        <property name="password" value="http://www.mamicode.com/${quartz.jdbc.password}" />    </bean>        <!-- 另一个事务管理器, Jdbc单数据源事务 -->    <bean id="quartzTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">        <property name="dataSource" ref="quartzDataSource" />    </bean>        <bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">        <property name="dataSource" ref="quartzDataSource"/>        <property name="applicationContextSchedulerContextKey" value="http://www.mamicode.com/applicationContext"/>        <property name="configLocation" value="http://www.mamicode.com/classpath:quartz.properties"/><!--        这个是必须的，QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动         -->        <property name="startupDelay" value="http://www.mamicode.com/30"/><!--        这个是可选，QuartzScheduler 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了        -->        <property name="overwriteExistingJobs" value="http://www.mamicode.com/true"/>        <property name="jobDetails" >            <list>                <ref bean="serverHealthJobDetail"/>            </list>            </property>                </bean>        <!-- 运行次数记录 -->    <bean id="serverHealthJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">        <!--requestsRecovery属性为true，则当Quartz服务被中止后，再次启动任务时会尝试恢复执行之前未完成的所有任务-->        <property name="requestsRecovery" value="http://www.mamicode.com/true"/>        <!-- 标识job是持久的,删除触发器的时候不被删除 -->        <property name="durability" value="http://www.mamicode.com/true"/>        <property name="jobClass" value="http://www.mamicode.com/cn.yzzn.hvac.quartz.job.ServerHealthJob"/>    </bean>    </beans>

public abstract class JobSupport extends QuartzJobBean {     private BuildingManager buildingManager;    private PlcManager plcManager;     private static Logger logger = LoggerFactory.getLogger(JobSupport.class);     private ApplicationContext applicationContext;    /**     * 从SchedulerFactoryBean注入的applicationContext.     */    public void setApplicationContext(ApplicationContext applicationContext) {        this.applicationContext = applicationContext;    }     public <T> T getBean(String beanName, Class<T> clazz) {        return this.applicationContext.getBean(beanName, clazz);    }         @Override    protected void executeInternal(JobExecutionContext context)            throws JobExecutionException {        if (ObjectUtils.isNullOrEmptyString(buildingManager)) {            buildingManager = getBean("buildingManager", BuildingManager.class);        }        if (ObjectUtils.isNullOrEmptyString(plcManager)) {            plcManager = getBean("plcManager", PlcManager.class);        }         List<Building> buildingList = buildingManager.getBuildings();         int size = buildingList.size();        for (int i = 0; i < size; i++) {            Building building = buildingList.get(i);                         Set<Plc> plcSet = building.getPlcs();            for (Plc plc : plcSet) {                innerIter(building, plc, i, size);            }        }    }     public abstract void innerIter(Building building, Plc plc,            int index, int size); }public class ServerHealthJob extends JobSupport {     @Override    public void innerIter(Building building, Plc plc, int index, int size) {        // TODO Auto-generated method stub             }     }

/** * Quartz Scheduler 管理类 * 不带groupName参数的方法都采用自动填充默认组的形式 Scheduler.DEFAULT_GROUP * @author PigWing * */public class SchedulerManagerImpl implements SchedulerManager {     private QuartzDao quartzDao;    private Scheduler scheduler;         private static Logger logger = LoggerFactory.getLogger(UserController.class);          /***     * 增加一个触发器任务,采用默认组形式     */    public void addTrigger(String triggerName, String jobName,            String cronExpression) throws SchedulerException, ParseException {        addTrigger(triggerName, Scheduler.DEFAULT_GROUP, jobName, Scheduler.DEFAULT_GROUP, cronExpression);    }     /**     *      * 增加一个触发器任务     */    public void addTrigger(String triggerName, String triggerGroupName,            String jobName, String jobGrourpName, String cronExpression) throws SchedulerException, ParseException {        if(StringUtils.isEmpty(triggerName)) {            throw new RuntimeException("triggerName can not be null");        }                 try {            JobDetail jobDetail = scheduler.getJobDetail(jobName, jobGrourpName);            if(jobDetail != null) {                scheduler.addJob(jobDetail, true);                CronTrigger cronTrigger = new CronTrigger(triggerName, triggerGroupName, jobDetail.getName(), jobGrourpName);                cronTrigger.setCronExpression(cronExpression);                scheduler.scheduleJob(cronTrigger);                scheduler.rescheduleJob(cronTrigger.getName(), cronTrigger.getGroup(), cronTrigger);            }else {                logger.error("cant not find jobDetail: " + jobGrourpName);            }        }catch(SchedulerException e) {            logger.error(e.getMessage());            throw e;        }    }      /**     * 返回所有触发器信息     */    public List<Map<String, Object>> getAllTriggers() {        return quartzDao.getQuartzTriggers();    }     /**     * 停止触发器     */    public void parseTrigger(String triggerName, String groupName)            throws SchedulerException {        try {            scheduler.pauseTrigger(triggerName, groupName);        }catch(SchedulerException e) {            logger.error(e.getMessage());            throw e;        }             }     /**     * 停止触发器,采用默认组形式     */    public void parseTrigger(String triggerName) throws SchedulerException {        parseTrigger(triggerName, Scheduler.DEFAULT_GROUP);     }     /**     * 重启触发器     */    public void resumeTrigger(String triggerName, String groupName)            throws SchedulerException {        try {            scheduler.resumeTrigger(triggerName, groupName);        }catch(SchedulerException e) {            logger.error(e.getMessage());            throw e;        }              }     /**     * 重启触发器,采用默认组形式     */    public void resumeTrigger(String triggerName) throws SchedulerException {        resumeTrigger(triggerName, Scheduler.DEFAULT_GROUP);    }     /**     * 移除触发器     */    public boolean removeTrigger(String triggerName, String groupName)            throws SchedulerException {        try {            parseTrigger(triggerName, groupName);            return scheduler.unscheduleJob(triggerName, groupName);        }catch(SchedulerException e) {            logger.error(e.getMessage());            throw e;        }    }     /**     * 移除触发器,采用默认组形式     */    public boolean removeTrigger(String triggerName) throws SchedulerException {        try {            return removeTrigger(triggerName, Scheduler.DEFAULT_GROUP);        }catch(SchedulerException e) {            logger.error(e.getMessage());            throw e;        }    }     /**     * 返回所有的任务名称     */    public String[] getJobNames(String groupName) throws SchedulerException {        return scheduler.getJobNames(groupName);    }     public String[] getJobNames() throws SchedulerException {        return scheduler.getJobNames(Scheduler.DEFAULT_GROUP);    }     @Autowired    public void setQuartzDao(QuartzDao quartzDao) {        this.quartzDao = quartzDao;    }     @Autowired    public void setScheduler(Scheduler scheduler) {        this.scheduler = scheduler;    }      }