springbatch自学之路-09（监听器）

超、凢脫俗 2023-02-17 14:55 15阅读 0赞

**目录**

1.启动类

2.Job监听器

3.chunk监听器

4.配置类

--------------------

1.启动类

package com.springbatch._07listener;
    
    import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /**
     * SpringBatchDemo项目启动类
     *
     * @Package: PACKAGE_NAME
     * @ClassName: com.springbatch._01helloworld.SpringBatchConfig
     * @author: zq
     * @since: 2020/5/22 20:31
     * @version: 1.0
     * @Copyright: 2020 zq. All rights reserved.
     */
    @SpringBootApplication
    @EnableBatchProcessing
    public class SpringBatchConfig {
    
        public static void main(String[] args) {
    
            SpringApplication.run(SpringBatchConfig.class, args);
    
        }
    
    }

2.Job监听器

package com.springbatch._07listener;
    
    import org.springframework.batch.core.JobExecution;
    import org.springframework.batch.core.JobExecutionListener;
    
    /**
     * Job监听器
     *
     * @Package: com.springbatch._07listener
     * @ClassName: MyJobListener
     * @author: zq
     * @since: 2020/6/14 18:57
     * @version: 1.0
     * @Copyright: 2020 zq. All rights reserved.
     */
    public class MyJobListener implements JobExecutionListener {
    
        @Override
        public void beforeJob(JobExecution jobExecution) {
    
            System.out.println(jobExecution.getJobInstance().getJobName() + "before...");
    
        }
    
        @Override
        public void afterJob(JobExecution jobExecution) {
    
            System.out.println(jobExecution.getJobInstance().getJobName() + "after...");
    
        }
    }

3.chunk监听器

package com.springbatch._07listener;
    
    import org.springframework.batch.core.annotation.AfterChunk;
    import org.springframework.batch.core.annotation.BeforeChunk;
    import org.springframework.batch.core.scope.context.ChunkContext;
    
    /**
     * Trunck监听器
     *
     * @Package: com.springbatch._07listener
     * @ClassName: MyChunkListener
     * @author: zq
     * @since: 2020/6/14 18:58
     * @version: 1.0
     * @Copyright: 2020 zq. All rights reserved.
     */
    public class MyChunkListener {
    
        @BeforeChunk
        public void before(ChunkContext chunkContext) {
    
            System.out.println(chunkContext.getStepContext().getStepName() + "before===");
    
        }
    
        @AfterChunk
        public void after(ChunkContext chunkContext) {
    
            System.out.println(chunkContext.getStepContext().getStepName() + "after===");
    
        }
    
    }

4.配置类

package com.springbatch._07listener;
    
    import org.springframework.batch.core.Job;
    import org.springframework.batch.core.Step;
    import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
    import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
    import org.springframework.batch.item.ItemReader;
    import org.springframework.batch.item.ItemWriter;
    import org.springframework.batch.item.support.ListItemReader;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.util.Arrays;
    import java.util.List;
    
    @Configuration
    public class ListenerJobConfig {
    
        //创建 创建job的对象
        @Autowired
        private JobBuilderFactory jobBuilderFactory;
    
        //创建 创建step的对象
        @Autowired
        private StepBuilderFactory stepBuilderFactory;
    
        @Bean
        public Job listenerJob() {
    
            return jobBuilderFactory.get("listenerJob")
                    .start(myChunkStep())
                    .listener(new MyJobListener())
                    .build();
    
        }
    
        @Bean
        public Step myChunkStep() {
            return stepBuilderFactory.get("myChunkStep")
                    .<String, String>chunk(2)
                    .faultTolerant()
                    .listener(new MyChunkListener())
                    .reader(read())
                    .writer(write())
                    .build();
        }
    
        @Bean
        public ItemWriter<String> write() {
            return new ItemWriter() {
                @Override
                public void write(List list) throws Exception {
                    for (Object o : list) {
    
                        System.out.println(o);
    
                    }
                }
            };
        }
    
        @Bean
        public ItemReader<String> read() {
    
            return new ListItemReader<>(Arrays.asList("java", "c", "c++"));
    
        }
    
    
    }

5.执行结果

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200614191250105.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU=,size_16,color_FFFFFF,t_70