本文介绍: RabbitMQ(六)消息的持久化
一、简介
1.1 定义
1.2 消息丢失的场景
出现消息丢失的场景有:
二、交换机的持久化
方式一:直接 new
直接实例化对应的 Exchange
实现类即可,默认:持久化的、非自动删除的。
Exchange
源码:
方式二:channel.exchangeDeclare()
在 RabbitMQ 的原生 API 中,例如:Java 客户端 API,声明持久化交换机时,需要将 durable
参数设置为 true
:
方式三:ExchangeBuilder【推荐】
三、队列的持久化
方式一:直接 new
方式二:channel.queueDeclare()
方式三:QueueBuilder【推荐】
四、消息的持久化
方式一:channel.basicPublish()
方式二:rabbitTemplate.convertAndSend()【推荐】
五、持久化问题
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。