使用Spring与Spring批处理的集成

Question

我有一个spring批处理应用程序，它从文件中读取数据，进行一些处理，最后编写一个定制的输出。这一切都是一步到位的。在下一步中，我将使用一个tasklet来归档输入文件（移动到另一个文件夹）。这个应用程序运行良好。但是，现在我需要在远程服务器上对sftp输出文件进行进一步处理。我找到了一种使用spring integration实现sftp的方法，在这里我创建了一个输入通道，该通道将反馈给outboundchannel适配器。我把我的文件作为有效载荷放在消息中，并将消息发送到通道。我在这里看到的唯一问题是，每次我必须获得加载spring配置文件所需的上下文，这似乎是一种完成任务的黑客方式。有人知道把SI和SB结合起来的方法吗。

如果你想查看我的配置，请告诉我。。。提前谢谢！！

无需再次加载spring配置即可访问同一应用程序上下文的代码

public class AppContextProvider implements ApplicationContextAware{

    private static ApplicationContext ctx;

    public ApplicationContext getApplicationContext() {
        return ctx;
    }

    public void setApplicationContext(ApplicationContext appContext) throws BeansException {
        ctx = appContext;
    }
} 

将输出文件推送到sftp服务器的代码

log.info("Starting transfer of outputFile : " + absoluteOutputFileName);
final File file = new File(absoluteOutputFileName);
final Message<File> message = MessageBuilder.withPayload(file).build();
AppContextProvider context = new AppContextProvider();
final MessageChannel inputChannel = context.getApplicationContext().getBean("toChannel",MessageChannel.class);
inputChannel.send(message);
log.info("transfer complete for : " + absoluteOutputFileName);

Answer 1

正如Michael所说，您肯定希望查看并利用spring批处理集成。实际上，我们使用Spring集成作为某种包装来启动100%的Spring批处理作业。

我们发现一个特别有用的用例是利用spring集成文件入站通道适配器轮询暂存目录，以指示新批处理文件何时到达。当轮询器找到一个新文件时，我们使用输入文件名作为参数启动一个新的批处理作业。

在可重启性方面，这是一个真正的帮助，因为我们现在每个文件有一个作业实例，而不是以任意间隔启动作业，然后在临时文件夹中的多个文件之间进行分区。现在，如果在处理过程中发生异常，您可以立即将特定作业作为重新启动的目标，而不是等待100个“良好”文件中的99个先完成。

Answer 2

查看spring batch项目中的spring batch integration模块。在那里，我们有通过消息启动作业的组件。在您的情况下，您可以通过FTP下载文件，然后让JobLaunchingMessageHandler启动作业。

你也可以看这段视频，我几年前在Spring一号上共同发表了一个关于这个主题的演讲：https://www.youtube.com/watch?v=8tiqeV07XlI