rocketmq常见问题

· 消息队列

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

Read More →
#RocketMQ

MQClientInstance类分析

· 消息队列

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

Read More →
#RocketMQ

Consumer源代码分析

· 消息队列

Consumer源代码分析 消费流程 DefaultMQPushConsumer DefaultMQPushConsumer是默认进行消费的工具类，类图如下： public DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook, AllocateMessageQ...

Read More →
#RocketMQ

NameServer源代码分析

· 消息队列

NameServer源代码分析 周末继续阅读RocketMq的学习,在上周已经简单的把RocketMq的安装和使用学习了一下。本周主要来看一下NameServer的源代码和设计 NameServer启动 NamesrvController启动 public static NamesrvController main0(String[] args) { try {...

Read More →
#RocketMQ

RocketMQ组件

· 消息队列

RocketMQ组件 RocketMQ简单的看是由四个组件构成的，分别是NameServe、Broker、Producer、consumer这四个组件构成的; 一个简单的执行过程是: consumer通过向NameServer询问具体的Topic所在的Broker地址 consumer通过向Broker保持长连接的形式，获取到信息 同一组下的consumer会向broker中的不同Message...

Read More →
#RocketMQ