Spring批处理中的多个项目编写器
我目前正在编写一个Spring批处理，其中我正在读取一个数据块，并对其进行处理，然后我希望将此数据传递给两个Writer。一个writer将简单地更新数据库，而第二个writer将写入csv文件。
我计划编写自己的自定义编写器，并在customItemWriter中注入这两个ItemWriter，并在customItemWriter的write方法中调用这两个ItemWrite的write方法。这种做法是否正确？是否有符合我要求的ItemWriter实现？
提前致谢
共有1个答案
您可以使用Spring的CompositeItemWriter并将您的所有Writer委托给它。
下面是一个配置示例。
-
我们使用Spring Batch进行一些处理，通过Reader读取一些ID，我们希望通过处理器将它们处理为“块”，然后写入多个文件。但是处理器接口一次只允许处理一个项目,我们需要进行批量处理,因为处理器依赖于第三方,不能为每个项目调用服务。 我看到我们可以为“块”中涉及的所有读取器-处理器-写入器创建包装器，以处理列表<>并委托给一些具体的读取器/处理器/写入器。但这对我来说并不是件好事。像这样：
-
事务在Spring批处理中未回滚。我有意抛出异常来测试事务回滚。即使从项目编写器引发异常，数据库事务也在提交。下面是写入器中保存到DB中的方法。对象是注入到此类中的 jpa 存储库 我尝试用@Transactional（传播=Propagation.REQUIRES_NEW， rollbackFor=Exception.class）标记上述方法的事务，但它仍然在提交事务。我肯定我错过了一些东西。任
-
关于文章Spring批处理CompositeItemWriter如何管理委托编写器的事务？，对于复合项编写器事务管理，难道不应该将数据源包装在如下所示的事务管理器中吗？没有下面的bean定义，事务管理就无法与Oracle和Hikari CP一起工作。不确定帖子中提供的示例是如何工作的。请澄清
-
我必须像这样配置批处理作业流。 XML文件阅读器- 我的定制处理器是这样的 这是一个好的方法吗？我看到了一些CompositeProcess、CompositeWriter的例子，但没有一个适合我的案例。 提前谢谢。
-
我是Spring批处理的新手，目前正在处理一个新的批处理作业。我的批处理作业： 读取器：读取数据库中的记录（即5家公司的员工） 处理器：处理记录 5个writer：过滤并写入每个文件（即A公司的员工在A路径写入A公司文件，B公司的员工在B路径写入B公司文件），最后一个writer将A公司的所有离职员工写入D公司。 任务：将文件保存到数据库中。 目前，我正在使用CompositeItemWriter
-
我是Spring批次的新手。我需要在spring批处理中实现的任务如下： 需要从数据库读取一些元数据。 基于此元数据，我需要读取一些文件。 经过一些处理后，需要将这些值从文件写入数据库。 我的查询如下： c.另外，基于某些条件，我可能需要调用第三组阅读器。如何在步骤中有条件地调用读取器？ 谢谢你看了我的帖子。我知道它很长。非常感谢任何帮助。另外，我想一个示例代码片段会帮助我更好地理解这一点。：）