企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# 一、消息丢失的原因 ①消息生产者没有成功发送消息到MQ ②消息发送成功,但是MQ宕机了,(没来得及持久化)内存丢失 ③消费者获取消息,但是还没来得及处理,消费者宕机了,由于MQ已经把数据删除,不能再重新获取之前的消息 # 二、如何保证不丢失 ⑴针对①:在MQ获取消息之后返回给生产者一个确认信息 ⑵针对②:通过配置刷盘和复制参数,让消息写入多个副本的磁盘上,来确保消息不会因为某个Broker宕机或者磁盘损坏而丢失 ⑶针对③:消费者处理完逻辑后返回MQ一个ack确认,再进行删除(可能会造成重复消费)