在Spring批处理作业之后触发Spring集成出站适配器

Question

我的要求和帖子里描述的差不多。i、 例如，在文件生成器Spring批处理完成后触发Spring集成程序。这里我主要使用Spring集成示例：XML配置和测试。我观察到，测试程序将配置文件初始化为ClassPathXmlApplicationContext，然后根据需要设置一些值。忽略配置，程序的关键似乎是以下四行：

final File file = new File(sourceFileName);
final Message<File> message = MessageBuilder.withPayload(file).build();
final MessageChannel inputChannel = ac.getBean("inputChannel", MessageChannel.class);
inputChannel.send(message);

我想知道是否有一个选项可以将其移动到配置文件本身，这样我就不必从测试程序中创建消息或将其传递到MessageChannel，只需启动Spring批处理，并观察它在作业完成后调用出站SFTP触发器。如果完成了，我的工作基本完成了，这样我就可以在Spring批处理工作的下一步插入它。

如果你注意到入站适配器的例子，我可以用下面的代码行在配置文件中完成所有这些：

<int-sftp:inbound-channel-adapter id="sftpInbondAdapter"
        channel="receiveChannel"
        session-factory="sftpSessionFactory"
        local-directory="file:${inbound.local.directory}"
        remote-directory="${inbound.remote.directory}"
        auto-create-local-directory="true"
        delete-remote-files="false"
        filename-pattern="*.*">
    <int:poller max-messages-per-poll="-1" fixed-rate="1000" />
</int-sftp:inbound-channel-adapter>

<int:channel id="receiveChannel">
    <int:queue/>
</int:channel>

从测试程序中，我可以做如下操作：

PollableChannel localFileChannel = context.getBean("inboundFileChannel", PollableChannel.class);
System.out.println("Received first file message: " + localFileChannel.receive());

也许我错过了一些非常基本的东西。我还查看了前面帖子中引用的示例，它调用了一个Tasklet，在这个Tasklet中，用户再次初始化上下文文件，这在我的例子中似乎不是一个好方法，因为我将在相同的XML中使用Spring批处理和Spring集成配置，就像它看起来是一个循环调用一样。

Answer 1

您可以使用消息网关。只需定义一个POJI并将其配置为

或者，使用JobLaunchingGateway启动批处理作业，然后在网关完成后执行sftp工作。