rocketmq的通信协议分析 rocketmq底层的通信是放在org.apache.rocketmq.remoting包下的，主要有RPCHook、RemotingServer、RemotingClient、RemotingUtil、RemotingHelper等接口和类组成 RemotingCommand协议 RemotingCommand是rocketmq定义的远程通信协议 //请求头sta...

Linux环境排查问题的工具和思路 将工作中使用到的在Linux下进行排查问题的工具和思路进行一个总结，主要从CPU、内存、I/O、网络、JVM这五个方面来进行。 CPU部分 CPU的性能指标 图示 CPU的性能分析工具 性能指标 性能工具 描述 系统CPU使用率 top、vmstat、mpstat、sar、/proc/stat top、vmstat、mpstat作为实时的监控...

RocketMQ主从同步机制分析 Broker分为Slave、Master两种角色，因此Slave会从master中同步信息、topicConfig、ConsumerOffer、DelayOffset、SubscriptionGroupConfig等信息 启动同步 handleSlaveSynchronize handleSlaveSynchronize是处理Slave Broker同步Ma...

rocketmq常见问题 RocketMQ由哪些角色组成？ 由NameSrv、Broker、Consumer、Producer组成 RocketMQ的整体流程？ NameSrv首先启动 Broker启动后向NameSrv进行注册，并对外提供服务 producer向NameSrv查询向Topic提供写服务的Broker进行写入 consumer向NameSrv查询向Topic提供写服务的Broke...

MQClientInstance类分析 MQClientInstance是位于org.apache.rocketmq.client.impl.factory下的一个为producer和consumer提供统一和Broker进行交互的底层工具类； 创建 MQClientManager public MQClientInstance getOrCreateMQClientInstance(fina...

MessageQueue的分析 MessageQueue是 TODO ...