rabbitMQ处理消息队列时的自动应答机制浅述

                                                                                                                         原创者:文思

网络资料(基本方向):

1:当出现异常时,我们需要把这个消息回滚到消息队列要么抛弃此消息:

2:经过开发中的实际测试,当让消息回滚到消息队列时,这条消息不会回到队列尾部,而是仍是在队列头部,这时消费者会立马又接收到这条消息,进行处理,接着抛出异常,进行回滚,如此反复进行。这种情况会导致消息队列处理出现阻塞,消息堆积,导致正常消息也无法运行。对于消息回滚到消息队列,我们希望比较理想的方式时出现异常的消息到达消息队列尾部,这样既保证消息不会丢失,又保证了正常业务的进行,因此我们采取的解决方案是,将消息进行应答,这时消息队列会删除该消息,同时我们再次发送该消息到消息队列,这时就实现了错误消息进行消息队列尾部的方案。

实际应用:

在做jodconvert结合mq进行文档异步转换时,因在process函数中没有捕获convert方法(文档转换时的方法)中抛出的异常,导致mq的消费方(process函数)接收消息消费时失败->返回队列第一位->执行->消费失败->返回队列第一位,如此反复导致后续mq消息被阻塞无法接收执行,用catch()捕获异常后,线应答成功,不会再次进入队列执行,解决。

以此总结出mq自动应答的1个知识点:

Spring 与RabbitMq集成对消息的处理方式是默认自动应答(百度),但是mq消息消费与否的标志,网络上百度出来的资料有些是错误的,现在通过程序来进行验证和判断,结论是:以process函数是否抛出异常或者异常是否被catch捕获为标准,以下是程序推论:

process是消息放处理接收mq消息函数

在使用mq消息进行业务处理的过程中,也就是使用消息进行业务处理的时候(convertUrl = queueBusinessHandlerService.ms2pdfByQueueExternalUtil(inputUrl)),什么情况下系统会认为消息消费不会失败,已经应答了呢,现在验证异常依次上抛,在最外层捕获(异常一定要依次通过throw抛出,否则程序就因为发生异常而中断):

1

1.1

1.1.

1.1.1

1.1.1.1

从1.1.1.1依次上抛到1

然后在最外层捕获:

通过命令行看日志可以看到,不会再执行那条mq记录了,也就说明:

当convertUrl = queueBusinessHandlerService.ms2pdfByQueueExternalUtil(inputUrl)抛出异常时被catch捕获,则process方法会认为消息消费成功,因为异常被捕获了嘛,process程序体没有中断,执行完了,所以认为消费成功,进行了自动应答,即使业务函数处理失败了,也不在会出现队列中了。

如果需要对失败的记录进行处理,建议在catch{}中:

//手动进行应答channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);

//重新发送消息到队列尾部channel.basicPublish(message.getMessageProperties().getReceivedExchange(),message.getMessageProperties().getReceivedRoutingKey(), MessageProperties.PERSISTENT_TEXT_PLAIN,JSON.toJSONBytes(new Object()));

不需要再次处理的就不用管了。


什么情况下算消费失败,没有应答成功呢,如果不在process中捕获异常,或者在try{}catch(){}以外的地方发生异常,如下:

process中报了异常且没有被catch捕获,则process认为消息接收时出现错误,没有消费成功,则自动返回到队里第一位,再次重复执行:

.

反复回到队列重复执行...

.

在使用spring boot时,默认的是自动应答,如果想手工应答,在application.propretes中:

spring.rabbitmq.listener.acknowledge-mode=manual

则:

mq顺利执行完没有报错,但再次发送mq:

无法接收到新的mq消息。就需要在程序中进行手工消息应该操作:

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,222评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,455评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,720评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,568评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,696评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,879评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,028评论 3 409
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,773评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,220评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,550评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,697评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,360评论 4 332
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,002评论 3 315
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,782评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,010评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,433评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,587评论 2 350

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,633评论 18 139
  • 来源 RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。支持消息的持久化、事务、拥塞控...
    jiangmo阅读 10,351评论 2 34
  • 关于消息队列,从前年开始断断续续看了些资料,想写很久了,但一直没腾出空,近来分别碰到几个朋友聊这块的技术选型,是时...
    预流阅读 584,562评论 51 786
  • 有些东西,给你打开一扇窗的同时却关闭了一道门,比如社交网络 政治的功能之一是合理而恰当地处置谎言 时间这个东西,其...
    i图纹系阅读 1,458评论 0 14
  • 楔子 君问归期未有期 我叫戚期, 亲戚朋友们都说我的名字不好听,取得很随便,好像带着某种欺骗似的。 而我却...
    殇浅离阅读 320评论 1 0