当前位置: 首页 > 知识库问答 >
问题:

Spring集成调用Spring批

方嘉言
2023-03-14

如果其他人已经解决了这个问题,那就只是寻找一些信息。我想同时使用Spring集成和Spring批处理。这两个都是SpringBoot应用程序,理想情况下,我希望将它们和各自的配置分开,这样它们都是自己的可执行jar。我在自己的进程空间中执行它们时遇到问题,我相信我希望,除非有人能说服我,否则,每个程序都能像自己的Spring Boot应用程序一样运行,并用自己的配置文件和属性初始化自己。不过,我遇到的问题是从SpringIntegration项目调用SpringBatch项目中的作业。起初,我无法从批处理项目中加载属性,所以我意识到我需要通过spring。忙碌的个人资料作为工作参数,这似乎解决了这个问题。但是Spring Boot批处理应用程序中还有其他一些东西没有像schema平台那样正确加载。sql文件和数据库未初始化等。

在作业的初始启动中,我可能希望响应返回到Spring集成,以获取关于作业状态的一些消息。有时我想在Spring集成没有启动作业的情况下运行作业,但仍然要利用将状态发送回Spring集成项目的优势,在通道或其他地方提供监听。

我已经查看了很多Spring示例,还没有找到确切的场景,大多数都是同一个项目中的两个依赖项,所以可能我正在做一些不可能的事情,但我确定我只是缺少Spring配置中的一点东西。

我的问题是:

  • 我不想让Spring集成项目知道任何关于SpringBatch配置的事情,除了工作的开始。我找到了一种很好的方法,可以在不加载整个批处理配置的情况下引用作业Bean

寻找一些通用的项目配置设置,以满足这些要求。

共有1个答案

劳星晖
2023-03-14

Spring Cloud Data Flow与Spring Cloud任务的结合完全符合您的要求。它在您选择的平台上作为新进程启动Spring Cloud任务应用程序(可以包含批处理作业)。我建议您在这里查看该项目:http://cloud.spring.io/spring-cloud-dataflow/

 类似资料:
  • Spring提供了特殊的类DelegatingVariableResolver,以无缝方式将JSF和Spring集成在一起。 在JSF中集成Spring依赖注入(IOC)功能需要以下步骤。 第1步:添加DelegatingVariableResolver 在faces-config.xml中添加一个variable-resolver条目,指向spring类DelegatingVariableRes

  • 我是spring集成和缓存新手,想知道如何将从出站网关接收到的对象添加到缓存中。无法确定所需的配置。 从以下配置,我从rest api收到的对象正在被记录: INFO:com.domain.IpAddress@74589991 我计划使用ehcache/caffiene,任何提示都会有帮助。 编辑2: 现在,我按照建议更改了出站网关: 并将ehache配置定义如下: 在我的服务类中,定义了可缓存的

  • 我有以下2个组件,它们应该首先从Mongo中删除文档,然后从Elastic中删除。 主要流程: 服务: 不幸的是,deleteDocumentInMongo从未被调用。我可以在日志中看到bean已正确注册。 我是做错了什么,还是你需要更多的调试信息?如果我窃听手柄,则deleteDocumentInES。执行输入,但忽略mongo流。

  • 我有一个要求,在我必须使用不同的有效负载值对Httpendpoint进行Http出站调用的循环中,调用函数不必等待从出站调用收到的响应,因此基本上出站调用将在循环中异步发生。 有没有办法用Http.outbound网关

  • 问题内容: 我想使用Spring Batch和Spring Integration从数据库导入数据,并将它们写入文件,然后通过ftp将其传输到远程服务器。 但是我想我的问题是我不想为我的表创建域对象。我的查询是随机的,我想要一些可以读取数据并将其写入文件并进行传输的东西。 是否可以在不创建各自的域对象的情况下使用Spring Batch和Integration? 问题答案: 绝对。您可以将JDBC

  • 我需要从REST服务调用SOAP Webservice。我在我的项目中使用Spring集成。目前,我正在使用基于xml的配置来实现目标。但我想用java dsl编写代码。请帮助我如何使用Spring集成DSL从REST服务调用SOAP服务。 一个例子会很有帮助。