这节主要讲述RocketMQ的整体架构,和常用术语解释。当我们接触一个新东西的时候,一定要知道他的原理,只有知道原理之后,才会产生问题。只有带着问题去读源码才会事半功倍。
首先盗用官方的一张图片:(官方地址:http://rocketmq.apache.org/)
NameServer:从上图可以清楚的看到NameServer主要干了两件事情,服务发现和路由。如果你知道zookeeper就可以很好理解NameServer了。NameServer就是一个轻量级的zookeeper。多个NameServer可以横向扩展,且它们之间没有任何通信。
Broker:Broker是RocketMQ的核心组成部分,通过轻量级的Topic和队列机制来维护消息存储,Broker支持消息Push和Pull模式。支持千亿级别的消息堆积能力,总之很强大。
Producer:顾名思义生产者,Producer去NameServer获取Broker列表,进行轮询发送消息。每个生产者都有一个ID(编号),多个生产者实例可以共用同一个ID。同一个ID下所有实例组成一个生产者集群。
Consumer:顾名思义消费者,Consumer去NameServer获取Broker列表,进行消息消费,支持Push和Pull两种模式。每个订阅者也有一个ID(编号),多个消费者实例可以共用同一个ID。同一个ID下所有实例组成一个消费者集群。
源码模块说明(RokcetMQ版本4.3.1):
rocketmq-broker:服务端,接受消息,存储消息,consumer拉取消息
rocketmq-client:消息发送和接收,包含consumer和producer
rocketmq-common:通用的枚举、基类方法、或者数据结构,包名有admin、consumer、filter、hook、message
rocketmq-distribution:脚本、配置模块,RocketMQ编译时,bin目录,benchmark目录,conf目录都是从这个模块编译输出的
rocketmq-example:示例模块
rocketmq-filter:消息过滤器
rocketmq-logappender:日志
rocketmq-logging:日志
rocketmq-namesrv:NameServer,类似服务注册中心,broker在这里注册,consumer和producer在这里找到broker地址
rocketmq-openmessaging:RocketMQ支持openmessaging,详见:http://openmessaging.cloud
rocketmq-remoting:使用netty的客户端、服务端,使用fastjson序列化,自定义二进制协议
rocketmq-srvutil:只有一个ServerUtil类,只提供Server程序依赖,尽可能减少客户端依赖
rocketmq-store:消息存储,索引,consumerLog,commitLog等
rocketmq-tools:命令行工具
原文地址:https://www.cnblogs.com/shileibrave/p/9883817.html