RabbitMQ中的消息会过期吗?
RabbitMQ 中的消息长期未被消费会过期吗?用过 RabbitMQ 的小伙伴可能都有这样的疑问,今天松哥就来和大家捋一捋这个问题。 1. 默认情况
首先我们来看看默认情况。
默认情况下,消息是不会过期的,也就是我们平日里在消息发送时,如果不设置任何消息过期的相关参数,那么消息是不会过期的,即使消息没被消费掉,也会一直存储在队列中。
这种情况具体代码就不用我再演示了吧,松哥之前的文章凡是涉及到 RabbitMQ 的,基本上都是这样的。 2. TTL
TTL(Time-To-Live),消息存活的时间,即消息的有效期。如果我们希望消息能够有一个存活时间,那么我们可以通过设置 TTL 来实现这一需求。如果消息的存活时间超过了 TTL 并且还没有被消息,此时消息就会变成 死信 ,关于死信 以及死信队列 ,松哥后面再和大家介绍。
TTL 的设置有两种不同的方式: 在声明队列的时候,我们可以在队列属性中设置消息的有效期,这样所有进入该队列的消息都会有一个相同的有效期。 在发送消息的时候设置消息的有效期,这样不同的消息就具有不同的有效期。
那如果两个都设置了呢?
以时间短的为准。
当我们设置了消息有效期后,消息过期了就会被从队列中删除了(进入到死信队列,后文一样,不再标注),但是两种方式对应的删除时机有一些差异: 对于第一种方式,当消息队列设置过期时间的时候,那么消息过期了就会被删除,因为消息进入 RabbitMQ 后是存在一个消息队列中,队列的头部是最早要过期的消息,所以 RabbitMQ 只需要一个定时任务,从头部开始扫描是否有过期消息,有的话就直接删除。 对于第二种方式,当消息过期后并不会立马被删除,而是当消息要投递给消费者的时候才会去删除,因为第二种方式,每条消息的过期时间都不一样,想要知道哪条消息过期,必须要遍历队列中的所有消息才能实现,当消息比较多时这样就比较耗费性能,因此对于第二种方式,当消息要投递给消费者的时候才去删除。
介绍完 TTL 之后,接下来我们来看看具体用法。
接下来所有代码松哥都以 Spring Boot 中封装的 AMPQ 为例来讲解。 2.1 单条消息过期
我们先来看单条消息的过期时间。
首先创建一个 Spring Boot 项目,引入 Web 和 RabbitMQ 依赖,如下:
然后在 application.properties 中配置一下 RabbitMQ 的连接信息,如下: spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest spring.rabbitmq.virtual-host=/
接下来稍微配置一下消息队列: @Configuration public class QueueConfig { public static final String JAVABOY_QUEUE_DEMO = "javaboy_queue_demo"; public static final String JAVABOY_EXCHANGE_DEMO = "javaboy_exchange_demo"; public static final String HELLO_ROUTING_KEY = "hello_routing_key"; @Bean Queue queue() { return new Queue(JAVABOY_QUEUE_DEMO, true, false, false); } @Bean DirectExchange directExchange() { return new DirectExchange(JAVABOY_EXCHANGE_DEMO, true, false); } @Bean Binding binding() { return BindingBuilder.bind(queue()) .to(directExchange()) .with(HELLO_ROUTING_KEY); } }
这个配置类主要干了三件事:配置消息队列、配置交换机以及将两者绑定在一起。 首先配置一个消息队列,new 一个 Queue:第一个参数是消息队列的名字;第二个参数表示消息是否持久化;第三个参数表示消息队列是否排他,一般我们都是设置为 false,即不排他;第四个参数表示如果该队列没有任何订阅的消费者的话,该队列会被自动删除,一般适用于临时队列。 配置一个 DirectExchange 交换机。 将交换机和队列绑定到一起。
这段配置应该很简单,没啥好解释的,有一个排他性,松哥这里稍微多说两句: ❝
关于排他性,如果设置为 true,则该消息队列只有创建它的 Connection 才能访问,其他的 Connection 都不能访问该消息队列,如果试图在不同的连接中重新声明或者访问排他性队列,那么系统会报一个资源被锁定的错误。另一方面,对于排他性队列而言,当连接断掉的时候,该消息队列也会自动删除(无论该队列是否被声明为持久性队列都会被删除)。
接下来提供一个消息发送接口,如下: @RestController public class HelloController { @Autowired RabbitTemplate rabbitTemplate; @GetMapping("/hello") public void hello() { Message message = MessageBuilder.withBody("hello javaboy".getBytes()) .setExpiration("10000") .build(); rabbitTemplate.convertAndSend(QueueConfig.JAVABOY_QUEUE_DEMO, message); } }
在创建 Message 对象的时候我们可以设置消息的过期时间,这里设置消息的过期时间为 10 秒。
这就可以啦!
接下来我们启动项目,进行消息发送测试。当消息发送成功之后,由于没有消费者,所以这条消息并不会被消费。打开 RabbitMQ 管理页面,点击到 Queues 选项卡,10s 之后,我们会发现消息已经不见了:
很简单吧!
单条消息设置过期时间,就是在消息发送的时候设置一下消息有效期即可。 2.2 队列消息过期
给队列设置消息过期时间,方式如下: @Bean Queue queue() { Map args = new HashMap<>(); args.put("x-message-ttl", 10000); return new Queue(JAVABOY_QUEUE_DEMO, true, false, false, args); }
设置完成后,我们修改消息的发送逻辑,如下: @RestController public class HelloController { @Autowired RabbitTemplate rabbitTemplate; @GetMapping("/hello") public void hello() { Message message = MessageBuilder.withBody("hello javaboy".getBytes()) .build(); rabbitTemplate.convertAndSend(QueueConfig.JAVABOY_QUEUE_DEMO, message); } }
可以看到,消息正常发送即可,不用设置消息过期时间。
OK,启动项目,发送一条消息进行测试。查看 RabbitMQ 管理页面,如下:
可以看到,消息队列的 Features 属性为 D 和 TTL,D 表示消息队列中消息持久化,TTL 则表示消息会过期。
10s 之后刷新页面,发现消息数量已经恢复为 0。
这就是给消息队列设置消息过期时间,一旦设置了,所有进入到该队列的消息都有一个过期时间了。 2.3 特殊情况
还有一种特殊情况,就是将消息的过期时间 TTL 设置为 0,这表示如果消息不能立马消费则会被立即丢掉,这个特性可以部分替代 RabbitMQ3.0 以前支持的 immediate 参数,之所以所部分代替,是因为 immediate 参数在投递失败会有 basic.return 方法将消息体返回(这个功能可以利用死信队列来实现)。
具体代码松哥就不演示了,这个应该比较容易。 3. 死信队列
有小伙伴不禁要问,被删除的消息去哪了?真的被删除了吗?非也非也!这就涉及到死信队列了,接下来我们来看看死信队列。 3.1 死信交换机
死信交换机,Dead-Letter-Exchange 即 DLX。
死信交换机用来接收死信消息(Dead Message)的,那什么是死信消息呢?一般消息变成死信消息有如下几种情况: 消息被拒绝(Basic.Reject/Basic.Nack) ,井且设置requeue 参数为false 消息过期 队列达到最大长度
当消息在一个队列中变成了死信消息后,此时就会被发送到 DLX,绑定 DLX 的消息队列则称为死信队列。
DLX 本质上也是一个普普通通的交换机,我们可以为任意队列指定 DLX,当该队列中存在死信时,RabbitMQ 就会自动的将这个死信发布到 DLX 上去,进而被路由到另一个绑定了 DLX 的队列上(即死信队列)。 3.2 死信队列
这个好理解,绑定了死信交换机的队列就是死信队列。 3.3 实践
我们来看一个简单的例子。
首先我们来创建一个死信交换机,接着创建一个死信队列,再将死信交换机和死信队列绑定到一起: public static final String DLX_EXCHANGE_NAME = "dlx_exchange_name"; public static final String DLX_QUEUE_NAME = "dlx_queue_name"; public static final String DLX_ROUTING_KEY = "dlx_routing_key"; /** * 配置死信交换机 * * @return */ @Bean DirectExchange dlxDirectExchange() { return new DirectExchange(DLX_EXCHANGE_NAME, true, false); } /** * 配置死信队列 * @return */ @Bean Queue dlxQueue() { return new Queue(DLX_QUEUE_NAME); } /** * 绑定死信队列和死信交换机 * @return */ @Bean Binding dlxBinding() { return BindingBuilder.bind(dlxQueue()) .to(dlxDirectExchange()) .with(DLX_ROUTING_KEY); }
这其实跟普通的交换机,普通的消息队列没啥两样。
接下来为消息队列配置死信交换机,如下: @Bean Queue queue() { Map args = new HashMap<>(); //设置消息过期时间 args.put("x-message-ttl", 0); //设置死信交换机 args.put("x-dead-letter-exchange", DLX_EXCHANGE_NAME); //设置死信 routing_key args.put("x-dead-letter-routing-key", DLX_ROUTING_KEY); return new Queue(JAVABOY_QUEUE_DEMO, true, false, false, args); }
就两个参数: x-dead-letter-exchange:配置死信交换机。 x-dead-letter-routing-key:配置死信 routing_key 。
这就配置好了。
将来发送到这个消息队列上的消息,如果发生了 nack、reject 或者过期等问题,就会被发送到 DLX 上,进而进入到与 DLX 绑定的消息队列上。
死信消息队列的消费和普通消息队列的消费并无二致: @RabbitListener(queues = QueueConfig.DLX_QUEUE_NAME) public void dlxHandle(String msg) { System.out.println("dlx msg = " + msg); }
很容易吧~ 4. 小结
好啦,今天就和小伙伴们聊一聊 RabbitMQ 中的消息过期问题,感兴趣的小伙伴可以去试试哦~ 原文链接:https://mp.weixin.qq.com/s/fFqzuN2AnLazoCyahL3EFw
原作者:江南一点雨
中国平安今天又回购了1。17亿,50元就是历史大底中国平安H股公告,11月2日回购1。17亿今天收盘后中国平安H股公告,中国平安集团今天继续在A股市场对中国平安股票进行回购,今天一共回购2,369,800股,回购最高价49。79元
大部分消费类股的阴跌极限是7个月伊利股份就是阴跌7个月后大反弹的优秀案例伊利股份是目前消费类公司反弹最快一家上市公司,伊利股份从今年1月达到最高点51。03后,就开始一路阴跌,持续到8月才开始彻底走出低估,阴跌长
敦煌网上的高清商品图片怎么快速一键批量采集保存对于一些刚接触跨境电商的小伙伴,如何找电商图片素材,如何做好商品选款可以算得上是大难题了。敦煌网作为知名的跨境电商平台,商品的种类非常齐全。今天,小编要跟大家一起分享一下敦煌网上的
快速压缩多个视频内存的具体操作方法和步骤当我们拍摄或采集的视频内存太大,导致无法批量保存的时候怎么办?今天,小编就要跟大家分享一下视频剪辑的实操经验,教你如何一键批量压缩视频内存,再也不要因为内存不够用而烦恼了,一起来看
心理咨询机构预约小程序怎么做?心理咨询行业由于其特殊性,在宣传推广方面存在着许多的限制,而这也导致心理咨询机构面临获客难的问题。为了解决这个难题,一些心理咨询机构选择开发微信小程序,借此来提高心理咨询机构线上的
月子中心小程序制作教程月子中心怎么引流进店?今天小编要跟大家聊的是月子中心微信小程序的开发制作,一起来看看具体的开发制作流程吧!所需工具电脑乔拓云网微信公众平台制作流程1。我们需要先去微信公众平台申请注册一个微信小程序,并且
一键批量获取米拍摄影相册高清原图的小技巧米拍摄影作为国内知名的图片素材网,上面有很多质量非常不错的高清图片。从事美工行业的朋友平时对素材的需求量又非常高,如果想要在米拍摄影上积累图片素材的话,要怎么操作呢?今天我就来分享
如何制作h5抽奖页面抽奖大转盘网页九宫格抽奖页面等社交软件中最热门当属微信模式,商家依托微信,发布各种营销活动,比如幸运抽奖大转盘,这种活动是引流涨粉的利器,制作抽奖转盘通常有两种途径,找专业的人开发,好处,可以做成你想要的任何样
教师节营销策划方案有哪些?借势营销花样多多,值得拥有在教师节营销活动中,我们可以采取不同的方式进行宣传,来营造出节日氛围。我们可以通过不同的方式可以对教师进行评选抽奖以及教师节促销活动。下面为大家介绍教师节营销模板使用方法我们需要先
国庆节海报如何制作,高端大气的海报制作如此简单一年一度的国庆节即将来临,准备好节日的小长假,那么可以想象的到,很多人就早在节日前就开始规划假日之旅,饱览祖国大好河山,着实让人兴奋而自豪。那么各大品牌自然也不会放过这个小长假,都
眼镜店如何宣传才能吸引人,营销宣传活动好点子分享随着开学季到来,很多眼镜店开始做宣传活动,为了增加眼镜店的收入,我们可以做一些眼镜店的宣传活动,通过活动宣传可以有效的用户进行互动。这里我们可以使用乔拓云线上线下的方式进行推广,为