自动创建，但新创建的 Topic 的路由信息只包含在其中一台 Broker 服务器上，这是为什么呢？ 期望值：为了消息发送的高可用，希望新创建的 Topic 在集群中的每台 Broker 上创 建对应的队列，避免 Broker 的单节点故障。 现象截图如下： Broker 集群信息 自动创建的 topicTest5 的路由信息： topicTest5 只在 broker-a 服务器上创建了队列，并没有在 distribution/conf/logback_namesrv.xml 文件拷贝到【Step2】中设置 的主目录下,执行后的效果如下图所示： 温馨提示：该文件为 nameserver 的日志路劲，可以手动修改 logback_namesrv.x ml 文件中的日志目录，由于这是 logback 的基础知识，这里就不再详细介绍 logback 的 配置方法。 Step4：以 debug 方法运行 HA 核心工作机制 < 44 2. 消息消费进度同步机制 从上面内容可知，主从同步引入的主要目的就是消息堆积的内容默认超过物理内存的 40%，则消息读取则由从服务器来接管，实现消息的读写分离，避免主服务 IO 抖动严重。 那问题来了，主服务器宕机后，从服务器接管消息消费后，那消息消费进度存储在哪里？当 主服务器恢复正常后，消息是从主服务器拉取还是从从服务器拉取？主服务器如何得知最新 的消息消费进度呢？

二：NettyRemotingServer Remoting 服务端实现 broker 启动初始化 NettyRemotingServer ， 向 netty 注册 handler NettyEncoder 协议编码器，将 RemotingCommand 转换为字节，给 netty 传输 NettyDecoder 协议解码器， 将 netty 接收的输入流，转换成 RemotingCommand Nett , sendMessageExecutor) 三：NettyRemotingClient 向 netty 注册 handler NettyEncoder 协议编码器，将 RemotingCommand 转换为字节，给 netty 传输 NettyDecoder 协议解码器， 将 netty 接收的输入流，转换成 RemotingCommand N 四：底层传输协议 RocketMq 服务器与客户端通过传递 RemotingCommand 来交互，通过 NettyDecoder， NettyEncoder 对 RemotingCommand 进行协议的编码与解码 协议格式

1 2

............................................................................. 46 14.5 利用服务器消息过滤，避免多余的消息传输 ........................................................................................... ，但是牺牲了分布式 Failover 特性，即 Broker 集群中只 要有一台机器丌可用，则整个集群都丌可用，服务可用性大大降低。 如果服务器部署为同步双写模式，此缺陷可通过备机自劢切换为主避免，丌过仍然会存在几分钟的服务丌 可用。（依赖同步双写，主备自劢切换，自劢切换功能目前迓未实现） 目前已知的应用只有数据库 binlog 同步强依赖严格顺序消息，其他应用绝大部分都可以容忍短暂乱序，推 (5)、(6)属亍单点故障，丏无法恢复，一旦収生，在此单点上的消息全部丢失。RocketMQ 在返两种情冴下，通 过异步复制，可保证 99%的消息丌丢，但是仍然会有极少量的消息可能丢失。通过同步双写技术可以完全避免单点， 同步双写势必会影响性能，适合对消息可靠性要求极高的场合，例如不 Money 相关的应用。 RocketMQ 从 3.0 版本开始支持同步双写。 4.7 Low Latency Messaging