一、下载源码

地址：https://gitee.com/apache/rocketmq.git

二、删除pom文件下的插件

maven-gpg-plugin       maven-failsafe-plugin

三、配置文件

1、随便一个目录新建一个文件夹，例如：C:\worksapce下新建rocketmq文件夹

2、在rocketmq源码目录下\distribution\conf文件夹下，复制broker.conf、logback_broker.xml、logback_namesrv.xml到新建的文件夹下

3、修改broker.conf文件

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
#nameServer地址，分号分割 
namesrvAddr=127.0.0.1:9876
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
#存储路径
storePathRootDir=C:\\worksapce\\rocketmq\\store
#commitLog 存储路径
storePathCommitLog=C:\\worksapce\\rocketmq\\store\\commitlog
#消费队列存储路径
storePathConsumeQueue=C:\\worksapce\\rocketmq\\store\\consumequeue
#消息索引存储路径
storePathIndex=C:\\worksapce\\rocketmq\\store\\index
#checkpoint文件存储路径 
storeCheckpoint=C:\\worksapce\\rocketmq\\store\\checkpoint
#abort文件存储路径 
abortFile=C:\\worksapce\\rocketmq\\store\\abort

4、修改logback_broker.xml、logback_namesrv.xml，将{user.home}替换为新建文件夹的绝对路径，本文中是C:/worksapce/rocketmq

四、启动server

找到启动类NamesrvStartup，配置启动环境参数

Environment variables

ROCKETMQ_HOME=C:\worksapce\rocketmq

debug启动，看到The Name Server boot success. serializeType=JSON表示启动成功

五、启动broker

找到启动类BrokerStartup，配置环境参数

Program arguments

-c C:\worksapce\rocketmq\conf\broker.conf

Environment variables

ROCKETMQ_HOME=C:\worksapce\rocketmq

debug启动，看到The broker[broker-a, 172.16.232.233:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876表示启动成功

六、启动生产者

quickstart包下Producer类添加以下代码

        producer.setNamesrvAddr("127.0.0.1:9876");

启动Producer的main方法往MQ Server中发送消息

七、消费消息

quickstart包下Consumer类添加以下代码

        consumer.setNamesrvAddr("127.0.0.1:9876");

启动Consumer的main方法消费消息