快速导航
RocketMQ入门和基本搭建
MQ优点和缺点
下载安装
- 下载二进制版本
- 将二进制包和jdk提前准备好
- 启动Nameserver
nohub sh /bin/mqnamesrv &
查看日志启动成功
- 启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
查看到broker使用虚拟机内存比较大,因为内存不足,需要
修改java启动脚本,改为256m
停止broker和namesrv sh mqshutdown broker|namesrv
再次启动broker,即可查看到broker启动成功
测试rockerMQ是否安装成功
- 打开2个客户端窗口
- 生产者窗口使用
设置环境变量
export NAMESRV_ADDR=localhost:9876
使用安装包中的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer生产者发送消息
- 消费者窗口使用
设置环境变量
export NAMESRV_ADDR=localhost:9876
接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer消费者接收消息 - 消费者窗口接收的消息
停止RocketMQ
- sh mqshutdown broker 关闭broker
- sh mqshutdown namesrv 关闭namesrv
