·定时消息、消息过滤等实现原理。 ·如何进行网络编程（Netty 实战）? 下定决心后便开始了我的源码分析 RocketMQ 之旅，大概在 4 个多月的时间中连续发表了 30 余篇文章，从 Nameserver、消息发送高可用设计、消息存储、消息消费、消息过滤、事务消息等各个方面对其进行了体系化的剖析，边写边分享，边分享边传播，终于得到了机械工业出版社华章分社的杨福川老师的认可，邀请我出书。 在 p10_1.jpg) 在 RocketMQ 主要的组件如下: ### 1. Nameserver Nameserver 集群，topic 的路由注册中心，为客户端根据 Topic 提供路由服务，从而引导客户端向 Broker 发送消息。Nameserver 之间的节点不通信。路由信息在 Nameserver 集群中数据一致性采取的最终一致性。 ### 2. Broker 消息存储服务器，分为两种角色：Master 服务器每隔 30s 会向 Nameserver 发送心跳包，心跳包中会包含存在在 Broker 上所有的 topic 的路由信息。 ### 3. Client 消息客户端，包括 Producer(消息发送者)和 Consumer(消费消费者). 客户端在同一时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。

APACHE ROCKETMQ 在 EC2 上部署所在目录说明：.....13 Nameserver :.....13 Broker:.....13 如何使用浏览器查看 APACHE ROCKETMQ 的 WEB CONSOLE.....14 如何登录 APACHE ROCKETMQ 的 NAMESERVER 和 BROKER NODE ?.....17 ## 背景介绍 Apache RocketMQ 的组件，并提示 您目前现有的配置。 按照默认 RocketMQ 的部署参数部署完成后，该方案会在用户的 AMAZON WEB SERVICES account 下部署如下的一个架构，包含两个 Nameserver 互为备份，三个 Broker Instance 每个 Broker Instance 上面启动三个 Broker 实例，每个 Broker 实例会在三个 Broker Instance 之间形成一个基于 tr>15Number of Apache RocketMQ NameServer Cluster NodeNameServerClusterCount2选择部署Apache RocketMQ Nameserver节点的数量。16Number of Apache

APACHE ROCKETMQ 在 EC2 上部署所在目录说明： ..... 15 Nameserver ..... 15 Broker ..... 16 如何使用浏览器查看 APACHE ROCKETMQ 的 WEB CONSOLE ..... 16 如何登录 APACHE ROCKETMQ 的 NAMESERVER 和 BROKER NODE? ..... 20 ## 背景介绍 Apache 中，将跳过 (不创建) 带有星号 (*) 的组件，并提示 您目前现有的配置。 按照默认 RocketMQ 的部署参数部署完成后，该方案会在用户的亚马逊云科技账户下部署如下的一个架构，包含两个 Nameserver 互为备份，三个 Broker Instance 每个 Broker Instance 上面启动三个 Broker 实例，每个 Broker 实例会在三个 Broker Instance 之间形成一个基于 tr>15Number of Apache RocketMQ NameServer Cluster NodeNameServerClusterCount2选择部署 Apache RocketMQ Nameserver 节点的数量。16Number of Apache

IP 地址对应于正确的组件。 a. 对 Kubernetes API 记录名称执行查找。检查结果是否指向 API 负载均衡器的 IP 地址： $ dig +noall +answer @<nameserver_ip> api..   将 <nameserver_ip> 替换为名称服务器的 IP 地址， 替换为集群名称， 替换为您的基域名。 ## 输出示例 api.ocp4.example.com 192.168.1.5 b. 对 Kubernetes 内部 API 记录名称执行查找。检查结果是否指向 API 负载均衡器的 IP 地址： $ dig +noall +answer @<nameserver_ip> api-int.. ## 输出示例 api-int.ocp4.example.com. 0 IN A 192.168.1.5

地址是否与正确的组件对应。 a. 对 Kubernetes API 记录名称执行查询。检查结果是否指向 API 负载均衡器的 IP 地址： $ dig +noall +answer @<nameserver_ip> api..  将 <nameserver_ip> 替换为 nameserver 的 IP 地址， 替换为您的集群名称， 替换为您的基本域名。nameserver_ip>nameserver_ip> ## 输出示例 api 192.168.1.5 b. 对 Kubernetes 内部 API 记录名称执行查询。检查结果是否指向 API 负载均衡器的 IP 地址： $ dig +noall +answer @<nameserver_ip> api-int.. ## 输出示例 api-int.ocp4.example.com. 0 IN A 192.168.1.5

• Mac OS 地址：192.168.166.20 • Cent OS 地址：192.168.166.206 保证两台电脑在同一网段，端口是通的，可以关闭防火墙 需要开放的端口：NameServer的9876端口、Broker的10911、11011、10909、11009端口 ## Mac OS rocketmq配置文件 ### 1、 编辑 conf/2m-2s-async/broker-a 刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘 flushDiskType=ASYNC_FLUSH # broker对外服务的监听端口 listenPort=10911 # nameServer地址，如果name server是多台集群的话，就用分号分隔 namesrvAddr=192.168.166.20:9876;192.168.166.20:9876 # 每个topic对应 刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘 flushDiskType=ASYNC_FLUSH # broker对外服务的监听端口 listenPort=11011 # nameServer地址，如果name server是多台集群的话，就用分号分隔 namesrvAddr=192.168.166.20:9876;192.168.166.206:9876 # 存储路径 s

分区迁移时，会导致网络风暴，耗时极长 ## 问题重点 Producer 在主节点宕机时，备节点要有自动切换为主的能力 • 容量调整时，不能产生数据迁移，且要在秒级完成 Route Discovery NameServer Cluster Send/ Receivice Message Client Cluster Route Discovery Raft CommitLog ![Image]( 'X-API-KEY: YOUR_KEY' -X PUT -d "plugins": { "rocketmq-producer": { "nameserver_list": ["127.0.0.1:9876"] } } "uri": "/rocketmq/producer/*" $ 'X-API-KEY: YOUR_KEY' -X PUT -d "plugins": { "rocketmq-consumer": { "nameserver_list": ["127.0.0.1:9876"], "cosumer_group": "test_group" }

内核参数。 下表描述了如何为实时 ISO 安装使用 ip=、nameserver= 和 bond= 内核参数。  ## 注意 在添加内核参数时顺序非常重要：ip=，nameserver=，然后 bond=。nameserver=<dns\_ip>)。这个示例设置： ·节点的IP地址为10.10.10.2 ·网关地址为10.10.10.254 ·子网掩码为255.255.255.0 ·主机名为core0 100:enp2s0在网络接口中配置VLAN并使用DHCP：ip=enp2s0.100:dhcpvlan=enp2s0.100:enp2s0| |您可以为每个服务器添加一个nameserver=条目来提供多个DNS服务器。|nameserver=1.1.1.1nameserver=8.8.8.8| |可选：使用bond=选项支持将多个网络接口绑定到一个接口。在这两个示例中：•配置绑定接口的语法为：bond=name\[:n

the proper persistent way to do DNS client configuration is in a following section. nameserver 8.8.8.8 nameserver 8.8.4.4 If you no longer need this configuration and wish to purge all IP configuration - Nameserver Address Nameserver Addresses represent the IP addresses of Domain Name Service (DNS) systems, which resolve network hostnames into IP addresses. There are three levels of Nameserver Addresses Addresses, which may be specified in order of precedence: The Primary Nameserver, the Secondary Nameserver, and the Tertiary Nameserver. In order for your system to be able to resolve network hostnames into

_3.jpg) ## MDS各个组件 MDS是中心节点，负责元数据管理、集群状态收集与调度。MDS包含以下几个部分： • Topology: 管理集群的 topo 元数据信息。 • Nameserver: 管理文件的元数据信息。 • Copyset: 副本放置策略。 - Heartbeat: 心跳模块。跟chunkserver进行交互，收集chunkserver上的负载信息、copyset信息等。 [Image](/uploads/documents/9/a/6/0/9a607d6baa2cd17132b07c4565d2aeff/p8_3.jpg) ## NAMESERVER NameServer管理namespace元数据信息，包括（更具体的信息可以查看curve/proto/nameserver2.proto）： • FileInfo: 文件的信息。 • PageFileSegment: segment是给文件分配空间的最小单位。 .........chunk64NsegmentN ## NAMESERVER Namespace的文件的目录层次关系如右图。 文件的元数据以KV的方式存储。 • Key: ParentID + “/” + BaseName; • Value: 自身的文件ID。