Java全栈大联盟RabbitMQ系列之Queue消息队列属性介绍(9)

资源干货第一时间送达!

今天安妮就给小伙伴们列举以下几个点:

说明:以下内容非强制或必学,做到了解即可。但是,最好熟练!

1、消息Message属性介绍

2、代码实践

3、运行效果展示

1、消息Message属性

服务器和应用程序之间传送的数据

本质上就是一段数据,由Properties和Body组成

常用属性:delivery mode、headers(自定义属性)、content_type、content_encoding、priority

这个priority并不能百分百保证,一定是优先级高的先执行,因为我们是集群模式,集群模式有多个消费者,这里涉及到一个顺序消费,后续会详细介绍顺序消息如何设计。

correlation_id:可视为消息唯一id,可能有些业务它和timestamp做拼接作为消息唯一id,然后再去做一些ACK

reply_to:做重回队列时,可以指定消息失败时,可以返回到哪个队列。

expiration:消息过期时间

deliveryMode为2,表示消息是持久化的投递;

2、生产者代码

启动生产者服务,查看queue:

再过10s,再次查看queue,消息已过期:

3、消费者代码

4、运行效果

启动消费者服务,再启动生产者服务:

觉得有用就转发分享一下吧

大家12月份的第三个周二愉快,与你前行

精彩内容

看完本文有收获?请转发分享给更多人

关注「Java全栈大联盟」,提升大神技能

欢迎新旧粉丝(撒花),我是Java全栈大联盟安妮。大家对微信博文有什么问题都可以@我留言,我会尽快回复大家。希望以后可以和各位成为技术道友!

安妮

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181211G062A800?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。

扫码关注云+社区

领取腾讯云代金券