跳过情况下禁用春批单项处理
我有一个处理(1000个)块中的项目的作业。这些项被编组到单个JSON有效负载中，并作为批处理发送到远程服务(在一个HTTP POST中全部为1000个)。有时，远程服务陷入停顿，连接超时。我为此设置了跳过 return steps.get("sendData") . chunk(1000)
..
spring-retry相关内容
如何为Spring数据源创建自定义重试逻辑？
我正在连接到Azure SQL数据库，我的下一个任务是在连接失败时创建自定义重试逻辑。我希望重试逻辑既可以在启动时运行(如果需要)，也可以在应用程序运行时出现连接故障时运行。我做了一个测试，我从我的应用程序中删除了IP限制，然后导致我的应用程序中出现了异常(作为例外)。我想处理抛出异常的时间，这样我就可以触发一个作业，验证应用程序和服务器是否配置正确。我正在寻找一种可以处理这些异常并重试数据库事务
..
当我们使用RetryTemplate时，Spring重试不起作用吗？
我通过引用from the following course开发了一个重试机制。下面是我在Spring Batch中开发的代码，在这个代码中@Recover方法没有被调用。我在这里做错了什么？ @EnableRetry @Configuration public class RetryConfig { @Value("${retry.interval.in.seconds}")
..
使用事务的 Spring 重试
Spring Retry 是否保证与 Spring 的 @Transactional 注释一起使用? 具体来说，我正在尝试使用 @Retryable 进行乐观锁定.似乎它取决于创建的 AOP 代理的顺序.例如，如果调用如下所示: 调用代码 -> 重试代理 -> 事务代理 -> 实际数据库代码 那么它会正常工作，但如果代理的结构如下: 调用代码 -> 事务代理 -> 重试代理
..
未使用 Spring AMQP StatefulRetryOperationsInterceptor
我正在尝试将 spring amqp 配置为仅重试消息定义的次数.当前一条消息失败，例如因为 DataIntegrityViolationException 被无限期重新交付. 根据文档 这里我想出了以下配置 @Bean公共 StatefulRetryOperationsInterceptor statefulRetryOperationsInterceptor() {返回 RetryIn
..
如何将 Spring Boot 中的配置属性注入 Spring Retry 注释?
在 spring boot 应用程序中，我在 yaml 文件中定义了一些配置属性，如下所示. my.app.maxAttempts = 10my.app.backOffDelay = 500L 和一个示例 bean @ConfigurationProperties(prefix = "my.app")公共类配置属性{私人 int maxAttempts;私人长 backOffDelay;公共
..
当目标系统关闭时停止 Spring Cloud Stream @StreamListener 的监听
我有一个应用程序，它从 Kafka 获取消息并调用目标系统来更新旧的 Oracle 数据库. 我想启用一个场景，如果目标系统停机，将消息留在 Kafka 总线上，并且在给定的时间段内不处理它们.我正在考虑一些基于断路器 Hystrix 的解决方案，但我找不到任何机制来告诉 Spring Cloud Stream“停止"事件侦听.我能想到的唯一另一种选择是，如果断路器打开，将这些消息传输到错误
..
spring重试找到最后一次重试
我正在使用 Spring-retry-1.2.0，重试工作正常，但在我的方法中，我想知道重试是否是最后一次重试，是否有任何方法可以在 spring-retry 中获取 retrialCount 或最后一次重试? 重试.java public class Offers extends SimpleRetryPolicy {@异步@Retryable(maxAttemptsExpression
..
对于同样是@Scheduled 的@Retryable 方法，未发现@Recover 带注释的方法
我研究了这个问题的答案 @Recover 方法是没有被@Retryable 触发 但我不明白为什么我的情况下无法运行恢复方法. @Service public MyRetryingService {@Scheduled(fixedRate = 10 * 1000)@Retryable(backoff = @Backoff(delay = 100, maxDelay = 101), maxA
..
@Recover 方法没有被 Spring AOP 建议拦截
在使用 Spring/Java 和面向方面的编程编写代码时，我遇到了一个问题.在服务类中，我有使用@Retryable 的重试方法和使用@Recover 的恢复方法. 这 2 个方法中的每一个都附加到 Aspects.Retryable 方法 - “triggerJob"TestProcessService 内部附加到 TestAspect 类中的这些方法 - beforeTestTrigg
..
如何只为 Http 状态码 500 配置 RetryTemplate?
我正在使用 spring-retry(使用 java 8 lambda)来重试失败的 REST 调用.我只想重试那些返回 500 错误的调用.但是我无法为此配置 retrytemplate bean.目前 bean 很简单，如下所示: @Bean("restRetryTemplate")公共 RetryTemplate retryTemplate() {映射, Boolean>retryable
..
Spring @Retryable - 如何在调用时记录?
我使用 compile 'org.springframework.retry:spring-retry:1.2.2.RELEASE' 和 Spring Boot 1.5.9.RELEASE. 配置为重试我的方法，效果很好: @Retryable(value = { IOException.class }, maxAttempts = 5, backoff = @Backoff(delay
..
Spring @Retryable与有状态的Hibernate对象
我正在尝试使Springs @Retryable在失败时重试服务方法. @Retryable(backoff = @Backoff(delay = 1000)，maxAttempts = 3)@Transactional(rollbackFor = Throwable.class)public Something saveSomething(Something something){//一些逻
..
兔子MQ& Spring Amqp重试而不阻塞消费者
我正在使用RabbitMQ和Spring amqp，在这里我不希望丢失消息.通过使用指数退避策略进行重试，我潜在地阻止了我的消费者，他们可能正在处理他们可以处理的消息.我想为失败的消息提供几天的时间，以尝试采用指数回退策略，但是我不想让消费者阻止几天，并且希望它继续处理其他消息. 我知道我们可以使用ActiveMQ实现这种功能(在将来的某个时刻重试消息(ActiveMQ))，但是找不到Rab
..
Spring的Retryable或RetryTemplate可以使用Retry-After标头进行动态补偿吗?
我可以使Spring的@Retryable或@RetryTemplate使用HTTP 503“服务不可用"响应中的Retry-After标头中接收的数字作为下一次重试迭代的延迟吗? 例如: @Retryable(maxAttempts = 42, backoff = @Backoff(delay = 1000), value = NotYet
..
重试不适用于Java Config的Spring Batch
我的Spring批处理作业具有以下配置: @Bean public Job myJob(Step step1, Step step2, Step step3) { return jobs.get("myJob").start(step1).next(step2).next(step3).build(); } @Bean public Step step1(ItemReader
..
从application.properties文件中读取spring @Retryable的maxAttempts
@Retryable(value = Exception.class, maxAttempts = 3) public Boolean sendMessageService(Request request){ ... } 注释中的 maxAttempts参数是硬编码的.我可以从application.properties文件中读取该值吗? 类似 @Retryable(val
..
当目标系统关闭时，阻止Spring Cloud Stream @StreamListener监听
我有一个应用程序，可以从Kafka获取消息并调用目标系统来更新旧版Oracle DB. 我想启用一种方案，如果目标系统关闭，则将消息保留在Kafka总线上，并且在给定的时间内不对其进行处理.我当时在想一些基于断路器Hystrix的解决方案，但是我找不到任何机制可以告诉Spring Cloud Stream“停止"事件监听.我能想到的唯一其他选择是，如果断路器是断开的，则将这些消息传送到错误/
..
在Spring bean的基类中定义的方法中使用@Retryable不会重试
我有一个类型B的spring托管bean.我在@Configuration类中有@EnableREtry.当我在doStuff()上使用@Retryable时，该方法将按预期在失败时重试. 但是，我真正想重试的方法是在基类A中定义的方法.A是一个具体的类，而不是spring托管的bean. doSomethingElse方法不会在引发异常时重试. 我真的想重试doSomethingEl
..
在Kafka用户中重试用尽时如何设置确认
我有一个重试5次的Kafka使用者，并且我将Spring Kafka与重试模板一起使用.现在，如果所有重试都失败了，那么在这种情况下如何确认工作.另外，如果我将确认模式设置为手动，那么如何确认这些消息 消费者 @Bean("kafkaListenerContainerFactory") public ConcurrentKafkaListenerContainerFactory
..