elastic job配置

 zookeeper注册中心配置
 1 package com.zwh.pay.account.worker;

import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Created by Administrator on 2017/7/10.
 */
@Configuration
public class RegistryCenterConfig {

    @Bean(initMethod = "init")
    public ZookeeperRegistryCenter  createZookeeperRegistryCenter(@Value("${regCenter.serverList}") final String serverLists, @Value("${regCenter.namespace}") final String namespace){
        ZookeeperConfiguration zookeeperConfiguration = new ZookeeperConfiguration
                (serverLists,namespace);
        return new ZookeeperRegistryCenter(zookeeperConfiguration);
    }
}

 开启事件追踪器
 1 package com.zwh.pay.account.worker;

import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.event.rdb.JobEventRdbConfiguration;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

/**
 * Created by Administrator on 2017/7/10.
 */
@Configuration
public class JobEventConfig {

    @Autowired
    private DataSource dataSource;

    @Bean("jobEventConfiguration")
    public JobEventConfiguration createJobEventConfiguration(){
        return new JobEventRdbConfiguration(dataSource);
    }
}

 配置任务启动类
 1 package com.zwh.pay.account.worker;

import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.lite.api.JobScheduler;
import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
import com.dangdang.ddframe.job.lite.spring.api.SpringJobScheduler;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 
 * ClassName: JobStart <br/>
 * Function: TODO 定时任务启动类. <br/>
 * Reason: TODO ADD REASON(可选). <br/>
 * date: 2017年9月30日 上午10:31:26 <br/>
 *
 * @author zhangwenhao
 * @version 1.0
 * @since JDK 1.8
 */
@Configuration
public class JobStart {

    @Autowired
    private ZookeeperRegistryCenter zookeeperRegistryCenter;

    @Autowired
    private JobEventConfiguration jobEventConfiguration;

    @Bean("fundCarryJob")
    public FundCarryJob fundCarryJob() {
        return new FundCarryJob();
    }

    private LiteJobConfiguration getLiteJobConfiguration(String cron, int
            shardingTotalCount, @SuppressWarnings("rawtypes") Class clazz) {
        return LiteJobConfiguration.newBuilder(
                new SimpleJobConfiguration(
                        JobCoreConfiguration.newBuilder(
                                clazz.getName(), cron,
                                shardingTotalCount).build(),
                        clazz.getCanonicalName()))
                .overwrite(true).build();
    }

    @Bean(initMethod = "init", name = "fundCarryJobScheduler")
    public JobScheduler fundCarryJobScheduler(final FundCarryJob fundCarryJob,
            @Value("${fundCarryJob.cron}")  String cron,
            @Value("${fundCarryJob.shardingTotalCount}")
            int shardingTotalCount) {

        return new SpringJobScheduler(fundCarryJob,
                zookeeperRegistryCenter,
                getLiteJobConfiguration(cron, shardingTotalCount,
                        FundCarryJob.class), jobEventConfiguration);
    }

}

定时任务执行
package com.zwh.pay.account.worker;


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.hivescm.pay.account.service.AccountSeqFlowService;

/**
 * ClassName:FundCarryJob <br/>
 * Function: TODO 定时任务执行. <br/>
 * Reason:     TODO ADD REASON. <br/>
 * Date:     2017年9月29日 下午5:55:51 <br/>
 * @author   zhangwenhao
 * @version  1.0
 * @since    JDK 1.8
 * @see      
 */
public class FundCarryJob implements SimpleJob{

    private Logger logger = LoggerFactory.getLogger(FundCarryJob.class);
    @Autowired
    @Override
    public void execute(ShardingContext arg0) {
        }
}

配置文件
1 #elastic job config
regCenter.serverList=10.12.31.100:2181,10.12.31.105:2181,10.12.31.109:2181
regCenter.namespace=fundCarryJob

fundCarryJob.cron=*/5 * * * * ?
#fundCarryJob.cron=0 0 0 * * ?
fundCarryJob.shardingTotalCount=1