
01 我对rocketmq简单认识
早之前听过Metamq,后来出来Rocketmq,还没反应过来,原来是改了名字。Rocketmq现在开始有企业陆续使用它了,架构师们既然选择它,定有它的原因。网上有很多Rocketmq的介绍,这里就不重复了。
我关注它,是因为工作需要用到它。读者朋友们也可能跟我一样。对吗?
其实,再深入一点点,我想有以下几个原因,驱使企业选择它:
java语言开发的
如果是其它语言,比如erlang,那假如企业要对消息系统改造,那就麻烦了,erlang工程师真的比较少。而java工程师,一抓一大把!-_-||
阿里出品的开源产品
大厂值得信赖
经过双11验证的
稳定性毋庸置疑
02 RocketMq的消息结构
| 字段名 | 是否必填 | 默认值 | 说明 |
|---|---|---|---|
| Topic | √ | null | 线下环境不需要申请,线上环境需要申请后才能使用 |
| Body | √ | null | 二进制形式,序列化由应用决定,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进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。




