将spring batch和spring集成结合起来？
当从服务器上检索文件并根据条件将文件路由到mvChannel和toGet通道时，我有许多在从服务器上检索文件的过程场景，我定义了一个路由器处理场景，并路由到作业通道和运行spring Batch
，我的问题是这是正确的体系结构吗？
共有1个答案
看起来真不错。从Spring集成和Spring批处理世界中集成它们是一种典型的模式。
但是，我在上一个
中看不到原因。您的所有作业都可以将其结果发送到
。看起来不需要等待所有的结果在一个地方做一些分析。
-
在我的用例中，最简单的集成组件安排是什么： 接收来自多个来源和多种格式的消息（所有消息都是JSON序列化对象）。 将消息存储在缓冲区中最多10秒（聚合） 通过不同的类属性getter（例如class1.someId（），class2.otherId（），...） 释放所有分组的消息并转换为新的聚合消息。 到目前为止（第1点和第2点），我正在使用聚合器，但不知道3）处的问题是否有现成的解决方案或者我
-
假设存在包含方法的接口： 实现combinedCall方法的最佳方法是什么： 从makeHttpCall获取数据 使用store InDatabase存储它 返回在store InDatabase完成时完成的完成？ 似乎在RxJava 1.0中可以执行Completable.merge（可观察），但合并似乎不再接受可观察。
-
Usecase：使用EventTime并从Kafka的记录中提取时间戳。 我想要的是：Flink提取时间戳并在初始间隔（例如20秒）内为每条记录发出水印，然后它可以周期性地发出水印（例如每10秒）。 原因：如果我使用PeriodicWatermark，开始时Flink只会在一段时间间隔后发出水印，并且我的第一个窗口（5分钟）中的计数是错误的-比后续窗口中的计数大得多。我有一个解决办法，将自动水印间
-
是否可以有一个登录rest服务，该服务使用Spring Security验证容器安全性，如果成功，则返回JWT令牌。然后调用其他服务将使用JWT过滤器。 基本思想是这样的。 我有一个React应用程序，它有一个登录页面。它发送一个带有用户名和密码的登录请求（通过rest服务）。安全性是基于容器的（例如Tomcat用户）。Spring security应该通过容器进行身份验证，如果用户名和密码正确，
-
问题内容： 您有一个要运行一些软件要求的项目（例如：特定版本的Apache，PHP版本，MySQL数据库实例以及其他几个软件）。 您已经发现Vagrant，因此您的虚拟环境已全部设置好。您可以在配置文件和食谱之外创建框。 您还已经了解了诸如Jenkins之类的持续集成系统的优势。 现在，您想结合这两个世界（Vagrant和Jenkins）以获得完美的持续集成环境。更具体地说，您不希望在运行Jenk
-
我想使用聚合器从两条消息中创建一条消息，但我不知道如何做到这一点。 目前，我正在从一个目录中读取两个文件，并希望将这些消息聚合为一个。 我的整个项目是这样的： 读入。拉链- 如果我可以在解压缩文件后发送一条包含两个有效负载的消息，那就太好了，但在读取后聚合就足够了。 我的拉链看起来像这样： 它将这些文件放入两个目录中，我使用FileReadingMessageSource再次从中读取它们。我还想只