RocketMq-安装与启动

安装与启动

学习一个技术框架最重要的一步就是让代码跑起来,再带着目的调试感兴趣的特性。

源码获取

可以从github上获取,这里要说明的一点,RocketMq成为Apache顶级项目(版本号4.0.0)后,迁移了源码存放的地址。新的地址是在Apache目录下,之前的代码在这里。在孵化过程中删除了很多注释,使得后者更适合作为学习版本去研究。另外,后者最新代码已经remove了,不过不要紧,我们可以找回有注释的版本。

1
2
3
4
mkdir rocketmq
cd rocketmq
git clone git@github.com:alibaba/rocketmq.git
git reset --hard 390ad33d1ba580cc62d779b4407aa276fd93e1fd

环境部署

  1. 修改install.sh
    • 删除第一行git pull,因为远端代码已经被remove
  2. 执行install.sh
    • sh ./install.sh
    • 执行完会生成/target/alibaba-rocketmq-x.x.x-alibaba-rocketmq/alibaba-rocketmq目录
  3. 设置环境变量
    • export ROCKETMQ_HOME=/Users/xxx/RocketMQ/target/alibaba-rocketmq-x.x.x-alibaba-rocketmq/alibaba-rocketmq
    • export NAMESRV_ADDR=localhost:9876
    • PATH=${PATH}:${ROCKETMQ_HOME}/bin

启动应用

  1. 启动nameserver

    1
    2
    nohup sh mqnamesrv &
    tail -f ~/logs/rocketmqlogs/namesrv.log
  2. 启动broker

    1
    2
    nohup sh mqbroker -n localhost:9876 &
    tail -f ~/logs/rocketmqlogs/broker.log
  3. 调试源码

    • 可以在IDE里调试rocketmq-example里面的源码
    • 也可以命令行中快速测试sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

关闭应用

  1. 关闭nameserver

    sh mqshutdown namesrv

  2. 关闭broker

    sh mqshutdown broker

参考

Apache RocketMQ

作者: wuzhaoyang(John)
出处: http://wuzhaoyang.me/
因为作者水平有限,无法保证每句话都是对的,但能保证不复制粘贴,每句话经过推敲。希望能表达自己对于技术的态度,做一名优秀的软件工程师。