B站全套最详细的RocketMQ核心源码剖析教程(RocketMQ分布式消息中间

P4-RocketMQ_1_快速实战3
rocketmq的安装,只依赖jdk
最核心的是broken,实际处理业务的组件,包括消息的存储、转发都是通过broken进行
NameServer是保存broken的路由信息,包括服务IP、端口,以及上下线的情况,类似微服务里的注册中心。因为broken是集群,服务可能会有变动,要能实现动态扩容、服务宕机要能感知。这就需要NameServer保存和更新这些信息
Producer(生产者)和Comsumer(消费者)都相当于客户端,交互的时候,只需要和NameServer打交道。通过nameserver找到某1个存活broken的,Producer向broken发送消息,Comsumer接收broken的消息。
先启动NameServer,再启动Broken