增加如下配 置 10.232.22.67 jmenv.taobao.net 推荐使用 HTTP 静态服务器寻址方式，好处是客户端部署简单，丏 Name Server 集群可以热升级。 11.2 自定义客户端行为 11.2.1 客户端 API 形式 DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsu 项目开源主页：https://github.com/alibaba/RocketMQ 36 Broker 启劢时，如何加载配置 ### 第一步生成 Broker 默讣配置模版 sh mqbroker -m > broker.p ### 第二步修改配置文件, broker.p ### 第三步加载修改过的配置文件 nohup sh mqbroker -c broker.p Broker

2.5 事物消息的 load&recover TransactionStateService.load ()事物状态服务加载， 加载只是建立文件映射 redoLog 队列恢复，加载本地 redoLog 文件 tranStateTable 事物状态表， 加载本地 tranStateTable 文件 recover: 正常恢复： 利用 tranRedoLog 文件的 recover 1. 接收数据向 RouteInfoManager 注册。 Broker 初始化加载本地配置，配置信息是以 json 格式存储在本地， rocketmq 强依赖 fastjson 作转换， RocketMq 通过 ConfigMananger 来管理配置加载以及持久化 1. 加载 topic 配置${user.home}/store/config/topics.json "topicFilterType":"SINGLE_TAG", "topicName":"TopicTest", "writeQueueNums":8 } } } 2. 加载消费进度偏移量 ${user.home}/store/config/consumerOffset.json { "offsetTable":{ ConfigMananger ConsumerOffsetManage

currentTimeMillis()); COUNTER = new AtomicInteger(0); } 从这里可以看出 FIX_STRING 的主要由：客户端的 IP、进程 ID、加载 MessageCl ientIDSetter 的类加载器的 hashcode。 唯一性算法 msgId 的唯一性算法由 MessageClientIDSetter 的 createUniqIDBuffer 方法实现。 private