资源干货第一时间送达!
今天安妮就给小伙伴们列举以下几个点:
说明:以下内容非强制或必学,做到了解即可。但是,最好熟练!
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全栈大联盟安妮。大家对微信博文有什么问题都可以@我留言,我会尽快回复大家。希望以后可以和各位成为技术道友!
安妮
领取专属 10元无门槛券
私享最新 技术干货