[**Apache RocketMQ**](https://rocketmq.apache.org/)**是一个分布式消息和流媒体平台，具有低延迟、高性能和可靠性、万亿级容量和灵活的可扩展性。** 它提供了多种功能： 1、消息传递模式，包括发布/订阅、请求/回复和流媒体 2、金融级交易消息 3、基于[DLedger的](https://github.com/openmessaging/openmessaging-storage-dledger)内置容错和高可用配置选项 4、多种跨语言客户端，如Java、C/C++、Python、Go 5、可插拔传输协议，例如 TCP、SSL、AIO 6、内置消息追踪能力，也支持opentracing 7、多功能大数据和流媒体生态系统集成 8、按时间或偏移量的消息追溯 9、可靠的 FIFO 和同一队列中的严格有序消息传递 10、高效的拉推式消费模式 11、单个队列百万级消息累积能力 12、多种消息传递协议，如 JMS 和 OpenMessaging 13、灵活的分布式横向扩展部署架构 14、闪电般的批量消息交换系统 15、各种消息过滤机制，如 SQL 和标签 16、用于隔离测试和云隔离集群的 Docker 镜像 17、用于配置、指标和监控的功能丰富的管理仪表板 18、认证和授权 19、免费的开源连接器，用于源和接收器 ### **组件介绍** - nameserv：提供轻量级的服务发现与路由服务，每个名称服务器记录了全部的 broker 的路由信息，并且提供相应的读写服务，支持快速存储扩展。 - borker（master、slave）：broker 集群，broker 通过提供轻量级的主题和队列机制来维护消息存储。它支持推和拉两种模型，包含容错机制（2 个副本或 3 个副本），并提供了强大的平滑峰值，提供积累数以亿计的消息并保证其在原始时间顺序的被消费能力。 - console：RocketMQ Console是RocketMQ 提供的可视化管理工具，方便可视化的操作。 ### **集群部署模式** ### ** 多 master 多 slave 异步复制模式：** - 在多 master 模式的基础上，每个 master 节点都有至少一个对应的 slave。master 节点可读可写，但是 slave 只能读不能写，类似于 mysql 的主备模式。 - **优点**： 在 master 宕机时，消费者可以从 slave读取消息，消息的实时性不会受影响，性能几乎和多 master 一样。 - **缺点**：使用异步复制的同步方式有可能会有消息丢失的问题。 - 2M-2S-SYNC(两主两从异步写) ### 环境变量配置 - master、slave配置参考  ### **登录** - 设置环境变量：USER_LOGIN_ENABLE=true 开关用户登录 - 默认用户：admin，默认密码：admin