通用的调度框架：iquartz

通用任务调度框架iquartz提供定时任务的定制化，能够开发出特定的任务并进行调度，如数据交换、数据处理、文件上传下载等各类任务，iquartz采用类似tomcat的class加载机制，通过自定义classloader，实现不同任务的依赖隔离，实现各个任务运行的独立和闭环。iquartz还能够对每个任务的调度执行进行监控，详细记录任务每一次的运行情况，并提供日志接口供用户使用。

1. 搭建框架的环境

1.1 iquartz + tomcat + mysql

iquartz下载：https://github.com/gx4air/iquartz/tree/master/bin

mysql脚本：https://github.com/gx4air/iquartz/tree/master/docs

mysql数据库新建数据库iqrtz，并将iqrtz.sql导入

1.2 IDE+ plugin.jar

IDE：eclipse 或idea

plugin.jar下载：https://github.com/gx4air/iquartz/tree/master/bin/client

2. 开发定制任务

2.1 无状态任务（参数一次性设置，任务运行中不会改变）

Java代码 
package datamining.plugin;  
  
import java.util.Map;  
import org.apache.log4j.Logger;  
import com.tech.dawn.iquartz.plugin.Plugin;  
import com.tech.dawn.iquartz.plugin.PluginResult;  
  
public class KMeansPlugin implements Plugin {  
    private Logger logger = Logger.getLogger(KMeansPlugin.class);  
    @Override  
    public PluginResult doPlug(Map<String, String> arg0) throws Throwable {  
        logger.info("从数据库查数据");  
        logger.info("数据分析");  
        logger.info("数据结束，返回任务结果");  
          
        PluginResult pr = new PluginResult();  
        pr.setResulst(true);  
        return pr;  
          
    }  
  
}  

2.2 有状态任务（任务运行前设定的参数可能随着任务的不断运行而有规律的改变）

Java代码 
package data.plugin;  
  
import java.sql.Connection;  
import java.sql.DriverManager;  
import java.util.Map;  
import org.apache.log4j.Logger;  
import com.tech.dawn.iquartz.plugin.Plugin;  
import com.tech.dawn.iquartz.plugin.PluginResult;  
  
public class DataMigrationPlugin implements Plugin {  
      
    private Logger logger = Logger.getLogger(DataMigrationPlugin.class);  
  
    @Override  
    public PluginResult doPlug(Map<String, String> params) throws Throwable {  
          
        String sourceDriver = params.get("sourceDriver");  
        String sourceUrl = params.get("sourceUrl");  
        String sourceUser = params.get("sourceUser");  
        String sourcePassword = params.get("sourcePassword");  
        String rowIndex = params.get("rowIndex");  
        logger.info("从数据源取数据,url-->"+sourceUrl);  
        logger.info("sourceDriver-->"+sourceDriver);  
        Class.forName(sourceDriver);  
  
        Connection conn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword);  
        logger.info("数据源connection成功:"+conn);  
          
          
        rowIndex = (Integer.parseInt(rowIndex)+1000)+"";  
          
        params.put("rowIndex", rowIndex);  
  
        logger.info("new rowIndex:"+rowIndex);  
          
        logger.info("返回任务结果");  
        PluginResult pr = new PluginResult();  
        pr.setParams(params);  
        pr.setResulst(true);  
        return pr;  
    }  
}  