Spring Batch :一个阅读器，复合处理器(两个具有不同实体的类)和两个kafkaItemWriter
Spring Batch是一个开源的批处理框架，用于处理大量的数据操作。它提供了一种简单且灵活的方式来处理复杂的批处理作业，如数据导入/导出、数据清洗、报表生成等。
Spring Batch的核心概念包括阅读器（Reader）、复合处理器（Processor）和写入器（Writer）。阅读器用于读取数据源中的数据，可以是数据库、文件、消息队列等。复合处理器用于对读取的数据进行处理，可以进行数据转换、过滤、验证等操作。写入器用于将处理后的数据写入目标位置，可以是数据库、文件、消息队列等。
在给定的问答内容中，提到了两个kafkaItemWriter。kafkaItemWriter是Spring Batch提供的一个特殊的写入器，用于将处理后的数据写入Kafka消息队列。Kafka是一个高吞吐量的分布式发布订阅消息系统，适用于大规模的实时数据处理。
Spring Batch的优势包括：
- 可扩展性：Spring Batch可以处理大量的数据操作，并且可以通过分布式部署来实现水平扩展，以满足高并发的需求。
- 可靠性：Spring Batch提供了事务管理机制，确保批处理作业的数据一致性和可靠性。
- 灵活性：Spring Batch提供了丰富的配置选项和扩展点，可以根据具体需求进行定制和扩展。
- 监控和管理：Spring Batch提供了丰富的监控和管理功能，可以对批处理作业进行监控、统计和管理。
Spring Batch的应用场景包括：
- 数据导入/导出：可以用于将大量的数据从一个数据源导入到另一个数据源，如将CSV文件中的数据导入到数据库中。
- 数据清洗和转换：可以用于对数据进行清洗、转换和验证，如对数据进行格式化、去重、校验等操作。
- 报表生成：可以用于生成各种类型的报表，如日报、周报、月报等。
- 批量任务处理：可以用于处理各种批量任务，如批量支付、批量退款等。
腾讯云提供了一系列与Spring Batch相关的产品和服务，包括云数据库、消息队列、云服务器等。具体推荐的产品和产品介绍链接地址可以根据实际需求和使用场景进行选择。
相关·内容
1回答
我正在开发Spring Batch CompositeItemReader and Writter示例。在这个程序中，我尝试读取数据，从mysql表中读取两个表，和写到单个XML文件。当我试图这样做时，我看到下面的错误正在出现：
java.lang.ClassCastException: java.lang.String cannot be cast to com.common.batch.model.Customer
at com.common.batch.processor.CustomerProcessor.process(CustomerProcessor.java:1)
浏览 2提问于2016-04-03得票数 0
1回答
步骤配置示例：
Step employersStep = stepBuilderFactory.get("employersStep")
.<Employer, EmployerEntity>chunk(10)
.reader(amqpReader())
.processor(processor)
.writer(entityWriter)
.build();
如你所见，我正在努力：
从AMQP代理(RabbitMQ);process it读取数据；将处理过的数据写入DB.。
案件的预期
浏览 2提问于2021-08-11得票数 0
根据Spring文档，它提供了以ItemReader的形式从数据库读取数据的各种方式。在我的例子中，需要对数据库执行大量的业务验证。假设在从以下任何一个源读取数据之后，我想根据多个数据库验证它们，我可以在Spring作业实现中使用SpringJdbcTemplate吗？
1. HibernatePagingItemReader
2. HibernateCursorItemReader
3. JpaPagingItemReader
4. JdbcPagingItemReader
5. JdbcCursorItemReader
浏览 1提问于2017-12-30得票数 1
回答已采纳
1回答
我们创建了一个自定义项目阅读器，它扩展了AbstractPaginatedDataItemReader。Spring-batch允许管理停止或不停止作业的异常(跳过的异常)。
在“经典”的spring-batch阅读器中，doRead方法抛出任何Exception。这意味着，如果在读取过程中抛出跳过的异常，则跳过该项并继续运行作业。
但在分页读取器中，用于检索下一个数据页的doPageRead方法不会抛出任何异常：
protected abstract Iterator<T> doPageRead();
doRead方法调用doPageRead方法：
protected T doR
浏览 1提问于2017-11-03得票数 3
我正在使用Spring batch和spring boot。我在处理多个文件时遇到问题。
我的方案。我有多个具有不同标题的文件，例如：
Sourcefile1.txt：
name, age, salary
ajay, 22, 2000
vijay, 23, 3000
Sourcefile2.txt：
name, address
vijay, india
ajay, uk
我想使用spring boot和spring batch来处理这些文件。我该怎么做呢？
浏览 0提问于2017-05-24得票数 0
我是Spring Batch的新手。我有以下问题。
我正在使用Spring Batch开发一个批处理过程。我有一个java数组，里面有一些'process_id‘值。我想要做的是，对于每个“process_id”，我需要使用ItemReader调用数据库存储过程。有没有人能帮我写ItemReader来实现这一点？
谢谢你的帮助。
浏览 1提问于2012-06-08得票数 1
回答已采纳
我致力于通过Spring Batch将一个包含大约30-40个表的巨大DB2模式转换成一个简化的JSON格式。我的进程在一个线程上工作得很好，但是一旦我增加了线程池的大小来支持多线程，我的ItemProcessor就崩溃了，出现了令人恼火的神秘和难以理解的错误。
我只是不明白我的处理器怎么可能不是线程安全的:我没有在任何地方维护状态，我只是进行了一些额外的存储库调用来丰富数据，因为我不能让读者获取我需要的一切。一个这样的存储库调用就是抛出一个ArrayIndexOutOfBoundsException！我甚至在我的处理器中添加了一个@Transactional注释，并使用Java的多线程jav
浏览 0提问于2020-06-03得票数 0
我想在批处理应用程序中使用Spring batch。我已经有了一个遵循DDD设计的域模型。我的问题是，批处理(在我的例子中，使用Spring batch)如何适应DDD？
例如，我有一个聚合根A，它的一个子节点是实体B。A有一个包含一个或多个B的列表。当每行对应一个操作(添加、删除...)时，批处理应用程序会收到一个文件在B的列表上。在我的聚合根A中，每个操作都有一个方法(例如addB、delB...)。使用Spring batch，我应该使用哪个ItemWriter？我不认为JdbcBatchItemWriter是合适的，因为我应该只通过域处理数据。关于DDD与批处理的使用，是否有最佳实践？
浏览 2提问于2012-04-16得票数 1
回答已采纳
2回答
我需要迁移数据，我想我可以使用spring批处理。我有大约一百万的客户在一个桌子(分页)。对于每个表，我需要从两个表中获取数据。根据这两个表的结果，我需要做一些操作。最后，我需要把结果写到数据库中。
我关心的是如何从客户的循环开始读取和链接数据.
弹簧批处理的默认模式
朗读
流程
写
我需要做的是
阅读客户，并为他们每一个
- read table x
- read table y
- process (get result of both read)
- write in table z
春季批次有什么可能吗？
浏览 2提问于2020-11-20得票数 0
spring batch的新手，正在尝试为大量数据输入实现Partition。我已经检查了下面的解决方案，它们与我的问题相似，但无法解决问题。
但我还是遇到了异常：
Caused by: org.springframework.expression.spel.SpelEvaluationException: EL1008E:(pos 0): Property or field 'stepExecutionContext' cannot be found on object of type 'org.springframework.beans.factory.conf
浏览 0提问于2017-08-31得票数 0
我有一个SQL脚本，它根据员工ids从多个表中执行删除操作：
DELETE FROM EMP_ADDRESS where EMP_ID in (EMP_IDS);
DELETE FROM EMP_DETAILS where EMP_ID in (EMP_IDS);
DELETE FROM EMPLOYEE where EMP_ID in (EMP_IDS);
有没有办法通过传递员工ids来调用Spring batch中的sql脚本？我尝试了另一种方法，在写入器中获取ids并从表中删除，如下所示：
public class DeleteEmployeeData implements ItemWr
浏览 0提问于2020-12-10得票数 2
我是第一次使用弹簧引导批处理，得到这个错误不能理解的确切问题，
我的模型/实体类如下所示：
@Data
@Entity
public class ChuData {
@Column(name="excDate")
private Timestamp excDate;
@Id
@Column(name="ID")
private Long ID;
@Column(name="dataID")
.
.
.
存储库的代码如下
@Repository
public interface CommonConf
浏览 3提问于2020-07-04得票数 0
回答已采纳
6回答
乍一看，我有一个很简单的问题，但我想不出怎么解决问题。我有一个抽象类Compound。Compound是由Structures组成的。然后还有一个Container，它包含1 Compound。
Compound的“特殊”实现有Versions。对于这种类型的Compound，我希望Container保存Compound的Version，而不是Compound本身。
您可以说，“只需创建一个接口Containable”，Container就能容纳1 Containable。不过，那是行不通的。原因是我正在创建一个框架，该框架的主要部分是简化存储，特别是搜索由Structure对象保存的特殊数据
浏览 0提问于2012-11-15得票数 6
回答已采纳
我正试图使用Spring .csv将java数据对象写入FlatFifileItemWriter文件，就像下面的示例中提到的那样。
编写器配置如下所示。
<bean id="cvsFileItemWriter" class="org.springframework.batch.item.file.FlatFileItemWriter">
<!-- write to this csv file -->
<property name="resource" value="file:cvs/repor
浏览 0提问于2016-05-13得票数 1
回答已采纳
对于Spring批处理作业，我们在同一个表上有两个不同的查询。要求具有一个读取器，该读取器执行两个查询以从同一个表中读取数据。
一种方法可能是：
<batch:step id="firstStep" next="secondStep">
<batch:tasklet>
<batch:chunk reader="firstReader" writer="firstWriter" commit- interval="2">
浏览 1提问于2016-05-26得票数 3
2回答
我正在使用hibernate和spring mvc来实现应用程序中的实体持久化。我在应用程序中的实体中有多个@瞬态字段。有没有一种方法可以告诉Json解析器自动忽略实体中所有带@瞬态注释的字段，而不需要使用@JsonIgnore或@JsonIgnoreProperties
浏览 0提问于2015-02-25得票数 0
我是Spring batch的新手。我目前正在开发一个学习Spring batch的测试项目，我遇到了一个问题。我的要求是，我需要查询我的oracle数据库，从一个表中找到ids，然后传递这些ids，并从其他表中获取这些ids的详细信息。目前我大约有300个ids。我可以获得in，但我不确定如何在Sql查询in子句中一次性传递这些in，以获得存储在不同表中的其他字段。我也对解决这个问题的其他建议持开放态度。
谢谢，尼克
浏览 4提问于2018-11-28得票数 0
我有一个Spring批处理进程，它从Server读取数据并写入文件。我使用的查询返回350000行，并在Server上运行大约2分钟--因此对查询进行了调优以获得最佳性能。
下面是JobConfiguration类：
@Configuration
@Slf4j
public class JobConfiguration {
private final JobBuilderFactory jobBuilderFactory;
private final StepBuilderFactory stepBuilderFactory;
private final FilePro
浏览 10提问于2020-04-16得票数 0
回答已采纳
我对Spring批处理框架非常陌生。
我在一个作业中创建了两个步骤(让我们称之为Step1 & Step2)。我想在并行中运行它们。不仅如此，Step1 2的IteamReader也应该使用Step1 1的ItemWriter。
换句话说，步骤2的ItemReader应该等待步骤1的ItemWriter编写一个块。Step1一写，Steps2就开始阅读，并将其传递给处理器，并进一步传递给处理器。
我要问的第一个问题是，在Spring批处理中甚至可以这样做吗？如果是，怎么做？
第二，如果这不可能的话，还能做些什么呢？
谢谢。
浏览 2提问于2018-01-11得票数 0
回答已采纳
我有一个spring-batch任务，可以将各种银行对帐单转换成我的应用程序。每种银行对帐单类型都有不同的读取器，并且所有类型都只有一个写入器。这项工作非常简单--读取、处理和写入：
<batch:job id="importer" restartable="true">
<batch:step id="import">
<batch:tasklet>
<batch:chunk reader="reader" writer="writ
浏览 0提问于2012-01-22得票数 3
回答已采纳
我对Spring Batch和ODM规则引擎都是新手。目前，我有一个Spring批处理应用程序，它将数据从excel .csv文件导入到xml文件中。Spring批处理是使用Eclipse - Maven项目用Java编写的。现在，我已经能够成功地读取文件并将其写入xml，我想使用ODM规则引擎运行规则。我在eclipse中有一个规则项目，但我不确定如何在Spring批处理中调用它(反之亦然)。只要我能以某种方式导出数据，我就不一定需要将其输出到xml。
浏览 1提问于2016-08-02得票数 0
我在我的应用中使用了spring batch。基本上，我所要做的就是读取输入目录中的所有XML文件。当我得到所有的XML文件时，每个文件都需要转换成根对象。我必须将该对象拆分为两个对象，并将它们打印到CSV文件中。因此，如果输入文件夹中有10个XML文件，我需要生成20行的CSV。如果有150行，CSV将有300行，依此类推。我的意思是使用FileReadingMessageSource。它有一个队列。但这样做的问题在于队列的返回类型。它返回File，我需要的是队列列表。我能以某种方式从我的阅读器中的一个目录中获得整个XML文件列表吗？
浏览 3提问于2018-12-19得票数 2
我想了解按块读取数据的基本机制。实际上，我想手动复制该代码。我们从中读取的数据库不支持SQL查询，SQL查询可以限制读取的记录数。因此，我正在尝试是否可以以某种方式将读取限制为特定的大小(就像spring batch如何将一次读取限制为特定的块大小一样)。
谢谢!
浏览 2提问于2018-11-30得票数 0
我对EF 4.1使用"Code First“有问题。在我开始发布任何代码之前，让我先设置我的情况。我在一个名为Data.EF的类库项目中有一个名为MemberSalesContext的DBContext类，我在一个名为Data.EF的单独类库项目中有我的POCOs。我的域项目对实体框架一无所知，没有引用，什么都不知道。我的Data.EF项目有一个对域项目的引用，这样我的DB上下文类就可以连接位于Data.EF.Mapping的映射类中的所有内容。我使用EntityFramework中的EntityTypeConfiguration类执行此名称空间中的所有映射。所有这些都是非常标准的东西
浏览 1提问于2011-06-17得票数 0
我正在尝试实现一个Spring Batch自定义ItemReader，但在使用IllegalArgumentException时遇到了问题。
异常跟踪在这里；
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'reader' defined in class path resource [com/chrisbeech/batch/JobConfig.class]: Invocation of init method failed; nested exce
浏览 0提问于2016-11-09得票数 0
我读到过Apache Solr和Spring Batch。Apache Solr是一种强大的搜索技术。现在，我们希望从Apache Solr读取数据，然后Spring Batch将处理该数据并将其写入数据库。
我搜索了很多，但我不能得到关于这个集成的演示。可以将Apache Solr与Spring Batch集成吗？
浏览 0提问于2015-10-04得票数 2
我想处理3个数据文件。比方说FileA，FileB，FileC。每个文件具有不同类型的数据，并将被加载到不同的表集。我读过关于Spring Batch的文章，看过视频，做过一些教程。我正在考虑为每种类型的文件编写一系列Steps。例如，我的FileProcessingJob将FileA-Step1、FileA-Step2、FileA-Step3用于FileA，然后将FileB-Step1、FileB-Step2、FileB-Step3用于FileB，并将<代码>d13</code>、FileC-Step2、FileC-Step3用于FileC。我希望将文件名作为参数传递
浏览 11提问于2018-01-20得票数 0
我想找到一种方法来测试我作为MultiResourceItemReader委托编写的自定义MultiResourceItemReader。
这里是我的Spring配置文件：
<batch:job id="allegati" incrementer="jobParametersIncrementer">
<batch:step id="allegati-import">
<batch:tasklet>
<batch:chunk reader="alle
浏览 2提问于2015-03-31得票数 1
回答已采纳
我在spring引导、spring批处理、spring数据jpa、hibernate和Postgresql中使用Atomikos。我在XA Datasource中配置了两个带有Atomikos池的数据源。
我遇到了的两个困难，
，首先，我不能禁用Atomikos池自动提交。我到处搜索，找不到可以设置为false的类似于自动提交的属性。
第二个问题有点复杂。我的分布式事务管理器可以工作，因为我更新了两个数据库。
，但是当我用JpaPagingItemReaderBuilder从第二个数据库读取数据时，我有一个nullPointeurException，下面的是我的第二个数据源和连接到第二个数据库
浏览 9提问于2022-02-13得票数 0
我必须跳过来自reader FlatFileItemReader的自定义映射器FieldSetMapper的自定义异常(CSVFieldMappingException)，对于我的Spring批处理作业业务logic.For的ArrayIndexOutOfBoundsException，我已经添加了作业步骤的配置，如下所示。
@Bean
public Step step1(StepBuilderFactory stepBuilderFactory,
ItemReader reader, ItemWriter writer,
浏览 10提问于2016-03-15得票数 0
我正在做一个Spring项目，我试图尝试使用Lombok来避免在我的域类中定义空的样板代码，比如空构造函数和getter\setter方法。
但这似乎不像我预料的那样有效。
这是我的DTO课程：
@Getter
@Setter
@NoArgsConstructor
public class NotaryDistrict {
String idDistrict;
String denominazione;
String regione;
String provincia;
ArrayList<Localita> localita
浏览 4提问于2021-08-06得票数 0
我使用spring作为持久化。如果存在多个具有相同名称的实体，是否有一种方法可以将一个实体标记为默认值。用于解决多个bean依赖关系问题的@Primary注释
@Entity(name = "ORGANIZATION")
@Table(name = "ORGANIZATION")
public class DefaultOrganization {
***
}
@Entity(name = "ORGANIZATION")
@Table(name = "ORGANIZATION")
public class Organi
浏览 6提问于2015-06-02得票数 2
在proyect与Jhiste4.4.1，Spring，Grandle，MongoDb
@Mapper(componentModel = "spring", uses = {})
public interface OportunidadMapper extends EntityMapper <OportunidadDTO, Oportunidad> {
是OportunidadDTO广告：
private Long clienteId;
在Oportunidad
@Field("clienteId")
private Long clienteI
浏览 2提问于2017-06-01得票数 0
回答已采纳
我的情况是，我得到了一个批处理作业，它将从两个不同的表中读取数据，并以不同的方式处理。
第一个读取器将执行简单的SQL检索和简单转换，第二个读取器将执行SQL检索和处理更新以及后面的插入逻辑。两个读取器都将返回字符串行并写入文件中。
在Spring批处理中，可能在一个步骤中有两个读取器和两个处理器，然后传递给一个写入器？
浏览 3提问于2015-10-29得票数 0
回答已采纳
在spring批处理作业中，我有一个步骤，希望使用Hibernate从数据库中逐块读取数据，对其进行处理，然后将其写回数据库。现在我在设置阅读器时遇到了一些问题：
@EnableBatchProcessing
@Configuration
@ComponentScan(basePackages = {"com.x.y.z.database", "com.x.y.p.database"}, excludeFilters={
@ComponentScan.Filter(type= FilterType.ASSIGNABLE_TYPE, value=C
浏览 0提问于2019-07-15得票数 0
我有一个Spring批处理作业，它读取一个文件并将其写入两个平面文件(格式不同)。它使用具有两个委托的CompositeWriter，这两个委托是扩展FlatFileItemWriter的自定义类。每个编写器只写入某些记录。例如，对于14个输入记录，GoodFileWriter将写入12个记录，而SkipFileWriter将仅写入两个。这个很好用。但是，如果作业在中间失败，并且我重新启动它，那么好的文件就会丢失记录。看起来Spring Batch只维护其中一个文件的文件大小/记录数量。如果需要的话，我很乐意提供一些例子。
我不得不相信这只是因为我对Spring Batch不在行，所以我会非常
浏览 0提问于2014-08-05得票数 0
1回答
一对多加入同一记录两次
、、、
我想加入这张桌子：
@Entity
@Table(name = "BATCH")
public class Batch {
@Id
private int id;
@OneToMany
@JoinColumn(name="BATCH_ID")
private List<BatchDelivery> batchDeliveryList;
public List<BatchDelivery> getBatchDeliveryList() {
return batchDeli
浏览 1提问于2013-10-14得票数 0
回答已采纳
我有两个数据库配置javaconfig类-一个用于transactionManager()和entityManagerFactory() @Bean方法的JPA类，另一个用于基于非JPA JDBCTemplate的查询提交以访问该数据库的数据的配置类。总体思路是使用JDBCTemplate读取数据，并在转换后将数据持久化到基于JPA的数据源中。我正在使用Spring来启用自动配置。我的测试失败了：
java.lang.IllegalArgumentException: Not an managed type:
spring-boot-starter-jdbc和spring-boot-
浏览 3提问于2014-06-14得票数 0
回答已采纳
在我们的域中，我们有我们的服务活跃的城市列表。使用Spring batch，我想调用一个带有城市名称参数的REST web-service。
也许我正在纠结于库的用法，但我的意思是这样的：
@Bean
public Step step1(ItemWriter writer) {
return stepBuilderFactory.get("step1")
.chunk(InstalledCities.values())
.reader(reader())
.processor(processor()
浏览 0提问于2019-02-23得票数 0
免责声明:我是春天的菜鸟。我所要求的可能很“奇怪”，因为我甚至不知道我不知道什么。
我正在尝试使用Java创建一个批处理数据移动/操作工具(我可以说是ETL工具)。有人建议我查看spring-batch，我非常喜欢它，因为它有许多用于数据读写和处理的库。
但我的问题是-我的数据源(平面文件或表)没有固定。在前端，用户将选择要加载的平面文件或数据库表，程序将自动加载该文件或数据库表。这意味着，通常的事情，如：
源/目标实体结构
源或目标数据库URL/DSN
工作参数等
在我的案子里不是预先决定的。它们是在运行时确定的。但是，到目前为止，无论我看到了什么spring-batch
浏览 0提问于2014-12-15得票数 2
我一直在尝试spring batch示例，但我无法通过itemwriter删除数据库中的记录。itemreader运行正常，但在itemwriter中，我不知道如何工作，因为我是spring batch的新手，我可能会犯一些错误。我尝试了一些示例中的以下代码，但它不起作用。我是不是必须写一些其他的类或者别的什么？
<bean id="itemWriter" class="org.springframework.batch.item.database.JdbcBatchItemWriter">
<property name="da
浏览 2提问于2013-12-06得票数 1
我有一个队列，其中的消息将由其他应用程序放置，我的应用程序所做的只是轮询队列，并获取所有消息，然后转换为其他对象并持久存储在数据库中。因此，对于这个1，我有两种方法。)使用spring调度器，每5秒轮询一次所有消息，然后使用Java8的并行流在数据库中持久化，因为所有流都是独立的。2.)有人建议使用spring batch，但不幸的是，我没有得到关于使用spring batch的充分解释。
你能提出一些建议和解释来帮助我吗，比如哪一个更有用，哪个更好？
浏览 0提问于2017-10-14得票数 2
1回答
我有多个“微服务”Spring应用程序。每个包都有自己的包结构，可以独立运行，非常好。每个都可能有自己的@EntityScan，这取决于我是否可以使用基本包技巧中的自动配置。
当我尝试将它们组合到单个Spring应用程序中时，是否所有单独的@EntityScan注释都得到了尊重？我现在没有看到这种行为。它似乎只尊重一个@EntityScan，然后我得到可怕的无法自动创建自定义存储库，因为它的JPA实体不存在。
弹簧启动1.2.3-释放
浏览 1提问于2015-05-13得票数 4
我试图在的春季批处理示例之后使用多行。
我遇到了以下编译错误-
我确信，在寻找实现ItemReader的类时，有一些与泛型有关的东西，但是AggregateItemReader实现了ItemReader。
public class AggregateItemReader<T> implements ItemReader<List<T>> {
你可以在这里找到我的代码-
更新：
我抑制了泛型，并按照下面的方式更新了AggregateItemReader，以便调用ItemStreamReader open()方法。
public class Aggr
浏览 3提问于2021-08-13得票数 1
回答已采纳
我目前正在开发Spring / JPA应用程序，最近我转向了基于JPA继承的域模型。总结一下我的域模型，我有一个抽象的Member实体，它由两个实体( Male和Female )子类。
在我所有的Spring控制器中，我想避免总是注入两个服务依赖项(一个处理Male实体，另一个处理Female实体)。我希望有一个MemberService服务(连同相应的MemberRepository)返回Male实例或Female实例。
上面是否可以使用Spring注释，如这个：
@RooService(domainTypes = { Member.class })或那个：
@RooJpaRepos
浏览 3提问于2012-09-17得票数 1
回答已采纳
我需要创建一个spring batch，其中我需要从2个不同的表中获取数据。这将是阅读器部分。 问题是我需要2个阅读器查询。并且只会根据条件调用其中的一个。但是作者是一样的。所以微线程基本上是一样的。 我可以在一个步骤中有两个阅读器，这将根据条件调用。？？ 类似于spring batch xml中的内容： if (condition)
then reader1
else reader2
...
....
......
<reader1 id=".." class="..">
</reader1>
.....
........
浏览 49提问于2020-12-14得票数 0
回答已采纳
1回答
也许这是一个反复出现的问题，但我需要对我的上下文进行一些定制。
我正在使用Spring 3.0.1。
我有一份简单的工作，有一些步骤。第一步是像这样的一块：
<tasklet transaction-manager="myTransactionManager">
<batch:chunk reader="myReader" processor="myProcessor" writer="myWriter" commit-interval="${commit.interval}">
&
浏览 1提问于2015-02-25得票数 7
回答已采纳
从高层次上看，我的应用程序流如下所示
REST控制器RequestMapping由GET()请求触发。REST控制器调用Service类中的方法。
@RequestMapping(value="/eventreports", method = RequestMethod.POST, produces = "application/json")
public @ResponseBody List<EventReports> addReportIds(@RequestBody List<Integer> reportIds) {
Li
浏览 0提问于2017-04-28得票数 1
我正在使用spring batch来解析我的文件。在ItemProcessor中，我验证传入的字段是否正确。如果它们不是，我想抛出一个ValidationException并将其记录到一个文件中，该文件对应的行包含错误的字段。那么，怎样才能找到ItemProcessor中的行数和文件名呢？
浏览 0提问于2013-02-19得票数 4
我的MongoDB数据如下： {
"college": [
{
"batch": {
"subject": [
{
"name": "DBA"
}
],
"name": "BBA",
"year": "2016"
}
},
{
"batch":
浏览 44提问于2019-09-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
