4. 启动集群并测试发送、消费
- 启动namesrv。
cd /tiger/rocketmq/namesrv1 nohup sh bin/mqnamesrv &
- 启动broker
cd /tiger/rocketmq/broker1 nohup sh bin/mqbroker -n localhost:9876 &
- check namesrv和broker进程启动是否正常:
ps -ef | grep rocketmq
- 发送、消费消息来验证集群是否正常
- 设置namesrv环境变量：
export NAMESRV_ADDR=localhost:9876
- 进入broker根目录
cd /tiger/rocketmq/broker1
- 发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
- 发送成功会打印:
- 消费消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
- 消费成功会打印:
