标签：文件 配置文件 启动 broker 源码 消息 9876 RocketMq 图文
源码下载
从github官网下载https://github.com/apache/rocketmq
我这里下载的是当前最新代码，4.7.1的版本
导入idea
各个代码包的功能
- acl：权限控制模块
- broker: broker 模块（broke 启动进程）
- client ：消息客户端，包含消息生产者、消息消费者相关类
- common ：公共包
- dev ：开发者信息（非源代码）
- distribution ：部署实例文件夹（非源代码）
- docs：很多官方文档。虽然不是源码，但很重要。强烈建议通读一遍。
- example: RocketMQ 例代码
- filter ：消息过滤相关基础类
- logappender：日志实现相关类
- namesrv：NameServer实现相关类（NameServer启动进程）
- openmessageing：消息开放标准
- remoting：远程通信模块，基于Netty。
- srcutil：服务工具类
- store：消息存储实现相关类
- style：checkstyle相关实现
- test：测试相关类
- tools：工具类，监控命令相关实现类
启动测试环境
编译打包
mvn clean package -Dmaven.test.skip=true启动NameSrv
先启动nameSrv
先建一个conf目录，存放需要的配置文件。
将distribution目录中的broker.conf和logback_broker.xml和logback_namesrv.xml复制过去一份
再配置一下Rocketmq_home环境参数，用来找到配置文件。如果不配置，会启动失败
Please set the ROCKETMQ_HOME variable in your environment to match the location of the RocketMQ installation
启动
成功会打印
The Name Server boot success. serializeType=JSON详细的日志，可以去日志文件中看。大号在logback的配置文件中可以找到。
启动Broker
修改conf文件
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# namesrvAddr地址
namesrvAddr=127.0.0.1:9876
# 自动创建topic，方便测试
autoCreateTopicEnable=true
# 存储路径
storePathRootDir=D:\\github\\rocketmq-master\\dataDir
# commitLog路径
storePathCommitLog=D:\\github\\rocketmq-master\\dataDir\\commitlog配置启动参数
注意，要配置一个-c参数，执行broker的配置文件
启动成功
The broker[broker-a, x.x.x.x:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876此时会产生下列文件
发送消息
在org.apache.rocketmq.example.quickstart包下，有最简单的测试代码。设置topic名为TopicTest
DefaultMQProducer producer = new DefaultMQProducer("my_produce_group_name");
producer.setNamesrvAddr("127.0.0.1:9876");
Message msg = new Message("TopicTest" /* Topic */,
"TagA" /* Tag */,
("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
);执行main方法，可以看到消息发送成功的日志
查看datadir目录，又生成了文件。最重要的就是commitlog和consumequeue
commitlog下的文件，直接就是占1G空间的文件。
并且commitlog文件的命名就是以文件的数据偏移量命名，1G = 1073741824byte
consumequeue下的是以topic名字分组的消费队列进度。文件大小默认是5860KB。
index下是消息索引文件，目的是为了快速定位到消息。大小默认是400M。名字默认是时间戳。
消费消息
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("my_consume_group_name");
consumer.setNamesrvAddr("127.0.0.1:9876")运行main方法，可以看到消息消息掉了。
标签：文件,配置文件,启动,broker,源码,消息,9876,RocketMq,图文 来源： https://blog.csdn.net/woliuqiangdong/article/details/121295330
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。