mq网络请求命令设计
RemotingCommand:
flag倒数第一位表示请求类型,0请求1返回。倒数第二位1.表示oneway
单条消息发送时,消息体的内容将保存在body种,批量消息发送,需要将多条消息体的内容存储在body中,RocketMQ采取的方式是,对单条消息内容使用固定格式进行存储
首先调用batch方法,将一批消息封装成MessageBatch对象,MessageBatch继承自Message对象,MessageBatch内部持有List<Message>messages,这样的话,批量消息发送流程与单条消息发送的处理流程完全一样。MessageBatch只需要将该集合中的每条消息的消息体body聚合成一个byte[]数值,在消息服务端能够从该byte[]数值中正确解析出消息即可。
相关推荐
程序员伊成 2020-08-06
waitzkj 2020-07-25
powrexly 2020-07-20
waitzkj 2020-07-18
shenzhenzsw 2020-06-21
陈晨软件五千言 2020-06-11
zhangtianshun 2020-06-09
Soongp 2020-06-07
waitzkj 2020-06-04
cj0 2020-06-01
zry 2020-05-28
wbingyang 2020-05-26
isHooky 2020-05-15
cj0 2020-05-11
shenzhenzsw 2020-05-09
OnMyHeart 2020-05-09
憧憬 2020-05-02
fansenjun 2020-04-27