本文涉及:投递失败的消息怎么处理、如何实现延时队列、如何指定消息的优先级、消息的持久化是如何实现的、如何保证消息不丢失
投递失败的消息怎么处理
首先投递失败存在如下两个情况
- 当交换器无法根据自身的类型和路由键找到符合条件的队列
- 如果交换器在将消息路由到队列时发现队列上并不存在任何消费者
解决方案:
在生产者投递消息时指定mandatory或者imrnediate参数设为 true 时,RabbitMQ 会把无法投递的消息通过Basic.Return 命令将消息返回给生产者,此时生产者需要调用channel.addReturnListener 来添加 ReturnListener 监昕器实现监听投递失败的消息
如果设置了上方两个参数就要添加ReturnListener 逻辑,使生产者的逻辑变得复杂,RabbitMQ中的备份交换机也可以处理这个问题
以通过在声明交换器(调用 channel.exchangeDeclare 方法)的时候添加alternate-exchange 参数来实现
对于备份交换器,使用时包含几种特殊情况:
如果设置的备份交换器不存在,客户端和 RabbitMQ 服务端都不会有异常出现,此时消息会丢失
如果备份交换器没有绑定任何队列,客户端和 RabbitMQ 服务端都不会有异常出现,此时消息会丢失
如果备份交换器没有任何匹配的队列,客户端和 RabbitMQ 服务端都不会有异常出现,此时消息会丢失
如果备份交换器和 mandatory 参数一起使用,那么 mandatory 参数无效
如何设置消息的过期时间
设置队列属性,队列中所有消息都有相同的过期时间
对消息本身进行单独设置,每条消息的 TTL 可以不同
如果两种方法一起使用,则消息的 TTL 以两者之间较小的那个数值为准
如何实现延时队列
- 使用死信交换机
消息投递到一个没有消费者的队列中,为这个队列指定死信队列,当消息达到设置过期时间还没有被消费时将会被发布到死信队列中,而消费者订阅死信队列直接消费到了一份延时消息
延时消息插件
从以下地址下载延时插件rabbitmq_delayed_message_exchange
<figure class="highlight dts"><table><tr>
<td class="gutter"><pre><span class="line">1</span><br></pre></td>
<td class="code"><pre><span class="line"><span class="symbol">https:</span><span class="comment">//www.rabbitmq.com/community-plugins.html</span></span><br></pre></td>
</tr></table></figure>
把下载好的插件放到以下目录
<figure class="highlight crystal"><table><tr>
<td class="gutter"><pre><span class="line">1</span><br></pre></td>
<td class="code"><pre><span class="line">/usr/<span class="class"><span class="keyword">lib</span>/<span class="title">rabbitmq</span>/<span class="title">lib</span>/<span class="title">rabbitmq_server3</span>.6.4/<span class="title">plugins</span></span></span><br></pre></td>
</tr></table></figure>
启动插件
<figure class="highlight routeros"><table><tr>
<td class="gutter"><pre><span class="line">1</span><br></pre></td>
<td class="code"><pre><span class="line">rabbitmq-plugins <span class="builtin-name">enable</span> rabbitmq_delayed_message_exchange</span><br></pre></td>
</tr></table></figure>
声明交换器类型为x-delayed-message来标示此交换机为延时交换机
发送消息时在header中添加”x-delay”参数来控制消息的延时时间
如何指定消息的优先级
设置队列的 max priority 参数,RabbitMQ中消息的优先级默认是0,最大值是10
消息的持久化是如何实现的
RabbitMQ的持久化分为:交换器的持久化、队列的持久化和消息的持久化
交换器和队列的持久化都是通过在声明时将 durable 参数置为 true 实现的
消息的持久化是在发送消息指定deliveryMode为2实现的
如何保证消息不丢失
生产者开启事务或者发送方确认机制,交换机、队列和消息全部设置持久化,消费者开启消费确认机制
推荐阅读
- SpringCloud学习系列汇总
- 为什么一线大厂面试必问redis,有啥好问的?
- 多线程面试必备基础知识汇总
- Java集合源码分析汇总-JDK1.8
- Linux常用命令速查-汇总篇
- JVM系列文章汇总
- MySQL系列文章汇总
- RabbitMQ系列文章汇总
博客所有文章首发于公众号《Java学习录》转载请保留
扫码关注公众号即可领取2000GJava学习资源
分享到:
相关推荐
RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件
RabbitMQ最新2021年面试题,高级面试题及附答案解析
Java后端高级面试题,涵盖关系型数据库、非关系型数据库redis、并发编程、Spring/SpringMVC、JVM、微服务、RabbitMQ等技术,冲!
程序员java面试题汇总 【资源介绍】 适宜人群:准备跳槽的初/中/高级 Java 程序员 想要查漏补缺的人 想要不断完善和扩充自己 Java...RabbitMQ部分面试题 Kafka部分面试题 Zookeeper部分面试题 MySql部分面试题等等等
RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息...本资料主要是分享在java面试中关于消息中间件rabbitmq的面试题,里面有一些架构图,也有很多八股文,大伙儿该背的还是得背一背,相信对大家还是有所帮助的!!!
它是用Erlang语言编写的,并且基于AMQP(高级消息队列协议)协议实现。作为一种应用程序之间的通信方法,RabbitMQ在分布式系统开发中应用非常广泛。 RabbitMQ的特点包括可靠性、灵活的路由、可扩展性、高可用性、...
Java后端体系高级面试题,包括数据库、redis、并发编程、Spring/SpringMVC、JVM、微服务、RabbitMQ等,助您找到高薪工作!
java高级面试题(包含redis rabbitmq java) 有答案java
1、什么是 rabbitmq 2、为什么要使用 rabbitmq 1、在分布式系统下具备异步,削峰,负载均衡等一系列高级功能 2、拥有持久化的机制,进程消息,队
2022年Java最新全套面试题资料,包含:Dubbo、JVM、Kafka、Linux、MongoDB、MyBatis、MySQL、Netty、Nginx、RabbitMQ消息中间件、Redis、Spring、SpringBoot、SpringCloud、SpringMVC、Tomcat、Zookeeper、并发编程...
java面试合集(内容涵盖:Java、MyBatis、ZooKeeper、Dubbo、Elasticsearch、Memcached、 Redis、MySQL、Spring、Spring Boot、Spring Cloud、RabbitMQ、Kafka、 Linux 等技术栈)
本套Java面试题大全,全的不能再全,需要的朋友可下载试试!一、Java基础知识面试题 1、Java概述 2、基础语法 3、面向对象 4、IO流? 5、反射 6、网络编程 7、常用API 8、常用工具类库 9、单元测试 10、日志 二、...
下面就来详细介绍一下Java开发RabbitMQ部分可能涉及的面试题。首先,RabbitMQ是一个开源的消息队列系统,它采用AMQP(高级消息队列协议)作为消息传输的标准。在分布式系统中,消息队列是一种常用的解耦方式,可以将...
2.笔试面试真题,划分为面试真题和企业面试题(面试真题按知识点划分,企业面试题按企业划分,都是大厂的) 3.公司题库,含面试笔试真题解析和答案,上百道真题。 涉及的java知识点: 01_Java语法基础 02_Java集合 ...
这本面试手册包含了Java基础、Java集合、JVM、Spring、Spring Boot、Spring Cloud、Mysql、Redis、RabbitMQ、Dubbo、Netty、Kafka、MongoDB、设计模式、数据结构、Java算法、加密算法、机器学习、云计算、分布式及...
02 10道Java高级必备的Netty面试题!.pdf 03 10道Java面试必备的设计模式面试题!.pdf 04 10个Java经典的List面试题!.pdf 05 10个Java经典的Main方法面试题!.pdf 06 10个Java经典的String面试题!.pdf 07 15道经典...
15 24道消息队列RabbitMQ面试题!.pdf 16 27道顶尖的Java多线程、锁、内存模型面试题!.pdf 17 29道常见的Spring面试题!.pdf 18 30个Java经典的集合面试题!.pdf 19 36道面试常问的MyBatis面试题!.pdf 20 40道常问...
史上最全java八股文面试题,高级/资深java都适合,涉及到的知识点有:Java基础、Spring/SpringMVC、SpringBoot、设计模式、多线程、集合、Java虚拟、网络TCP/IP、Redis/Memcached/Ehcache/Jetcache、Dubbo、RocketMQ...
ActiveMQ+RabbitMQ+Kafka、分布式限流面试专题系列:Nginx+zookeeper、集合、开源框架面试题系列:Spring+SpringMVC+MyBatis、面试必备之乐观锁与悲观锁、面试必问并发编程高级面试专题、面试常问必备之MySQL面试55...
对面试高级java工程师中可能会遇到的一些关于消息中间件的问题进行了整理,包括rabbitmq,kafka