RocketMQ系列(七)：RocketMQ源码分析一

前言

本文是基于rocketmq4.7.1源码的namesrcv、broker启动，简单的消息发送和接受测试

一、源码下载并导入

1.下载源码
github地址: https://github.com/apache/rocketmq
2.导入idea

1. 在根目录下创建conf文件夹
2. 复制distribution项目下conf文件里面的broker.conf、logback_broker.xml、logback_namesrv.xml文件
3. 粘贴到1中新建的conf

3.在根目录下Terminal窗口执行mvn install -Dmaven.test.skip=true

二、启动namesrv

在namesrv项目下NamesrvStartup类中执行main方法

二、启动broker

1.指定broker配置文件：


2.修改配置文件
添加:

autoCreateTopicEnable=true
namesrvAddr=192.168.1.170:9876
#ip
brokerIP1=192.168.1.170

3.启动
在broker项目下BrokerStartup类中执行main方法

三、启动Producer

在example项目下quickstart包中Producer类下
1.添加代码

producer.setNamesrvAddr("192.168.1.170:9876");

2.执行main方法

四、启动Consumer

在example项目下quickstart包中Consumer类下
1.添加代码

consumer.setNamesrvAddr("192.168.1.170:9876");

2.执行main方法