通讯"/>
RocketMQ(二):RPC通讯
匠心零度 转载请注明原创出处,谢谢!
RocketMQ网络部署图
- NameServer:在系统中是做命名服务,更新和发现 broker服务。
- Broker-Master:broker 消息主机服务器。
- Broker-Slave: broker 消息从机服务器。
- Producer: 消息生产者。
- Consumer: 消息消费者。
rocketmq的几个核心的模块,而对于每个模块都是单独的jvm进程,我们看到上面的架构图的时候,那些箭头就是rocketmq的rpc调用,下面我们来看看rocketmq的rpc是如果进行封装实现的。
说明: rocketmq系列都将会以rocketmq-4.1.0-incubating进行介绍。
RocketMQ通信组件
先排除Master、Slave直接通过原生的nio进行调用,其他通讯都是基于netty-all-4.0.36.Final以及RocketMQ自定义协议进行通讯的。
网络协议定义如下
我们来看看header data里面的数据定义:
code对于Request来说就是RequestCode类里面的常量信息:
说明:公众号【匠心零度】回复:rocketmq,可获得基于rocketmq4.1.0加详细中文代码注释 。
public class RequestCode {// Broker 发送消息public static final int SEND_MESSAGE = 10;// Broker 订阅消息public static final int PULL_MESSAGE = 11;// Broker 查询消息public static final int QUERY_MESSAGE = 12;// Broker 查询Broker Offsetpublic static final int QUERY_BROKER_OFFSET = 13;// Broker 查询Consumer Offsetpublic static final int QUERY_CONSUMER_OFFSET = 14;// Broker 更新Consumer Offsetpublic static final int UPDATE_CONSUMER_OFFSET = 15;// Broker 更新或者增加一个Topicpublic static final int UPDATE_AND_CREATE_TOPIC = 17;// Broker 获取所有Topic的配置(Slave和Namesrv都会向Master请求此配置)public static final int GET_ALL_TOPIC_CONFIG = 21;// Broker 获取所有Topic配置(Slave和Namesrv都会向Master请求此配置public static final int GET_TOPIC_CONFIG_LIST = 22;// Broker 获取所有Topic名称列表public static final int GET_TOPIC_NAME_LIST = 23;// Broker 更新Broker上的配置public static final int UPDATE_BROKER_CONFIG = 25;// Broker 获取Broker上的配置public static final int GET_BROKER_CONFIG = 26;// Broker 触发Broker删除文件public static final int TRIGGER_DELETE_FILES = 27;// Broker 获取Broker运行时信息public static final int GET_BROKER_RUNTIME_INFO = 28;// Broker 根据时间查询队列的Offsetpublic static final int SEARCH_OFFSET_BY_TIMESTAMP = 29;// Broker 查询队列最大Offsetpublic static final int GET_MAX_OFFSET = 30;// Broker 查询队列最小Offsetpublic static final int GET_MIN_OFFSET = 31;// Broker 查询队列最早消息对应时间public static final int GET_EARLIEST_MSG_STORETIME = 32;// Broker 根据消息ID来查询消息public static final int VIEW_MESSAGE_BY_ID = 33;// Broker Client向Client发送心跳,并注册自身public static final int HEART_BEAT = 34;// Broker Client注销public static final int UNREGISTER_CLIENT = 35;// Broker Consumer将处理不了的消息发回服务器public static final int CONSUMER_SEND_MSG_BACK = 36;// Broker Commit或者Rollback事务public static final int END_TRANSACTION = 37;// Broker 获取ConsumerId列表通过GroupNamepublic static final int GET_CONSUMER_LIST_BY_GROUP = 38;// Broker 主动向Producer回查事务状态public
更多推荐
RocketMQ(二):RPC通讯
发布评论