暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

Rocketmq Message消息结构

v587博客 2021-08-24
669



01 我对rocketmq简单认识


早之前听过Metamq,后来出来Rocketmq,还没反应过来,原来是改了名字。Rocketmq现在开始有企业陆续使用它了,架构师们既然选择它,定有它的原因。网上有很多Rocketmq的介绍,这里就不重复了。


我关注它,是因为工作需要用到它。读者朋友们也可能跟我一样。对吗?

其实,再深入一点点,我想有以下几个原因,驱使企业选择它:


  • java语言开发的

    • 如果是其它语言,比如erlang,那假如企业要对消息系统改造,那就麻烦了,erlang工程师真的比较少。而java工程师,一抓一大把!-_-||

  • 阿里出品的开源产品

    • 大厂值得信赖

  • 经过双11验证的

    • 稳定性毋庸置疑


02 RocketMq的消息结构



字段名是否必填默认值说明
Topicnull线下环境不需要申请,线上环境需要申请后才能使用
Bodynull二进制形式,序列化由应用决定,Producer 与 Consumer 要协商好序列化形式
Tags
null标签,方便服务器过滤使用。目前只支持每个消息设置一个 tag
Keys
null代表这条消息的业务关键词,服务器会根据 keys 创建哈希索引,设置后,可以在 Console 系统根据 Topic、Keys 来查询消息,由于是哈希索引,请尽可能保证 key 唯一
Flag
0完全由应用来设置,RocketMQ 不做干预
DelayTimeLevel
0消息延时级别,0 表示不延时,大于 0 会延时特定的时间才会被消费
WaitStoreMsgOK
true表示消息是否在服务器落盘后才返回应答。


文章转载自v587博客,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

评论