zoukankan      html  css  js  c++  java
  • Springbatch headerCallback 居然是在processor之前执行的

    今天遇到一个奇怪的问题,在一个step里有一个chunk,还有一个step的listener,这个listener实际上是一个headerCallback,这个headerCallback里面有一个@beforeStep方法和一个writerHeader方法:

      @BeforeStep
        public void beforeStep(StepExecution stepExecution) {
            this.stepExecution = stepExecution;
        }
    
        @Override
        public void writeHeader(Writer writer) throws IOException {
            //略
        }

    然后在chunk的writer里面,也引用了这个类:

    <bean id="trustActBatTrsFileWriter"
            class="org.springframework.batch.item.support.CompositeItemWriter"
            scope="step">
            <property name="delegates">
                <list>
                    <bean class="org.springframework.batch.item.file.FlatFileItemWriter">
                        <property name="resource"
                            value="file:#{jobParameters[uploadFilePath]}#{jobParameters[uploadFileName]}.txt" />
                        <property name="lineAggregator">
                            <bean
                                class="com.csii.bank.core.batch.support.writer.PrefixSuffixDelimitedLineAggregator">
                                <property name="delimiter" value="|" />
                                <property name="delimiterAsSuffix" value="false" />
                                <property name="fieldExtractor">
                                    <bean
                                        class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor">
                                        <property name="names"               
                                            value="略" />
                                    </bean>
                                </property>
                            </bean>
                        </property>
                        <property name="headerCallback" ref="trustActBatPayHeaderCallback"/>
                    </bean>
                </list>
            </property>
        </bean>

    然后我发现这个JOB执行的时候,一上来就执行了这个trustActBatPayHeaderCallback的@beforeStep方法,这很正常,因为他是step级别的监听器,而且是@beforeStep,但是,reader一结束立马就执行了,,立马又执行了writeHeader方法,,居然是在processor之前,颠覆了我的认知,

  • 相关阅读:
    魔术方法详解、魔术变量、预定义常量、预定义变量
    RabbitMQ:生产者消费者模型构建/为消息自定义属性/自定义消费者
    RabbitMQ:相关概念
    RabbitMQ:基于centos7安装
    Spring Boot:整合Dubbo
    Dubbo:服务提供者、消费者相关配置
    Dubbo:Dubbo Admin环境搭建
    Zookeeper:Curator Watcher机制和事务控制
    Zookeeper:Curator增删改查API
    Zookeeper:集群和zab协议
  • 原文地址:https://www.cnblogs.com/heben/p/7028660.html
Copyright © 2011-2022 走看看