按照书上的记录,作为一个最小单元的MQ的流程启动
1.导入源码
直接从git上拉取,从idea上打包生成就行
https://github.com/apache/rocketmq
那么,我们的顺序如下:
1.启动NameServer
首先是配置环境变量
Environment设置好了之后,要求目录下有,logs conf store三个文件夹
设置好了后直接启动
2.启动Broker
需要设置环境白能量
和上面一样设置Environment,配置RocketMQ的主目录和broker
外加设置broker的配置文件
配置文件如下:
启动并等待运行成功
3.使用RocketMQ测试是否能够发送
启动org.apache.rocketmq.example.quickstart.Producer
设置对应的NameServer地址
运行后查看发送
对应的Cosumer一样的流程
修改NameSrv的地址即可
运行之后消费数据即可