java-分布式任务调度的两种方式

在以往的项目开发中，分布式任务调度从 代码控制 到数据库 控制的过渡。。。。。

第一种方式：扩展spring 的 CronTriggerBean,将  属性注入进去

先来看一段代码：

 

package com.lixiaodao.task.quartz;

import java.text.ParseException;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.quartz.CronTriggerBean;

import com.lixiaodao.utils.DateUtil;
import com.lixiaodao.utils.StrUtils;

public class LixiaodaoCronTriggerBean  extends CronTriggerBean{

    private static final long serialVersionUID = 4625482606892589275L;
    
    private static final Logger logger = LoggerFactory.getLogger(LixiaodaoCronTriggerBean.class);
    
    private Map<String, String> cronExpressionMap;
    
    private static final String TEN_YEAR_LATER = DateUtil.date2String(DateUtil.rollByYear(10), DateUtil.SDF_YYYY);
    private static final String NOT_EXCUTE =  "0 0 0 1 1 ? " + TEN_YEAR_LATER; /**设定一个10年后的时间，只要服务器10年内重启，定时任务就不会执行**/

    /**
     * 重写 父类的方法
     */
    @Override
    public void setCronExpression(String cronExpression) throws ParseException {
        String localIp = "";//TODO ..这里是获取本地ip 的一种方式，内网或者外网，都可以，只要统一就ok
        cronExpression = "";
        if(cronExpressionMap != null){
            cronExpression = cronExpressionMap.get(localIp);
        }
        if(StrUtils.isBlank(cronExpression)){
            cronExpression = NOT_EXCUTE;
        }
        logger.debug("{} 使用 定时 {}",new Object[]{localIp,cronExpression});
        super.setCronExpression(cronExpression);
    }
    
}

再看配置：（黄色部分）

  1）自己扩展

  2）配置文件注入 <ip,执行周期键值对>

    如此就可以实现，多台服务器（不同ip），相同的配置文件下，不同的服务器调度不同的任务了

　　　　

    <bean id="runTask" class="com.lixiaodao.task.quartz.LixiaodaoCronTriggerBean">
        <property name="jobDetail">
            <bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
                <property name="targetObject" ref="adminUserService"/>
                <property name="targetMethod" value="clearPublishCount"/>
                <property name="concurrent" value="false"/>
            </bean>
        </property>
        <property name="cronExpressionMap">  
              <map>  
                <entry key="10.4.7.78" value="0 0 0 * * ?"/> 
                <entry key="10.4.3.180" value="0 2 0 * * ?"/>
              </map>  
          </property>
    </bean>

第二种方式：　用 quartz 提供的数据库 实现方式，实现分布式任务调度

　　 具体参见：http://blog.csdn.net/zxl315/article/details/10830105 

      原文详细，不再赘述