标签：tin rem com 聚合 处理流程 固定 调用 list ges
RemotingCommand:
flag倒数第一位表示请求类型，0请求1返回。倒数第二位1.表示oneway
单条消息发送时，消息体的内容将保存在body种，批量消息发送，需要将多条消息体的内容存储在body中，RocketMQ采取的方式是，对单条消息内容使用固定格式进行存储
首先调用batch方法，将一批消息封装成MessageBatch对象，MessageBatch继承自Message对象，MessageBatch内部持有List<Message>messages,这样的话，批量消息发送流程与单条消息发送的处理流程完全一样。MessageBatch只需要将该集合中的每条消息的消息体body聚合成一个byte[]数值,在消息服务端能够从该byte[]数值中正确解析出消息即可。
标签：tin rem com 聚合 处理流程 固定 调用 list ges
原文地址：https://www.cnblogs.com/lccsblog/p/12203741.html
