RabbitMQ在手动消费的模式下设置失败重新投递策略

server/2024/12/2 13:23:42/

最近在写RabbitMQ的消费者,因为业务需求,希望失败后重试一定次数,超过之后就不处理了,或者放入死信队列。我这里就达到重试次数后就不处理了。本来以为很简单的,问了kimi,按它的方法配置之后,发现报错之后一直重复消费,进入了死循环。

下面是kimi给的“最佳实践”的示例代码:

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar;
import org.springframework.amqp.rabbit.listener.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQConfig {@Beanpublic SimpleRabbitListenerContainerFactory myFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();factory.setConnectionFactory(connectionFactory);factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);return factory;}
}import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class RabbitMQConsumer {@RabbitListener(queues = "your-queue-name", containerFactory = "myFactory")public void receiveMessage(final Message message, com.rabbitmq.client.Channel channel) {// 消息处理逻辑try {String payload = new String(message.getBody());System.out.println("Received message: " + payload);// 业务逻辑处理// ...// 手动确认消息channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);} catch (Exception e) {System.out.println("Error processing message: " + e.getMessage());try {// 拒绝消息并重新入队channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);} catch (Exception ex) {// 如果消息拒绝失败,则关闭通道channel.close();}}}
}

问题出在哪里呢?

看起来是很完美的,但是......,还是有漏洞:

这样写是有问题的,会导致失败后消息重新入队,应该是因为重新计算重试次数,如果一直失败,就一直重试,一直清空,那永远不能达到最大次数,导致死循环......

所以,这个地方正确的处理方式是抛异常,

直接throw 一个异常即可。这样就能正确重试了。

这个过程参考了这个博文:rabbitmq消费(失败)重试3次(多次) - 幂次方 - 博客园

总结教训:AI不是万能的,如果按AI的方案得不到结果,有可能是它出错了,毕竟它的方案是没有经过实践检验的。这个时候就会发现原始资料的重要性了。博客还是有它存在的价值的。


http://www.ppmy.cn/server/146727.html

相关文章

C++20: 像Python一样逐行读取文本文件并支持切片操作

概要 逐行读取文本文件,并提取其中连续的几行,这对于 Python 来说是小菜一碟。 C 则很笨拙, 语言不自带这些。 这次我来拯救 C boys & girls, 在 C20 环境下,山寨一个 Python 下的逐行读文本文件、支持 slice 操作…

【C++】 list接口以及模拟实现

list介绍 list文档介绍 C中的list是一个双向链表容器。它允许在任意位置进行快速插入和删除操作,并且能够在常量时间内访问任意元素,并且该容器可以前后双向迭代。 1. list是可以在常数范围内在任意位置进行插入和删除的序列式容器,并且该容…

arcgis for js FeatureLayer和GeoJSON一个矢量点同时渲染图形和文本

效果 FeatureLayer和GeoJSONLayer, 一个矢量点同时渲染图形和文本 代码 相关参数自行查阅文档, 这里就不做注释了 示例代码手动创建FeatureLayer方式, 如果是通过远程url加载图层的 渲染方式同理, GeoJSONLayer同理 <!DOCTYPE html> <html lang"zn"><…

[极客时间]AIGC产品经理训练营毕业总结

为期10周的训练营也进入尾声了,回想当初&#xff0c;真的是蛮感慨的。 我为什么会去参加AIGC产品训练营呢? 其实也是蛮奇妙的. 我是一名传统业务的前端研发, 因为一个项目第一次真实的接触到了AIGC,就感觉像是打开了新世界的大门,让我倍感兴奋,想要在ai的世界里探索一番. 不过…

数学建模选MATLAB还是Python?

在进行数学建模时&#xff0c;选择合适的编程语言和工具对于建模的效率和效果至关重要。目前&#xff0c;MATLAB和Python是两个常用的数学建模工具&#xff0c;它们各自有优缺点&#xff0c;适用于不同的场景。本文将从多个维度对MATLAB和Python进行比较&#xff0c;帮助大家做…

git的使用(简洁版)

什么是 Git&#xff1f; Git 是一个分布式版本控制系统 (DVCS)&#xff0c;用于跟踪文件的更改并协调多人之间的工作。它由 Linus Torvalds 在 2005 年创建&#xff0c;最初是为了管理 Linux 内核的开发。Git 的主要目标是提供高效、易用的版本控制工具&#xff0c;使得开发者…

用c语言完成俄罗斯方块小游戏

用c语言完成俄罗斯方块小游戏 这估计是你在编程学习过程中的第一个小游戏开发&#xff0c;怎么说呢&#xff0c;在这里只针对刚学程序设计的学生&#xff0c;就是说刚接触C语言没多久&#xff0c;有一点功底的学生看看&#xff0c;简陋的代码&#xff0c;简陋的实现&#xff0…

Milvus的索引类型

Milvus 是一个开源的向量数据库&#xff0c;专为高效存储、检索和管理大规模向量数据而设计。Milvus 提供了多种索引类型&#xff0c;用于加速向量搜索的性能&#xff0c;不同的索引类型适用于不同的数据特性、查询需求和硬件资源。下面是 Milvus 支持的主要索引类型的详细介绍…