RocketMQ系列异常处理：发送失败、重复消费

RocketMQ系列异常处理：发送失败、重复消费 RocketMQ系列异常处理发送失败、重复消费文章目录生产者失败消费者幂等处理使用消息队列，不论是消息生产者还是消费者，都容易存在异常情况。生产者失败异常情况：生产者在把消息发送到mq的broker的过程中，容易存在以下情况：1.发送时，网络异常，消息没有到达broker；2.发送同步消息时，消息到达broker，但是当broker相应生产者时，网络异常，生产者没有收到响应，认为发送失败；解决方案：如果是发送异步消息，也就是生产者不会等待broker响应，此种情况就会产生消息丢失；如果业务场景不在乎少量消息...

RocketMQ系列异常处理发送失败、重复消费文章目录生产者失败消费者幂等处理使用消息队列，不论是消息生产者还是消费者，都容易存在异常情况。生产者失败异常情况：生产者在把消息发送到mq的broker的过程中，容易存在以下情况：1.发送时，网络异常，消息没有到达broker；2.发送同步消息时，消息到达broker，但是当broker相应生产者时，网络异常，生产者没有收到响应，认为发送失败；解决方案：如果是发送异步消息，也就是生产者不会等待broker响应，此种情况就会产生消息丢失；如果业务场景不在乎少量消息丢失，则不要处理；否则可以采用如下方法：使用带回调的消息发送方法，生产者的异步线程在发送消息后，会根据结果情况，调用回掉接口中的方法，成功或者失败，生产者根据具体情况记录日志or保存数据库，后续可以通过定时任务或者人工处理失败的消息，进行重新发送。如果发送同步消息，生产者会等待broker返回结果，如果失败，可以进行重试或者保存到数据库，后续再从数据库中查询出来进行重发。以上只能保证消息成功发送到broker，但无法保证唯一性，因为当消息到达broker，但是broker却没有响应时，生产者会重复发送（客户端默认重试3次），导致消息重复。消费者幂等处理上述分析中，消费者可能会重复发送消息，因此需要消费者进行幂等处理，否则会导致业务异常，比如重复扣减库存数量。实际产生消息重复的情况有如下几种：生产者重复发送；broker投递消息时，重复投递；当broker推送到消费者，但是没有得到消费者的响应（比如消费者响应时，网络异常），此时broker会重复投递消息；负载均衡时消息重复：当rocketmq的broker宕机、重启、扩容、缩容时，可能会触发rebalance，导致消息重复消费。常用的幂等处理方案：消费者在接收到消息之后，在消息处理之前，先查询数据库中是否存在，存在则不处理。如果不存在，则首先将消息存入数据库，存入成功后，在处理消息。这里注意的是，要使用一定的规则来界定消息的重复性，比如使用订单id（不要使用消息id，因为rocketmq不保证消息id的唯一性），如果使用mysql，这个订单id要加唯一索引，避免并发时，两个线程同时查询数据库，发现不存在，然后同时将消息存入数据库的情况。更多最佳实践，请参考官方文档：best_practice -全文完-

                    本文档为【RocketMQ系列异常处理：发送失败、重复消费】，请使用软件OFFICE或WPS软件打开。作品中的文字与图均可以修改和编辑，
                    图片更改请在作品中右键图片并更换，文字修改请直接点击文字进行修改，也可以新增和删除文档中的内容。 
 该文档来自用户分享，如有侵权行为请发邮件ishare@vip.sina.com联系网站客服，我们会及时删除。

                    [版权声明] 本站所有资料为用户分享产生，若发现您的权利被侵害，请联系客服邮件isharekefu@iask.cn，我们尽快处理。

                    本作品所展示的图片、画像、字体、音乐的版权可能需版权方额外授权，请谨慎使用。

                    网站提供的党政主题相关内容(国旗、国徽、党徽..)目的在于配合国家政策宣传，仅限个人学习分享使用，禁止用于任何广告和商用目的。
                

下载需要：免费已有0 人下载

立即下载

RocketMQ系列异常处理：发送失败、重复消费

你可能还喜欢