最新 最热

路由注册是通过Broker和NameServer之间的心跳功能来实现

明:Broker上的FilterServer列表,消息过滤服务器列表,后续介绍Consumer时会介绍,consumer拉取数据是通过filterServer拉取,consumer向Broker注册。

2021-09-26
0

实际路由注册是在org.apache.out.BrokerOuterAPI#registerBrokerAll中实现

实际路由注册是在org.apache.rocketmq.broker.out.BrokerOuterAPI#registerBrokerAll中实现,核心代码如下:

2021-09-26
0

分析NameServer是如何进行路由信息管理的

NameServer作为一个轻量级的注册中心,主要是为消息生产者和消费者提供Topic的路由信息,并对这些路由信息和Broker节点进行管理,主要包括路由注册、路由剔除和路由发现。...

2021-09-24
1

NameServer到底是如何启动的呢?

既然是源码解读,那么我们先来看下代码入口:org.apache.rocketmq.namesrv.NamesrvStartup#main(String[] args),实际调用的是main0()方法,

2021-09-24
0

这份程序猿社招准备花了我一周时间

金三银四,很多人都准备跳槽面试,我这里梳理下自己准备社招面试时的一些经验,给需要的人,希望能帮到大家,祝大家拿到满意的offer。

2021-04-26
1

RocketMQ RocketMQMessageListener注解自动配置源码

org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration// 根据注解查找所有bean@Overridepublic void afterSingletonsInstantiated() { Map<String, Ob...

2021-03-02
1

RocketMq消息中间件及分布式事务消息实现原理

一次RPC变成两次RPC、内容存储和择机投递;基于消息的通信模式,从关注处理到关注通知。

2020-02-24
1