温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

mq消息丢失问题如何解决

发布时间:2022-09-27 16:05:48 来源:亿速云 阅读:248 作者:iii 栏目:数据库

这篇“mq消息丢失问题如何解决”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“mq消息丢失问题如何解决”文章吧。

1.生产者存放消息的过程中丢失消息

mq消息丢失问题如何解决

解决办法:

(1)事务机制:(同步方式,不推荐)

对于RabbitMQ消息队列来说,生产者发送数据之前开启RabbitMQ的事务机制 channel.txselect,如果消息没有进队列,则生产者受到异常报错,并进行回滚channel.txRollback,然后重试发送消息。如果收到了消息,则可以提交事务channel.txCommit。这是同步操作,会影响性能。

(2)异步机制:

confirm模式来解决同步机制的性能问题。每次生产者发送的消息都会分配一个唯一的id,如果写入到了RabbitMQ队列中,则RabbitMQ会回传一个ack消息,说明这个消息接收成功。如果RabbitMQ没能处理这个消息,则回调nack接口。说明需要重试发送消息。

也可以自定义超时时间 + 消息 id 来实现超时等待后重试机制。但可能出现的问题是调用ack接口时失败了,所以会出现消息被发送两次的问题,这个时候就需要保证消费者消费消息的幂等性。

事务模式和confirm模式的区别:

事务机制是同步的,提交事务后悔被阻塞直到提交事务完成后。

confirm 模式异步接收通知,但可能接收不到通知。需要考虑接收不到通知的场景。

2.消息队列消息丢失

mq消息丢失问题如何解决

解决办法:

(1)创建Queue时,将其设置为持久化

(2)发送消息的时候将消息的deliveryMode设置为2(将消息持久化 1:非持久化,2:持久化)

(3)开启生产者 confirm`模式,可以重试发送消息。

3.消费者丢失消息

mq消息丢失问题如何解决

解决办法:

关闭RabbitMQ的自动ack,每次生产者将消息写入消息队列后,就自动回传一个ack给生产者。

消费者处理完消息再主动ack,告诉消息队列我处理完了。

4.总结

(1)开启生产者消息手动确认机制

(2)开启消息持久化,队列持久化,交换机持久化(默认开启)

(3)开启消费者消息手动确认机制

以上就是关于“mq消息丢失问题如何解决”这篇文章的内容,相信大家都有了一定的了解,希望小编分享的内容对大家有帮助,若想了解更多相关的知识内容,请关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

mq
AI