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