elastic-job定时器的使用

比眉伴天荒 2021-09-27 21:10 422阅读 0赞

废话不多说了，直接上代码，elastic-job的一些配置参数可以参考这篇博文：[https://blog.csdn.net/dhj199181/article/details/83088036][https_blog.csdn.net_dhj199181_article_details_83088036]

**elastic-job.xml配置：**

<?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:reg="http://www.dangdang.com/schema/ddframe/reg"
        xmlns:job="http://www.dangdang.com/schema/ddframe/job"
        xsi:schemaLocation="http://www.springframework.org/schema/beans 
                            http://www.springframework.org/schema/beans/spring-beans.xsd 
                            http://www.dangdang.com/schema/ddframe/reg 
                            http://www.dangdang.com/schema/ddframe/reg/reg.xsd 
                            http://www.dangdang.com/schema/ddframe/job 
                            http://www.dangdang.com/schema/ddframe/job/job.xsd 
                            ">
    
        
        <reg:zookeeper id="regCenter" server-lists="localhost:2181"
            namespace="elastic-job" base-sleep-time-milliseconds="1000"
            max-sleep-time-milliseconds="3000" max-retries="3" />
            
            
        <job:simple id="JobSimpleJob" class="com.it.park.rms.job.MyElasticSimpleJob"
            registry-center-ref="regCenter" cron="0/30 * * * * ?"
            sharding-total-count="3" sharding-item-parameters="0=A,1=B,2=C" />
            
            
        <job:dataflow id="myDataFlowJob" class="com.it.park.rms.job.MyDataFlowJob" registry-center-ref="regCenter"
                  sharding-total-count="2"  sharding-item-parameters="0=A,1=B,2=C,3=D,4=E"  description="分片处理" cron="0 0/1 * * * ?" streaming-process="true" overwrite="true" />
            
            
    </beans>

**SimpleJob任务例子：**

public class MyElasticSimpleJob implements SimpleJob{
    
    	@Override
    	public void execute(ShardingContext arg0) {
    		System.out.println("-------");
    		
    	}
    
    }

**DataflowJob任务例子：**

public class MyDataFlowJob implements DataflowJob<TestModel>{
    
    	@Autowired
    	private TestService testService;
    	
    	@Override
    	public List<TestModel> fetchData(ShardingContext arg0) {
    		System.out.println(arg0.getJobName());
    		System.out.println(arg0.getJobParameter());
    		System.out.println(arg0.getShardingItem());
    		System.out.println(arg0.getShardingTotalCount());
    		System.out.println(arg0.getTaskId());
    		TestModel model = new TestModel();
    		model.setStatus("N");
    		List<TestModel> list = testService.selectByModel(model);
    		System.out.println("======"+list.size());
    		return list;
    	}
    
    	@Override
    	public void processData(ShardingContext arg0, List<TestModel> list) {
    		for (TestModel testModel : list) {
    			System.out.println(testModel.getName());
    			testService.batchUpdate(Lists.newArrayList(testModel));
    			System.out.println("修改成功");
    		}
    	}
    
    }

[https_blog.csdn.net_dhj199181_article_details_83088036]: https://blog.csdn.net/dhj199181/article/details/83088036