如果消费者系统的数据库宕机，会怎么样？ 假设我们的MQ使用都没有问题，但是如果消费者系统的数据库挂了呢？因为我们一直都是假设了一个场景，就是生产者在处理完自己的逻辑之后会推消息到MQ，然后下游消费者系统从MQ里获取消息去执行后续的处理。 那么如果这个时候，消费者系统的数据库宕机了，同样会使消费者从MQ里获取到消息之后，消费线程就会挂掉，没办法继续进行处理。 所以针对这样的场景，消费者系统要怎么处理？应该如何重试？数据库宕机的时候，你还可以返回CONSUMESUCCESS吗？ 在下面代码片段中，我们注册了一个监听器回调函数，当consumer获取到消息之后，就会调用这个函数进行处理consumer。registerMessageListener（newMessageListenerConcurrently（）｛OverridepublicConsumeConcurrentlyStatusconsumeMessage（ListMessageExtmsgs，ConsumeConcurrentlyContextcontext）｛在这里对获取到的msgs订单消息进行处理比如增加积分、发送优惠券、通知发货，等等returnConsumeConcurrentlyStatus。CONSUMESUCCESS；｝｝）； 我们可以在这个回调函数中对消息进行处理，处理完之后，就可以告诉RocketMQConsumer这批消息的处理结果。 比如，如果返回的是CONSUMESUCCESS，那么Consumer就知道这批消息处理完成了，就会提交这批消息的offset到broker上去，然后下次就会继续从broker上获取下一批消息来处理。 但是如果此时我们在上面的回调函数中，对一批消息进行处理的时候，因为数据库宕机了，导致处理逻辑无法完成，此时我们还能返回CONSUMESUCCESS吗？如果你返回的话，下次就会处理下一批消息，但是这批消息其实没有处理成功，此时必然就导致这批消息丢失了。如果对消息的处理有异常，返回RECONSUMELATER状态 如果因为数据库宕机，导致对这批消息处理是异常的，就应该返回一个RECONSUMELATER状态。 告诉RocketMQ这批消息处理有异常，过段时间再次给我这批消息让我重新试一下。 所以我们的代码应该改成下面这样：consumer。registerMessageListener（newMessageListenerConcurrently（）｛OverridepublicConsumeConcurrentlyStatusconsumeMessage（ListMessageExtmsgs，ConsumeConcurrentlyContextcontext）｛try｛在这里对获取到的msgs订单消息进行处理比如增加积分、发送优惠券、通知发货，等等returnConsumeConcurrentlyStatus。CONSUMESUCCESS；｝catch（Exceptione）｛如果因为数据库宕机等问题，对消息处理失败了此时返回一个稍后重试的状态returnConsumeConcurrentlyStatus。RECONSUMELATER；｝｝｝）；RocketMQ是如何让你进行消费重试的 那么RocketMQ在收到你返回的RECONSUMELATER状态之后，是如何让你进行消费重试的呢？ RocketMQ有一个针对这个ConsumerGroup的重试队列，如果返回了RECONSUMELATER状态，他会把你这批消息放到这个消费组的重试队列中去。 比如你的消费者组的名称是VoucherConsumerGroup，那么他会有一个RETRYVoucherConsumerGroup这个名字的重试队列。 重试队列中的消息会按照配置的时间再次给消费者，让消费者进行处理，如果再次失败，那么会再过一段时间让消费者进行处理，默认最多是重试16次，每次重试之间的间隔时间是可以配置的：messageDelayLevel1s5s10s30s1m2m3m4m5m6m7m8m9m10m20m30m1h2h如果连续重试16次还是无法处理消息，然后怎么办？ 那么如果在16次重试范围内消息处理成功了，自然就没问题了，但是如果你对一批消息重试了16次还是无法处理成功呢？这个时候会把消息放到死信队列中。 其实就是一批消息交给消费者去处理，消费者重试了16次还一直没有处理成功，就不要继续重试这批消息了，就可以认为他们死掉了就可以了，然后这批消息会自动进入死信队列。 死信队列的名字是DLQVoucherConsumerGroup
让我难忘的人小学作文300字黄老师的好朋友郭老师来长沙了，我高兴得喜出忘外，因为又有人跟我玩了。据说他打篮球很厉害，太棒了，我可喜欢打篮球了。盼啊盼，终于盼到了郭老师。郭老师的身材很好，高高的个子，……圆桌论坛去中心化的加密艺术家需要互助成长2021赛博北京数字链得得、钛媒体集团、CryptoC发起主办的第一届赛博北京数字艺术节于8月7日至8月10日在线上举办。在律动BlockBeats深度作者、加密艺术家Sleepy的主持下，跨媒体……高二写景作文海边日落有人说日出好看，因为代表了前途光明，也有人说日落好看，因为又要预示着新的一天就要到了。不管是日出还是日落，都很美好。在城市的山上，看日出更好，在海边看日落别有一番风味。为……如果微信收100块年费，就能创造几百亿利润，腾讯为何不敢收？微信如果敢收费的话，不到一年立马垮掉！如果微信收费，你还会继续用吗？打开应用商店，下载量最高的基本上都是社交软件，微信已经成为人们日常必不可少的软件，社交、工作、学……三国演义的一种读法初二作文在校的学习生涯里，除了有学习陪伴我们，在课余时间里，我们可以看一些有趣的书籍啦讨论一下生活中的未解之谜啦！做一些有利身体健康的运动啦但是更多的同学都选择了沉浸在书的世界里当中，……我爱冬天的雪花六（4）班蒋梦莹不知我为什么那么爱雪，假如把雪比作清纯动听的乐章，深情、优美的诗篇，那么我更爱、更神往第一个令人新奇的音符、第一行令人陶醉的诗篇mdash；mdash；雪……三星GalaxyWatch4Classic智能手表放弃支持连IT之家8月12日消息外媒9to5Google报道，大多数与安卓智能手机兼容的智能手表通常也提供对苹果iOS平台的支持，但这种情况可能正在改变。通过三星GalaxyWatch4……精选作文假如时间可以倒流时间宛如一淌流水，失而不复，正因如此，它给我的生活和童年也留下了许多遗憾。假如时间可以倒流，我想回到以前学舞蹈的时光，因为舞蹈让我坚强了品格、坚定了信念。舞蹈还让我在六一……阿里女员工事件iPhone却遭狂喷，国人最需要的功能苹果就是要说这几天网上最火的事莫过于阿里女员工事件了。具体怎么回事小智在这里就不多做叙述，反正网上大把地讨论信息。但在这件事中，iPhone却莫名其妙地成为不少网友怒喷的对象，这到底是……幸福很简单幸福就像一缕清香，在空气中弥漫；而它又如同棉花糖一般，在我嘴里不停地浮动。是啊，幸福是弥漫在空气中的，不已让人察觉。有时，就是别人随意中的一句话，都会是幸福的。一个……被捧上神坛的阿里，我们是时候该降降温了最近阿里女员工被性侵事件，在全网引发关注，热度持续居高不下，很多人纷纷说，如今的阿里究竟是怎么了？后马云时代，阿里这艘大船又该如何远航？阿里的破冰文化真的是毫无下限和尺度吗？可……新款比亚迪唐EV续航里程达700公里还有啥里程焦虑？日前，我们从《新能源汽车推广应用推荐车型目录》（2021年第7批）获悉，新款比亚迪唐EV续航里程大幅提升，其NEDC续航分别达到700公里和615公里，与现款车型最高565公里……