RocketMQ支持3种消息发送方式

同步消息(Sync Message):生产者向broker发送消息,执行相关的代码同时等待,直到broker服务器返回发送结果,在后续执行。

异步消息(Async Message):生产者向broker发送消息时指定消息发送成功及发送异常的回调方法,调用的生产者代码执行立即返回,生产者发送消息线程不阻塞,消息发送成功或失败的回调任务在一个新的线程中执行。

单项消息(Oneway Message):生产者向broker发送消息,执行相关代码时直接返回,不等待broker服务器的结果。

消息结构

基础属性

topic:主题:将相同topic的消息发送到相同的的消息队列中。

消息体:消息的内容,可有是String,也可以是对象类型(此对象可有序列化)。单个消息的最大长度是4M

消息Flag:消息的标记,

拓展属性

tag:消息的二级分类,用于消费消息时进行过滤,可为空。

keys:Messgae索引键,可有根据key,快速检索到消息,可为空。

waitStoreMsgOK:消息发送时是否等消息存储后在返回。

快速入门