如何在spring batch和spring Integration中从itemWriter编写输出通道？

Question

首先感谢大家的关注，我将spring batch和spring integration结合起来，定义了一个作业流，从ftp适配器中检索文件发送到jobChannel，并用spring batch对其进行处理，我要写到输出通道，处理后使用通道，我的代码是：

     <int-ftp:outbound-gateway id="gatewayGET"
                                  local-directory-expression="'./backup/' +#remoteDirectory"
                                  session-factory="ftpSessionFactory"
                                  request-channel="toGetChannel"
                                  reply-channel="toProcessChannel"
                                  command="get"
                                  temporary-file-suffix=".writing"
                                  command-options="-P"
                                  expression="payload.remoteDirectory + '/' + payload.filename"/>
        <int:channel id="toProcessChannel">
            <int:interceptors>
                <int:wire-tap channel="logger2"/>
            </int:interceptors>
        </int:channel>
    <int:channel id="outboundJobRequestChannel"/>
    <int:channel id="replyJobChannel"/>
   <service-activator input-channel="jobLaunchReplyChannel"/>
 <int:transformer input-channel="toProcessChannel" output-channel="outboundJobRequestChannel">
        <bean class="ir.isc.macna.configuration.FileMessageToJobRequest">
            <property name="fileParameterName" value="fileName"/>
        </bean>
    </int:transformer>
    <batch-int:job-launching-gateway request-channel="outboundJobRequestChannel"
                                     reply-channel="jobLaunchReplyChannel"/>

@Component
@StepScope
public class MacnaFileWriter implements ChunkMessageChannelItemWriter<FileInfo> {

    @Autowired
    @Qualifier("replyJobChannel")
    private MessageChannel messageChannel;
    @Override
    public void write(List<? extends FileInfo> list) throws Exception {

       // send Message to replyJobChannel channel with Send method
    }
}

<int-ftp:outbound-gateway session-factory="ftpSessionFactory"
                              request-channel="replyJob"
                              command="mput"
                              auto-create-directory="true"
                              expression="payload"
                              remote-directory-expression="payload.remoteDirectory + '/' + payload.filename + '.out'"
                              reply-channel="output"/>

Answer 1

MessageChannel具有Send方法。为此，您可以使用MessageBuilder为您的有效负载创建消息 。

由于它只是一个 ，因此与任何其他MessageChannel都没有区别。定义消费者的标准方法如下：

<service-activator input-channel="jobLaunchReplyChannel"/>

但是，不清楚为什么要将消息发送到JobLaunchReplyChannel，因为该通道是针对 (JobLaunchingGgateway类）的结果的：

jobExecution = this.jobLaunchingMessageHandler.launch(jobLaunchRequest);

请参见Spring批处理集成文档。

也许您需要AsynciteMwriter或ChunkMessageChannelItemWriter？