仅处理spring重试中的自定义异常
在处理Spring重试中的自定义异常时，可以采取以下步骤：
- 确定重试策略：Spring提供了一种简单而强大的机制来处理方法调用的重试。可以使用
@Retryable注解来标记需要重试的方法，并指定重试的条件和行为。可以通过设置value属性来指定需要重试的异常类型，通过maxAttempts属性来指定最大重试次数，通过backoff属性来指定重试间隔等。 - 自定义异常类：首先，需要创建一个自定义的异常类，该类应该继承自
RuntimeException或其子类。可以根据具体的业务需求，定义不同的异常类来表示不同的错误情况。 - 异常处理器：接下来，需要创建一个异常处理器类，用于处理自定义异常。可以使用
@Component注解将该类声明为Spring的组件，以便自动扫描和注入。在异常处理器类中，可以编写逻辑来处理自定义异常，例如记录日志、发送通知等。 - 配置重试策略：在Spring的配置文件中，需要配置重试策略。可以使用
@EnableRetry注解来启用Spring的重试功能，并指定需要扫描的包路径。此外，还可以通过配置文件或注解来设置重试的相关参数，如最大重试次数、重试间隔等。 - 使用重试功能：在需要进行重试的方法上，添加
@Retryable注解，并指定需要重试的异常类型。当方法抛出指定的异常时，Spring会自动进行重试，直到达到最大重试次数或成功执行。
总结起来，处理Spring重试中的自定义异常需要定义自定义异常类、编写异常处理器、配置重试策略，并在需要重试的方法上添加相应的注解。通过这些步骤，可以实现对自定义异常的重试处理，提高系统的可靠性和稳定性。
腾讯云相关产品和产品介绍链接地址：
相关·内容
我是spring-retry的新手。基本上，为了重新尝试REST调用，我已经将spring-retry集成到了我的spring应用程序中。为此，我作了以下修改：
将spring-retry添加到pom.xml中。
增加了以下配置：
@Configuration @EnableRetry公共类RetryConfiguration {}
最后，将@Retryable注释添加到类(该类不是Spring )方法中，我希望对各种异常进行重试，如下所示：
公共类OAuth1RestClient扩展了OAuthRestClient {@重写@Retryable(maxAttemp
浏览 0提问于2021-11-23得票数 1
回答已采纳
我有一个Spring AMQP消息监听器在运行。
public class ConsumerService implements MessageListener {
@Autowired
RabbitTemplate rabbitTemplate;
@Override
public void onMessage(Message message) {
try {
testService.process(message); //This process method can throw Business Exception
浏览 1提问于2016-05-02得票数 19
回答已采纳
我目前正在使用Spring来使用来自主题的消息以及@Retry of Spring。因此，基本上，我正在重新尝试处理消费者的信息，以防出现错误。但是，在这样做时，我希望避免KafkaMessageListenerContainer抛出的异常消息。相反，我想显示一条自定义消息。我尝试在ConcurrentKafkaListenerContainerFactory中添加一个错误处理程序，但是在这样做时，不会调用我的重试。有人能指导我如何显示自定义异常消息以及@Retry场景吗？下面是我的代码片段：
ConcurrentKafkaListenerContainerFactory Bean Confi
浏览 14提问于2020-06-24得票数 0
我很难理解如何正确处理Spring Cloud流中反序列化异常。主要是因为实现的框架不支持标头，并且DLQ被认为是与原始消息不同的架构。因此，过程流需要是:消费消息->反序列化错误-> DlqHandler ->使用新模式序列化->发送到DLQ
下面链接的文档并没有给出一个好的想法，如果这是可能的。我已经看到了相当多的Spring-Kafka的SeekToCurrentErrorHandler示例，但据我所知，这些是不同的实现，与我如何正确地获取反序列化错误，然后有一个自定义代码部分，以序列化为新的格式，并从那里移动。
我的主要问题是:用spring cloud str
浏览 15提问于2021-03-11得票数 0
回答已采纳
2回答
即使在特定配置之后，Spring流也不会在反序列化错误上重试。期望是，它应该基于配置的重试策略重试，最后将失败的消息推送到DLQ。
配置如下。
spring.cloud.stream.bindings.input_topic.consumer.maxAttempts=7
spring.cloud.stream.bindings.input_topic.consumer.backOffInitialInterval=500
spring.cloud.stream.bindings.input_topic.consumer.backOffMultiplier=10.0
spring.cloud.s
浏览 1提问于2019-06-26得票数 0
回答已采纳
我是Spring批处理的新手，使用spring引导，我阅读了几乎所有可用的文章，但没有找到用于用例的确切场景/片段，如下所示。
从DB读取数据(例如:5项)
处理数据:如果API调用失败，则调用API和，跳过项并处理下一个项。(对所有5个项目按顺序排列)
所有跳过的项都应记录在db中。
在处理所有5项失败/成功方案后，然后在一段时间间隔后重试失败项。
我已经使用了RetryTemplate，但是在那里它会在异常情况下立即重新尝试这个项目，所以它不适合我。
我创建了跳过策略，它跳过了异常，给了我预期的行为，但无法开始重试尝试(3)以同样的方式。
有人能帮我举几个例子并指导
浏览 0提问于2018-10-29得票数 0
我正在尝试在春季amqp中实现恢复。我使用了下面的代码来实现相同的功能 RetryOperationsInterceptor retryInterceptorBuilder =RetryInterceptorBuilder.stateless()
.maxAttempts(5)
.recoverer(new CustomRejectAndDontRequeueRecoverer())
.build();
container.setAdviceChain(new RetryOperationsIn
浏览 23提问于2020-01-22得票数 2
回答已采纳
1回答
我需要帮助在春季云流卡夫卡绑定错误处理场景。我的应用程序有java 8使用者，其中绑定是在application.yaml中指定的。消费者被写为：
@Bean
public Consumer<Message<Transaction>> doProcess() {
return message -> {
Transaction transaction = message.getPayload();
if(true) {
throw new RuntimeException("e
浏览 3提问于2021-12-17得票数 0
回答已采纳
1回答
我有一个使用Kafka绑定的Spring项目，我正在努力理解并最终定制Cloud使用的RetryTemplate。
我并没有找到很多关于它是如何工作的文档，但是我所读到的内容将我引向以下假设：
默认情况下，云流配置并启用Spring重试，包括默认重试和退避策略。
默认情况下，@StreamListener中的任何未命名异常都将触发Spring
云流将以某种方式跟踪每条消息的RetryContext信息(如何跟踪)？(我不确定)
这些假设正确吗？
现在，在我的应用程序中，我有一种模式，可以立即处理某些消息，但其他消息必须推迟再试一次(使用指数退避等)。
我应该抛出一个异常导致
浏览 3提问于2020-06-08得票数 7
回答已采纳
1回答
我已经使用ribbon配置了2个zuul实例(不带eureka)，如下所示：
zuul.retryable=true
zuul.routes.simple-ms-app.serviceId: client
client.ribbon.listOfServers=http://localhost:7788,http://localhost:8877
当两个实例7788 & 8877都启动并运行时，一切都会正常进行。
当listOfServers中的第一个实例关闭时，请求将以以下错误结束：
com.netflix.zuul.exception.ZuulException: Forwardi
浏览 3提问于2018-12-27得票数 2
1回答
我们正在构建一个spring批处理，它在春季批处理中调用处理器部分中的第三方API。
要求是当第三方API不可用时，春批需要重新尝试指定的阈值限制并中止批处理。
我尝试过用容错步骤重试spring批处理，它在一个线程程序中工作得很好，但是当我们包括aysncprocessor和aysncitemwriter时，它并没有停止批处理。
请给我一些重试限制/自定义代码的例子，说明在出现任何异常情况下如何使用aysncprocessor /异步编写器退出。
Update 1-：我尝试了块大小为100的，有5个具有重试限制的aysnc线程，我发现很少的记录只处理两次，很少有记录被处理了三次，最后Exh
浏览 4提问于2020-06-29得票数 1
回答已采纳
我正在尝试在spring-boot中实现一个Kafka重试消费者，并使用SeekToCurrentErrorHandler进行重试。 我已将退避策略设置为有5次重试尝试。 我的问题是，假设重试的第一次尝试，异常是‘数据库不可用’，第二次尝试db是可用的，但在另一个步骤中存在另一个失败，如超时，在这种情况下，重试计数将回到零并开始新的尝试，或者将继续仅尝试第一次重试后的剩余尝试。 我的要求是每次异常与之前抛出的异常不同时，将重试计数重置为零。 如何在Kafka中实现这一点？ 这是我的消费者配置。 @Bean
public ConcurrentKafkaListenerContainer
浏览 115提问于2020-11-06得票数 0
我的服务侦听RabbitMQ队列。我在消费者端配置重试策略。当我抛出异常时，所有死信都会被请求。但是，依赖于我的业务逻辑，在抛出StopRequeueException (除SmsException之外的所有异常)之后，我希望停止对此消息的重试。但这条信息还是需要的。这是我的配置
spring:
rabbitmq:
listener:
simple:
retry:
enabled: true
initial-interval: 3s
max-attempts: 10
max-
浏览 5提问于2021-05-05得票数 0
回答已采纳
1回答
我们计划使用spring重试功能，并希望在布尔标志上重试，而不是在异常上重试。当我们使用SimpleRetryPolicy时，重试似乎只在异常时发生。我们可以调整它或使用不同的重试策略，在其中我们可以检查布尔标志吗？
谢谢
浏览 0提问于2015-08-11得票数 2
1回答
春云流卡夫卡粘结剂重试
、、、
我有春季云流应用与卡夫卡绑定，消费和发送信息。在应用程序中，我使用重试策略配置自定义错误处理程序，并向处理程序中添加不可还原的异常。配置示例：
@Bean
public ListenerContainerCustomizer<AbstractMessageListenerContainer<?, ?>> customizer(
SeekToCurrentErrorHandler customErrorHandler
) {
return (((container, destinationName, group) -> {
conta
浏览 6提问于2022-05-25得票数 0
回答已采纳
我一直在尝试为Spring cloud stream kafka实现重试逻辑，以便在向主题sample-topic生成事件时抛出异常，它会再重试两次。
我在application.properties文件中添加了以下配置
spring.cloud.stream.bindings.processSampleEvent.destination=sample-topic
spring.cloud.stream.bindings.processSampleEvent.content-type=application/json
spring.cloud.stream.bindings.processSa
浏览 25提问于2021-07-06得票数 1
我需要识别数据库连接失败异常与其他异常，并在我的kafka侦听器错误处理程序中进行相应的处理。由于Spring Data JPA中的所有内容都被转换为DataAcccessException，我只是想知道当应用程序运行时发生连接故障时会抛出什么异常。工作环境: Spring boot 2.x、Spring data jpa、spring-kafka、Java 8
浏览 2提问于2019-02-20得票数 1
1回答
我正在尝试设置重试策略，如下所示：
<spring:beans>
<spring:bean id="threadingPolicyTemplate"
class="org.mule.retry.async.AsynchronousRetryTemplate">
<spring:constructor-arg index="0">
<spring:bean id="foreverRetryPolicyTe
浏览 0提问于2011-11-08得票数 1
回答已采纳
1回答
在Spring应用程序中，我使用spring流为PubSub (spring gcp-pubsub binder)订阅一个主题。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupI
浏览 3提问于2020-07-03得票数 1
如果使用RestTemplate调用其他服务时出现问题，我已经使用spring @Retryable实现了重试函数调用。
下面给出了函数，问题是我已经将maxAttempts设置为4，如果发生任何异常，它应该尝试4次。但是，即使没有任何异常，该函数也执行了4次，并且在数据库中创建了4个employee条目。
调用另一个服务的createEmployee函数，用于在数据库中创建员工
@Retryable(value = { Exception.class }, maxAttempts = 4, backoff = @Backoff(delay = 1000))
public Response c
浏览 0提问于2019-07-05得票数 0
我正在将一个使用Spring AMQP的项目迁移到一个使用Spring Cloud Stream和RabbitMQ的项目。 在我的旧项目中，当使用@RabbitListener处理消息时发生异常时，就会抛出该异常。如果绑定了死信队列，则仍会抛出异常(如果有重试，则仅抛出一次，我猜是最后一次)。这对于日志记录非常有帮助。 在Spring Cloud中，如果您定义以下属性，则@StreamListener有一个死信队列机制： spring.cloud.stream.bindings.input1.destination=dest1
spring.cloud.stream.rabbit.bindi
浏览 27提问于2019-01-19得票数 0
回答已采纳
1回答
我在一个项目中使用Spring和JPA。我在做一些JPA操作时有一个疑问，比如repository.save(object)。
如果程序由于DB断续而未能连接DB，则，
程序如何在异常的情况下重新尝试一些spring引导功能？
在类中最相关的异常类是什么？
任何帮助都是非常感谢的！
浏览 0提问于2019-11-06得票数 0
众所周知，spring batch从2.0版本开始就使用面向块的处理。
这是否意味着，如果项编写器中发生异常，数据源事务管理器将回滚整个块，还是只回滚相关的项？
实际上，我尝试了一下，看到框架回滚了整个数据块。这不是我需要的，因为我不希望，比方说，当最后一个项导致抛出异常时，499个已经成功处理的项在由500个项组成的块中回滚。
我能找到的唯一解决方案是将下面的属性添加到我的微线程中。然而，我不确定这是否是正确的做法。
<batch:transaction-attributes propagation="NOT_SUPPORTED"/>
另一种意见是简单地将块大小
浏览 1提问于2011-03-09得票数 0
我正在开发一个非常简单的Spring Boot应用程序，它将处理来自单个主题的消息，然后将该批消息持久化到Cassandra数据库中。我尝试将Spring Kafka与一批消息一起使用，每次当我的onMessage()方法抛出MyKafkaRetryException时，就会开始一个无限的重新处理循环，但我希望在重试结束后，这批消息会被移到DLT。(如果我抛出任何其他异常，则会立即将消息移动到DLT。)我刚刚用我自己的异常分类配置了一个RecoveringBatchErrorHandler。所以我不知道这里出了什么问题。 @Bean
public RecoveringBatc
浏览 111提问于2021-08-25得票数 1
我的工作是从csv文件(包含最多65,000行)中读取数据，处理数据并写入数据库。以下是我的配置--
@Bean
public Job csvFileLoadJob() throws Exception {
return jobBuilderFactory.get("csvFileLoadJob")
.preventRestart()
.start(csvFileLoadStep())
.build();
}
@Bean
pu
浏览 1提问于2020-10-08得票数 0
回答已采纳
我只想在Spring重试中重试自定义异常。但是retryTemplate会重试所有异常。我的代码： try {
getRetryTemplate().execute((RetryCallback<Void, IOException>) context -> {
throw new RuntimeException("ddd"); // don't need to retry
});
} catch (IOException e) {
浏览 27提问于2019-12-17得票数 1
回答已采纳
2回答
我有以下配置的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<String> myReader,
ItemProcessor<String, String> myProcessor,
浏览 0提问于2019-05-16得票数 3
回答已采纳
4回答
在使用Spring (特别是Spring推荐的方法:声明性事务)时，在死锁或锁定超时异常时实现事务重启的最佳实践是什么？
谢谢,
Asaf
浏览 1提问于2009-11-19得票数 25
1回答
我使用spring-integration-kafka实现了使用自定义确认机制的Kafka使用者。
使用了来自的代码。
我试图实现的是，当抛出异常时，不应该将确认发送回Kafka (即不执行偏移提交)，因此下一个fromKafka.receive(10000)方法调用将返回与前一个方法相同的消息。
但我面临一个问题:即使确认没有发送给Kafka，消费者也不知何故知道下一条消息的偏移量，并继续阅读新消息，尽管偏移主题中的偏移值保持不变。
在发生故障时，如何使消费者重读信息？
浏览 3提问于2015-10-21得票数 5
我在写入器上使用了一个spring batch重试。作者看起来像这样：
public class MyWriter implements ItemWriter<MyClass> {
@Retryable(maxAttempts=3, backoff=@Backoff(delay=2000))
public void write(List<? extends MyClass> list) throws Exception {
// db operation 1 -- insert query
// some business logic
浏览 27提问于2017-08-31得票数 1
回答已采纳
1回答
我在使用新的0.3.0测试版WebJobs开发工具包的WebJob中有以下逻辑。当我的代码无法处理消息时，Azure仪表板会显示一个聚合异常(这是有意义的，因为这是异步的)。但是，它不会重试处理消息。
我所能找到的很少的表明，消息应该在失败后10分钟内重试。新的SDK不是这样的吗？
public static Task ProcessMyMessageAsync(
[QueueTrigger(Config.MY_QUEUE)] string msg,
int dequeueCount,
CancellationToken cancellationToken)
{
浏览 2提问于2014-06-27得票数 6
2回答
我有以下配置
spring.rabbitmq.listener.prefetch=1
spring.rabbitmq.listener.concurrency=1
spring.rabbitmq.listener.retry.enabled=true
spring.rabbitmq.listener.retry.max-attempts=3
spring.rabbitmq.listener.retry.max-interval=1000
spring.rabbitmq.listener.default-requeue-rejected=false //I have also changed i
浏览 3提问于2016-10-04得票数 4
回答已采纳
我正在使用spring 2.1.7.RELEASE和Spring 2.2.8.RELEASE.And，我使用@KafkaListener注释来创建一个使用者，我使用的是我在下面使用的consumer.And的所有默认设置，如Spring文档中所指定的那样。
// other props
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ErrorHandlingDeserializer2.class);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
浏览 2提问于2020-03-05得票数 1
回答已采纳
2回答
我正在开发一个spring引导应用程序，它对多个外部服务进行http调用，聚合并返回对前端的响应。
下面是我的项目的当前结构：
RouteController -> Handler -> ServiceLayer
RouteController路由到不同的handlersHandler，对多个服务进行调用，对每个服务调用执行聚合并返回response.Different ServiceLayers。 handler可以返回部分响应，如果一个服务调用失败，它将返回其他调用的响应。i没有添加类/控制器级别的异常处理程序，因为也可以返回部分响应。
Note -除非所有服务调用都失败，否则
浏览 6提问于2020-05-13得票数 2
回答已采纳
我有一个简单的Spring应用程序，其中我为RabbitMQ设置了以下设置(spring starter版本为2.7.0)：
spring:
rabbitmq:
host: localhost
port: 5672
virtual-host: my_host
username: admin
password: password
template:
retry:
enabled: true
initial-interval: 3s
max-interval: 10s
m
浏览 23提问于2022-07-05得票数 0
回答已采纳
我的容器工厂有一个SeekToCurrentErrorHandler，它使用DeadLetterPublishingRecoverer将某些“NotRetryableException”类型的异常发布到DLT，并不断为其他类型的异常寻找相同的偏移量。使用此设置，在产生不可重试异常的一定数量的有效负载之后，存储重试上下文的映射- MapRetryContextCache (Spring)溢出抛出一个RetryCacheCapacityExceededException。从最初的外观来看，要由DLT恢复程序处理的消息的重试上下文不会从MapRetryContextCache中删除。这或我的配置不正
浏览 0提问于2019-07-02得票数 1
回答已采纳
我使用AnnotationConfigApplicationContext创建了一个基于spring框架的应用程序。
一个bean有一个init方法，它创建到外部服务的连接。这可以用@PostConstruct注释，以便在启动bean后自动运行，这是可行的。
若要在创建此连接时处理任何异常，我希望init方法在捕获异常时重试5次。当使用@PostConstruct和@Retryable对方法进行注释时，我看到异常被抛出一次，并且程序退出--它看起来@Retryable没有任何效果。
我在配置类中正确地使用了@EnableRetry和@Configuration。我已经在同一个bean上创建了另
浏览 6提问于2016-07-03得票数 3
回答已采纳
1回答
我正在使用编写一个Java应用程序。下面是我使用的functional片段：
@Bean
public Function<KStream<String, String>, KStream<String, String>> process() {
return input ->
input.transform(
() ->
new Transformer<String, String, KeyValue<String, String>>() {
浏览 0提问于2020-08-27得票数 1
回答已采纳
我将在Spring Boot MVC应用程序中使用@Retry，同时通过@Version使用乐观锁定将数据存储到DB。
当OptimisticLockException异常发生时，我会重试多次。并在100次之后跌倒(对于我的逻辑来说，它是检查发生了什么错误的触发器)
那么它是上述断路器模式吗？在Spring initializr中创建项目时，我应该使用Hystrix依赖项吗？或者我可以只在gradle/maven中添加spring-retry依赖项并使用@Retry？我糊涂了，请帮帮忙
浏览 16提问于2020-02-06得票数 0
1回答
对于我的卡夫卡批次消费者，有两种情况我想要处理。
侦听器接收记录之前发生的反序列化异常。重新尝试这些没有多大意义，只需直接发送到DLQ。
侦听器中发生的异常。由于我正在对批处理应用一些流操作(过滤和分组等)，因此很难确切地知道批处理中哪些记录失败。因此，对我来说，只要重试整个批，并且如果达到重试极限，将整个批处理发送到DLQ，这是更简单和可以接受的。
编辑后反馈
我已经成功地使用了ListenerContainerCustomizer来解决场景2。
现在，我仍然需要处理场景1(反序列化异常)。我尝试过使用failedDeserializationFunction，如这
浏览 1提问于2021-06-29得票数 0
我使用JSR-352实现了一个批处理(在通配符上使用jberet )。
我有一个项计数15的块，java.lang.Exception被配置为可还原和可跳的异常。
当有许多异常时，大多数项将被多次处理。在这种极端情况下，所有项目都会在作者中抛出异常：
前15项阅读
异常发生在第一项上。
块被回滚并配置为item-count =1。
第一项读
异常再次发生，则跳过项。
继续处理其他14项，每一项都可能出现异常，每一项都被跳过。
在前15项之后，块返回项-count= 15。
项目16-30改为
异常再次发生
读取器回滚到最新的检查点。
此时仍然没有
浏览 4提问于2018-11-16得票数 5
回答已采纳
几周前，我的项目被更新为使用Kafka 3.2.1，而不是使用Spring 2.7.3 (3.1.1)附带的项目。我们进行这一升级是为了避免Kafka流中的一个问题--非法状态和参数异常不会在未被处理的异常处理程序中结束。在消费者方面，我们也转移到合作粘性分配。
同时，我们启动了一些弹性测试，并且开始出现使用Kafka批处理侦听器时不再在某些分区上使用的Kafka记录的问题。这个问题发生在测试引起的几次重新平衡之后(部署在Kubernetes中，我们停止了一些荚、微服务和代理实例)。这个问题不是每个听众都能听到的。卡夫卡的经纪人和微型服务已经开始运作。
在我们的调查中，
我们启用了assign
浏览 8提问于2022-09-01得票数 1
回答已采纳
我有一些代码如下所示：
@Transactional(noRollbackFor = { CannotAcquireLockException.class, LockAcquisitionException.class })
public void deleteSomeData() {
int backOffTime = 0;
int fibonacci = 1;
boolean executed = false;
do {
try {
this.myDAO.deleteTheData();
ex
浏览 1提问于2015-05-21得票数 2
回答已采纳
1回答
在春季集成中，我有一些要解决的问题，我是春季集成方面的新手。
场景是处理三个dbf文件并提取数据并将其作为JSON发送到HTTP服务，如果在3分钟内没有来自该服务的响应，则应该等待10分钟并再次尝试。其余的服务将用json回复。
现在我有三到四件事我无法解决：
我需要从rest服务读取回复，并依赖于该回复，决定重试或完成该过程。(此外，如果我发送消息到rest，没有响应也应该重试)
例如，我需要从动态文件夹名获得多个文件({ THREE }/20140101/这里将找到三个DBF文件)。是否有可能使文件夹名为模式或日期与特定的格式？并且文件适配器可以按文件处理多个文件或文件。
可以
浏览 0提问于2014-12-09得票数 1
回答已采纳
我正在使用mybatis-spring-boot-starter (2.0.1)，我遇到了一个问题，有时我在写入mysql时会遇到死锁：
com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Deadlock found when trying to get lock; try restarting transaction
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:123)
at com.mysql.cj.jdbc.
浏览 5提问于2020-07-10得票数 0
我正在使用ActiveMQ 5.15.14，并在代理上使用自定义的重传策略，在尝试向客户端重新传递一次之后，将坏消息传递给DLQ。
当使用基于Spring的客户端时，当从Java代码中抛出异常时，此方法将正确工作。但是，如果Java客户端崩溃或突然终止，则代理中的重传计数会增加，但无论重发尝试的次数如何，消息都不会发送到DLQ。
是否有一种方法可以让代理根据客户端断开连接将消息移动到DLQ，而不是报告实际异常？
浏览 3提问于2021-01-15得票数 0
回答已采纳
默认情况下，sidekiq将重试任何抛出异常的作业。这很好。但是，我希望能够捕获该异常，以便我的异常处理程序不会收到通知，然后重试该作业。如何在react中完成此操作？
所以我的代码看起来像这样：
def perform
...
rescue ExcClass => ex
# log
end
但我真的想重试这项工作。
浏览 0提问于2015-06-30得票数 5
1回答
当web服务失败时，我尝试重试。
我使用了spring retry，但是使用spring retry我不能指定基于状态码的retry
这是我的代码
@retryable(value=Exception.class,maxAttampts=2)
Public void retry() throws exception {
System.out.println("retry started")
throw new exception}
我在我的webservice类中调用了retry()方法。
浏览 15提问于2019-07-17得票数 0
1回答
我正试图找到围绕外部服务调用包装spring-retry @Retryable注释的最佳方法。这是我的代码：
@Retryable(exclude = HttpClientErrorException.BadRequest.class, value = RestClientException.class)
private ResponseEntity<Item> retrieveItemById(String id)
{
HttpHeaders headers = new HttpHeaders();
try {
return restTempla
浏览 4提问于2022-07-05得票数 0
回答已采纳
我正在使用spring 2.2.8，并试图创建一个批量消费者。这里我有个问题。
假设我根据我的用户设置在每次投票中接收到大约100条记录，而在这100条记录中，如果只有一条记录因为一些下游系统错误而失败(可能是一个短暂的错误，比如DB停机了几秒钟并返回等等)，那么我是否可以为所有100条记录提交偏移量，然后将失败的记录发送到另一个主题或其他持久性存储，以便稍后处理它？
浏览 17提问于2020-09-09得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
