1.下载 RocketMQ 并运行
.1 安装条件
64bit OS, Linux/Unix/Mac is recommended;(Windows user see guide below)
64bit JDK 1.8+;
Maven 3.2.x;
Git;
4g+ free disk for Broker server
由于笔者 Linux 内网的测试机器内存不足 4G,所以选择在本地 Windows 系统搭建
1.2 编译好的 mq 工具下载地址:
1.3 配置环境变量
类似 Java 环境变量,配置 ClassPath 一样,配置
ROCKETMQ_HOME="D:\rocketmq"
1.4 开启 Name Server
.\bin\mqnamesrv.cmd
结果如图:

1.5 开启 Broker
注意:内存需要超过 4G,哈哈~
.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
结果:

1.6 启动自带的模拟工具
.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer
结果:

纳尼?报错了,照着 guide 来还会报错?看了下,应该是远程链接失败,就是 ip 端口没配置。带着猜测,我反编译了 lib 包下面的 rocketmq-example-4.7.1.jar,
找到org.apache.rocketmq.example.quickstart,看了代码,少了配置 ip 端口的代码,即少了producer.setNamesrvAddr("localhost:9876;localhost:9876");暂时放着,后面下载源码再试
2.下载源码
2.1 源码下载地址:
2.2Eclipse 打开项目
build 过程参考 mater 文件夹下的 BUILDING 文件,成功导入 eclipse 即为如下结果

3.运行示例代码
注意,需要把源码里面注释的 consumer.setNamesrvAddr("localhost:9876;localhost:9876");打开,否则会报错
照着示例一个一个跑,大同小异!
下一篇文章玩一下可视化界面
|