安装

下载

http://rocketmq.apache.org/dowloading/releases/

安装

  • 把下载的安装包扔到自己的虚拟机上,解压

目录介绍

  • bin:启动的脚本,包括shell脚本和CMD脚本
  • conf:配制文件,包括broker配置文件
  • lib:依赖的jar包,Netty,commons-lang,FastJson等

启动MQ

  • 启动NameServer

启动NameServer
nohup sh bin/mqnameserv &
查看启动日志
tail -f ~/log/rocketmqlogs/namesrv.log

  • 启动Broker

启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
查看启动日志
tail -f ~/log/rocketmqlogs/broker.log

  • 可能存在的问题:RocketMq默认的虚拟机内存较大,启动Broker如果因为内存不足失败,
    编辑以下两个配置文件,修改jvm大小

vi runbroker.sh
vi runserver.sh

  • 可以修改为

JAVA_OPT="${JAVE_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

测试

  • 发送消息

设置环境变量
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

关闭

  • 关闭NameServer

sh /bin/mqshutdown namesrv

  • 关闭Broker

sh bin/mqshutdown broker