我管理一个现在相当大的spring集成应用程序。最近,我们想要添加一个使用spring批处理的批处理作业(原理:管理、监视、调度、在沿途任何地方发生故障时重新启动的能力)。
由于我们已经开发了很多到公司服务的连接器,我们计划在批处理中重用它们,所以我一直在密切关注spring批处理和spring集成是如何协同工作的(其中包括:spring批处理集成)。我们的想法是使用(已经可用的)spring集成组件以某种方式实现spring批处理任务。
我可能错过了spring核心层的一些基本内容,但我无法找到一种简单的方法从spring批处理任务中“调用”spring集成endpoint(如果我们忘记了复杂的管道,如RMI调用、“远程分块”、“远程分区”……)
我错过什么了吗?
这是一个非常常见的用例(从批处理作业/步骤调用集成流)。
只需将集成网关连接到Tasklet中即可。
在最近的应用程序中,使用messaginggateway
注释或DSL非常常见。但是,如果您更熟悉XML,那么
也会很好地工作。
我有一个spring批处理应用程序,它从文件中读取数据,进行一些处理,最后编写一个定制的输出。这一切都是一步到位的。在下一步中,我将使用一个tasklet来归档输入文件(移动到另一个文件夹)。这个应用程序运行良好。但是,现在我需要在远程服务器上对sftp输出文件进行进一步处理。我找到了一种使用spring integration实现sftp的方法,在这里我创建了一个输入通道,该通道将反馈给outb
如果其他人已经解决了这个问题,那就只是寻找一些信息。我想同时使用Spring集成和Spring批处理。这两个都是SpringBoot应用程序,理想情况下,我希望将它们和各自的配置分开,这样它们都是自己的可执行jar。我在自己的进程空间中执行它们时遇到问题,我相信我希望,除非有人能说服我,否则,每个程序都能像自己的Spring Boot应用程序一样运行,并用自己的配置文件和属性初始化自己。不过,我遇
我们有一个Spring批量应用程序。除了运行应用程序的能力之外,我们还拥有一些轻量级测试类,这些类允许我们单独运行每个作业,并在作业完成后执行断言。 这对于在本地运行测试很好。但是,对于定义测试在持续集成环境(如TeamCity)中运行的最佳实践,有没有人能给出建议。 对于使用持续集成测试Spring Integration应用程序,也有一个类似的问题。
我正在尝试将BeanIO与spring Batch集成。使用BeanIO,我正在读取一个固定长度的流文件。我已经测试并验证了使用独立类读取平面文件的代码,它可以无缝地工作,但是当我试图将它与Spring Batch集成时,BeanIOFlatFileItemReader的doRead()方法没有被调用,而且我编写的RedemptionEventCustomProcessor是如何直接被调用的。 我
我正在将Spring Boot项目与Spring批处理和数据jpa项目集成。所有与作业和数据配置相关的东西都是正确的,除了将我的作业编写器结果保存在数据库中。在我读取文件并对其进行处理后,我无法将其写入mysql数据库。没有错误,但也没有插入。有趣的是我的数据源已配置。因为在插入之前,我可以从数据库中获取示例记录。请协助我解决这个问题。 我的申请。属性: 批次配置: 道类: 作家类: temPer
我正在构建一个小微服务来访问来自SFTP文件服务器的文件。我决定使用Spring Integration SFTP完成这项工作。我对Spring Integration很陌生,对它的工作原理很困惑。 我的目标是在SFTP服务器上获得一个目录中的文件列表,并将它们呈现给用户界面。从那里,用户将选择一个文件进行下载,我将使用文件名将文件从SFTP服务器流式传输到用户界面。 其次,我是否需要两个接口才能