1、下载rocketmq编译后的二进制文件

http://rocketmq.apache.org/release_notes/release-notes-4.3.2/ 下载rocketmq-all-4.3.2-bin-release.zip

解压到D:\rocketmq-all-4.3.2-bin-release 并且配置环境变量

RocketMq Windows下配置(编译后的二进制文件)

ROCKETMQ_HOME : D:\rocketmq-all-4.3.2-bin-release

2、启动

  2.1启动namesrv

  在D:\rocketmq-all-4.3.2-bin-release\bin下运行 mqnamesrv.cmd

  成功后如图:(成功后不要关闭该终端)

RocketMq Windows下配置(编译后的二进制文件)

  2.2启动broker(成功后不要关闭该终端)

  进入bin目录,set NAMESRV_ADDR=127.0.0.1:9876设置环境变量,mqbroker启动broker

RocketMq Windows下配置(编译后的二进制文件)

3、demo项目

项目地址:https://github.com/liyanlei58/rocketmq_demo

拉下来后在 com.lyl.mq.test下的Producer以及PushCustomer

运行Producer主类,发送消息

运行PushCustomer主类 接受消息

RocketMq Windows下配置(编译后的二进制文件)

 

相关文章: