spring 相关问题

嗨，我想了解 Spring Batch 的设计。给定以下作业配置： @豆公共步骤 jobStep() { 返回新的 StepBuilder("stepName", repo) . 嗨，我想了解 Spring Batch 的设计。给定以下作业配置： @Bean public Step jobStep() { return new StepBuilder("stepName", repo) .<List<Entity>, List<Entity>> chunk(10, txnManager) .reader(reader) .processor(processor) .writer(writer) .build(); } 以及以下示例处理器： public class JobProcessor implements ItemProcessor<List<Entity>, List<Entity>> { @Override public List<Entity> process(List<Entity> items) { for (Entity record: items) { //do some logic return items; } 我的观察是，读取器/处理器/写入器运行的次数与块大小相同。例如，在上面的例子中，处理器将运行 10 次，作者也将运行 10 次。如果我的阅读器只提取 2 条记录，则它小于块大小。 ItemProcessor中List的大小只有2——如果传入整个记录集，为什么还要额外运行8次？避免重复处理的唯一方法似乎是跟踪某个项目是否被处理（和写入）。这并不难，但我想了解这是正常行为还是我做错了什么。总而言之 - 如果 Spring Batch 记录集小于块大小，处理器/编写器不应该只运行一次，因为第一个块包含整个记录集？编辑：这是我删除列表的尝试，但它仍然循环块次数，即使项目的大小只有 2。 @Bean public Step jobStep() { return new StepBuilder("stepName", repo) .<Entity, Entity> chunk(10, platformTransactionManager) .reader(reader) .processor(processor) .writer(writer) .build(); } public class JobReader implements ItemReader<Entity> { @Override public Entity read() { List<Entity> items = repo.getData(); return items.isEmpty() ? items.get(0) : null; } public class JobProcessor implements ItemProcessor<Entity, Entity> { @Override public Entity process(Entity entity) throws Exception { //do stuff return entity; } 这里看起来错误的是您正在操作实体列表。正确的代码应该是这样的： public Step jobStep() { return new StepBuilder("stepName", repo) .<Entity, Entity> chunk(10, txnManager) .reader(reader) .processor(processor) .writer(writer) .build(); } public class JobProcessor implements ItemProcessor<Entity, Entity> { @Override public Entity process(Entity item) { //do some logic on one item return item; } } 与您的问题中未显示的读者和作者类类似。

java spring spring-boot spring-batch

回答 1 投票 0

设置上下文 |获取 TransactionSynconizationMananger.isCurrentTransactionReadOnly() 的值

我正在尝试将我的事务动态路由到 READ_WRITE 或 READ_ONLY 数据源。但在我的类中 TransactionRoutingDataSource 扩展了 AbstractRoutingDataSource 当我试图获得 va 时...

java spring hibernate transactions dynamic-routing

回答 1 投票 0

JpaTransactionManager 支持 REQUIRES_NEW 传播吗？

在我的 springboot 应用程序中，我有一个带有嵌套事务的方法，如下所示。 //消息处理程序 @Transactional(传播=传播.REQUIRES_NEW) @覆盖公共无效过程消息（

java spring rollback transactionmanager

回答 1 投票 0

如何告诉 Springdata 存储库的删除方法在实体不存在时不抛出异常？

我正在使用SpringData的存储库。如果我尝试通过不存在或从未存在过的 ID 删除实体，则会引发异常。因为我不想检查该实体之前是否存在...

java spring spring-data

回答 10 投票 0

Spring HTTP 接口 - 逗号分隔的参数值列表

我在Spring中有以下@HttpExchange：导入 org.springframework.web.bind.annotation.RequestParam; 导入 org.springframework.web.service.annotation.GetExchange; ... @GetExchange(&quo...

java spring spring-boot

回答 1 投票 0

Spring 4 计算注释的占位符

我有一个注释，带有一个 String 属性，我希望它在运行时计算。在我所说的具体情况下 @Scheduled(initialDelayString = "10000" ) 根据o...

java spring annotations

回答 1 投票 0

Spring JPA - 如何在将父实体及其子实体保存在同一事务中后重新加载它们

在我的服务类中，我试图更新一个实体（及其许多子实体），并希望在同一事务中使用更新的记录。表中的数据正在更新，但上下文未更新...

java spring spring-data-jpa

回答 1 投票 0

@GetMapping 和 @GetExchange 有什么区别？

从Spring 6开始，引入了@GetExchange、@PostExchange、@PutExchange、@DeleteExchange、@PatchExchange。据我所知，我们已经有了相同的注释，可以做同样的事情@GetMa...

java spring spring-boot

回答 1 投票 0

如何在 MockWebServer 中使用 @BeforeEach 和 @AfterEach 注解？

在进行集成测试时，我试图用一个或多个 MockWebServer 来模拟控制器的行为，但没有找到解决方案。我看到这里的帖子说 MockWebServer 应该......

java spring spring-boot integration-testing mockwebserver

回答 1 投票 0

Spring Cloud Gateway + Spring Cloud Security + Keycloak 如何连接

他这几天一直在尝试用 Keycloak 连接 s-c-gateway 和 s-c-security。我希望位于网关后面的模块没有 keycloak 配置。春天来了吗...

spring security cloud keycloak gateway

回答 4 投票 0

Spring boot：无法打破bean之间的依赖循环

我正在使用 Spring Boot 创建一个航空公司网站。我有一个 Seat 类和一个 Flight 类，它们代表数据库中的表。这个想法是，每当添加航班时，座位......

spring spring-boot hibernate dependency-injection lazy-initialization

回答 1 投票 0

Spring参数验证注解不验证

我有一个像这样的控制器方法：导入 javax.validation.Valid; 导入 javax.validation.constraints.Min; 导入 javax.validation.constraints.NotNull; @控制器 @RequestMapping(值 = "/fo...

java spring validation

回答 3 投票 0

spring 4 计算注释的占位符

我有一个注释，带有一个 String 属性，我希望它在运行时计算。在我所说的具体情况下 @Scheduled(initialDelayString = "10000" ) 根据o...

java spring annotations

回答 1 投票 0

原因：org.messaging.handler.annotation.support.MethodArgumentNotValidException：无法解析 public void 中索引 1 处的方法参数

我正在开发 Kafka Consumer App，在手动尝试确认和确认时出现以下错误。可能是什么原因导致了这个问题？错误详情： org.springframework.kafka.listener.

spring apache-kafka spring-kafka

回答 1 投票 0

如何访问springs中的另一个字段@Value

就像标题所示，我想使用 springs @Value 注释访问另一个字段值。我想这样做是为了通过另一个字段 id 解析字段值。例如：我有一个字段 id 和一个字段