• 每天一个知识点- rabbitMq 如何防止消息不丢失

    在这里插入图片描述

    每日一题

    在这里插入图片描述

    rabbitMq 如何防止消息不丢失

    我们使用 rabbitMq 用来传递消息的时候，至少有三个参与者，分别是 生产者、MQ、消费者
    从三个参与者的角度来说都有可能出现消息丢失的情况

    生产者生产消息 保证消息投递到MQ

    在生产者发送到RabbitMQ Server时有可能因为网络问题导致投递失败，从而丢失数据。我们可以使用confirm模式（或者事务机制 但是影响性能）防止数据丢失和消息落库保证消息不丢失

    1. 在生产者发送消息之前，保存消息到数据库，设置状态位发送中
    2. 生产者收到MQ的确认回调时，更改数据库中消息的状态为已删除
    3. 可以开启定时任务扫描未发送成功的消息重新投递，重试一定次数后还未成功，则标记消息状态为发送失败之后人工处理

    RabbitMQ Server

    在rabbitMq内部出现消息丢失分为两种情况

    1. 消息找不到对应的 exchange 或者 queue
      这两种都可以使用 rabbitMq 的参数 mandatory 来解决，开启强制消息投递（mandatory为设置为true），但消息未被路由至任何一个queue，则回退一条消息到RabbitTemplate.ReturnCallback中的returnedMessage方法
    2. rabbitServer 宕机
      需要将队列和exchange持久化

    消费者消费异常

    打开手动消费者确认机制，手动ACK，如果消费者出现异常，消息重新入队，等待再次消费，这里可能会出现消息重复消费的情况，所以同时也要保证消息的幂等性

  • 相关阅读:
    手机上的动态ip流量是算自己的流量吗？
    dubbo的学习笔记
    【搭建yolox深度学习环境】
    在毕设中，使用vue3+pinia的一些收获
    QJsonObject经过哪些转换才能发送到UDP端口
    FreeRTOS创建任务-简要
    Head First HTML与CSS 阅读笔记
    企业能源管控平台—化工行业方案
    服务器折腾
    【Elasticsearch】kibana 操作es文档详细总结
  • 原文地址：https://blog.csdn.net/qq_44808472/article/details/126412073