定时消息、消息过滤等实现原理。  如何进行网络编程（Netty 实战）？ 下定决心后便开始了我的源码分析 RocketMQ 之旅，大概在 4 个多月的时间中连续 发表了 30 余篇文章，从 Nameserver、消息发送高可用设计、消息存储、消息消费、消 息过滤、事务消息等各个方面对其进行了体系化的剖析，边写边分享，边分享边传播，终于 得到了机械工业出版社华章分社的杨福川老师的认可，邀请我出书。 一、RocketMQ 部署架构 在 RocketMQ 主要的组件如下： 1. Nameserver Nameserver 集群，topic 的路由注册中心，为客户端根据 Topic 提供路由服务，从 而引导客户端向 Broker 发送消息。Nameserver 之间的节点不通信。路由信息在 Nameserver 集群中数据一致性采取的最终一致性。 2. Broker 消息存储服务器，分为两种角色：Master RocketMQ 中，主服务承担读写操作，从服务器作为一个备份，当主服务器存 在压力时，从服务器可以承担读服务（消息消费）。所有 Broker，包含 Slave 服务器每隔 30s 会向 Nameserver 发送心跳包，心跳包中会包含存在在 Broker 上所有的 topic 的路 由信息。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 11 > 1.1 RocketMQ

ROCKETMQ 在 EC2 上部署所在目录说明： ..................................................................... 15 Nameserver .............................................................................................. WEB CONSOLE ....................................................... 16 如何登录 APACHE ROCKETMQ 的 NAMESERVER 和 BROKER NODE？ ........................................... 20 Page 3 of 21 (不创建) 带有星号（*）的组件，并提⽰ 您⽬ 前现有的配置。 按照默认 RocketMQ 的部署参数部署完成后，该方案会在用户的亚马逊云科技账户下 部署如下的一个架构，包含两个 Nameserver 互为备份，三个 Broker Instance 每个 Broker Instance 上面启动三个 Broker 实例，每个 Broker 实例会在三个 Broker Instance

的记录名称、通配符路由和集群节点运行 DNS 查找。验证 响应中包含的 IP 地址对应于正确的组件。 a. 对 Kubernetes API 记录名称执行查找。检查结果是否指向 API 负载均衡器的 IP 地址： 将 <nameserver_ip> 替换为名称服务器的 IP 地址， 替换为集群名 称， 替换为您的基域名。 输出示例 出示例 b. 对 Kubernetes 控制台的路由： 输出示例 出示例 $ dig +noall +answer @<nameserver_ip> api.. 1 api.ocp4.example.com. 0 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> api-int.. 168.1.5 $ dig +noall +answer @<nameserver_ip> random.apps.. random.apps.ocp4.example.com. 0 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> console-openshift-console

DHCP。 重要 重要 添加网络参数时，还必须添加 rd.neednet=1 内核参数。 下表描述了如何为实时 ISO 安装使用 ip= 、nameserver= 和 bond= 内核参数。 注意 注意 在添加内核参数时顺序非常重要： ip=，nameserver=，然后 bond=。 # cp rhcos--live.x86_64.iso bootstrap.ign /mnt/ 描述 例子 例子 要配置一个 IP 地址，可以使用 DHCP(ip=dhcp)或者 设置单独的静态 IP 地址(ip=)。然后在每 个节点上指定 DNS 服务器 IP 地址(nameserver= )。这个示例设置： 节点的 IP 地址为 10.10.10.2 网关地址为 10.10.10.254 子网掩码为 255.255.255.0 主机名为 core0 DNS 服务器地址为 4.4.4.41 ip=10.10.10.2::10.10.10.254:255.255.255.0:co re0.example.com:enp1s0:none nameserver=4.4.4.41 通过指定多个 ip= 条目来指定多个网络接口。 ip=10.10.10.2::10.10.10.254:255.255.255.0:co re0.example.com:enp1s0:none

记录名称执行查询。检查结果是否指向 API 负载均衡器的 IP 地址： 将 <nameserver_ip> 替换为 nameserver 的 IP 地址， 替换为您的集 群名称， 替换为您的基本域名。 $ dig +noall +answer @<nameserver_ip> api.. 1 192.168.1.5 $ dig +noall +answer @<nameserver_ip> api-int.. api-int.ocp4.example.com. 0 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> random.apps.. +answer @<nameserver_ip> console-openshift-console.apps. . console-openshift-console.apps.ocp4.example.com. 0 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> bootstrap

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.properties 刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘 flushDiskType=ASYNC_FLUSH # broker对外服务的监听端口 listenPort=10911 # nameServer地址，如果name server是多台集群的话，就用分号分隔 namesrvAddr=192.168.166.20:9876;192.168.166.206: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 # 每个topic对

应中包含的 IP 地址是否与正确的组件对应。 a. 对 Kubernetes API 记录名称执行查询。检查结果是否指向 API 负载均衡器的 IP 地址： 将 <nameserver_ip> 替换为 nameserver 的 IP 地址， 替换为您的集 群名称， 替换为您的基本域名。 输 输出示例 出示例 b. 对 Kubernetes 输 输出示例 出示例 $ dig +noall +answer @<nameserver_ip> api.. 1 api.ocp4.example.com. 604800 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> api-int.. api-int.ocp4.example.com. 604800 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> random.apps.. OpenShift Container Platform 4.14 安装 安装 1762 1 2 注意 注意

应中包含的 IP 地址是否与正确的组件对应。 a. 对 Kubernetes API 记录名称执行查询。检查结果是否指向 API 负载均衡器的 IP 地址： 将 <nameserver_ip> 替换为 nameserver 的 IP 地址， 替换为您的集 群名称， 替换为您的基本域名。 输出示例 出示例 b. 对 Kubernetes 输出示例 出示例 $ dig +noall +answer @<nameserver_ip> api.. 1 api.ocp4.example.com. 604800 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> api-int.. api-int.ocp4.example.com. 604800 IN A 192.168.1.5 $ dig +noall +answer @<nameserver_ip> random.apps.. OpenShift Container Platform 4.13 安装 安装 1690 1 2 注意 注意

k>:::none nameserver=srv1 [nameserver=srv2 [nameserver=srv3 [...]]]" $ export IPCFG="ip=192.168.100.101::192.168.100.254:255.255.255.0:::none nameserver=8.8.8.8" $ govc vm.change -vm k>:::none nameserver=srv1 [nameserver=srv2 [nameserver=srv3 [...]]]" $ export IPCFG="ip=192.168.100.101::192.168.100.254:255.255.255.0:::none nameserver=8.8.8.8" $ govc vm.change -vm k>:::none nameserver=srv1 [nameserver=srv2 [nameserver=srv3 [...]]]" $ export IPCFG="ip=192.168.100.101::192.168.100.254:255.255.255.0:::none nameserver=8.8.8.8" $ govc vm.change -vm

DHCP。 重要 重要 添加网络参数时，还必须添加 rd.neednet=1 内核参数。 下表描述了如何为实时 ISO 安装使用 ip= 、nameserver= 和 bond= 内核参数。 注意 注意 在添加内核参数时顺序非常重要： ip=，nameserver=，然后 bond=。 ISO 的路由和 的路由和绑定 定选项 下表提供了配置 Red Hat Enterprise Linux C 描述 例子 例子 要配置一个 IP 地址，可以使用 DHCP(ip=dhcp)或者 设置单独的静态 IP 地址(ip=)。然后在每 个节点上指定 DNS 服务器 IP 地址(nameserver= )。这个示例设置： 节点的 IP 地址为 10.10.10.2 网关地址为 10.10.10.254 子网掩码为 255.255.255.0 主机名为 core0 DNS 服务器地址为 4.4.4.41 ip=10.10.10.2::10.10.10.254:255.255.255.0:co re0.example.com:enp1s0:none nameserver=4.4.4.41 Files bootstrap.ign and mybootstrap.ign are identical # ./coreos-installer iso ignition