1. 按官方说明用 docker 部署 rocketmq ,启动 broker 报错:
明:Broker上的FilterServer列表,消息过滤服务器列表,后续介绍Consumer时会介绍,consumer拉取数据是通过filterServer拉取,consumer向Broker注册。
实际路由注册是在org.apache.rocketmq.broker.out.BrokerOuterAPI#registerBrokerAll中实现,核心代码如下:
NameServer作为一个轻量级的注册中心,主要是为消息生产者和消费者提供Topic的路由信息,并对这些路由信息和Broker节点进行管理,主要包括路由注册、路由剔除和路由发现。...
既然是源码解读,那么我们先来看下代码入口:org.apache.rocketmq.namesrv.NamesrvStartup#main(String[] args),实际调用的是main0()方法,
金三银四,很多人都准备跳槽面试,我这里梳理下自己准备社招面试时的一些经验,给需要的人,希望能帮到大家,祝大家拿到满意的offer。
org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration// 根据注解查找所有bean@Overridepublic void afterSingletonsInstantiated() { Map<String, Ob...
一次RPC变成两次RPC、内容存储和择机投递;基于消息的通信模式,从关注处理到关注通知。