mq网络请求命令设计

RemotingCommand:

mq网络请求命令设计

flag倒数第一位表示请求类型,0请求1返回。倒数第二位1.表示oneway

单条消息发送时,消息体的内容将保存在body种,批量消息发送,需要将多条消息体的内容存储在body中,RocketMQ采取的方式是,对单条消息内容使用固定格式进行存储

mq网络请求命令设计

首先调用batch方法,将一批消息封装成MessageBatch对象,MessageBatch继承自Message对象,MessageBatch内部持有List<Message>messages,这样的话,批量消息发送流程与单条消息发送的处理流程完全一样。MessageBatch只需要将该集合中的每条消息的消息体body聚合成一个byte[]数值,在消息服务端能够从该byte[]数值中正确解析出消息即可。

mq网络请求命令设计

mq网络请求命令设计

mq网络请求命令设计

相关推荐