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 

      原文詳細，不再贅述