RocketMQ 2 理论知识

RocketMQ支持3种消息发送方式

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

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

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

消息结构

基础属性

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

消息体：消息的内容，可有是String，也可以是对象类型（此对象可有序列化）。单个消息的最大长度是4M

消息Flag：消息的标记，

拓展属性

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

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

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

快速入门

特殊说明： 解决问题的光鲜，藏着磕Bug的痛苦。 万物皆入轮回，谁也躲不掉！ 以上文章，均是我实际操作，写出来的笔记资料，不会出现全文盗用别人文章！烦请各位，请勿直接盗用！