Linux下RocketMQ下载安装教程

一,下载安装包

  1.官网地址:http://rocketmq.apache.org/dowloading/releases/

 2.网盘下载:

  链接:https://pan.baidu.com/s/1pir1iAVkAhhaTrT-6Jx2-w
  提取码:m281

二、安装及启动

1、将zip文件上传到linux的~下,然后解压:

  我的安装包放在了/home/RocketMQ    解压:unzip 压缩包名称

    

 2、移动  执行  mv rocketmq-all-4.3.0-bin-release /usr/local/rocketmq 

  

看一下该文件的目录:

   启动NameServer命令(bin目录下)

     启动:nohup sh  mqnamesrv  &

    查看日志:tail -f ~/logs/rocketmqlogs/namesrv.log

   启动Broker命令(bin目录下)

    启动:nohup sh mqbroker -n localhost:9876 &

    查看日志:tail -f ~/logs/rocketmqlogs/broker.log

  关闭RocketMQ命令:(bin目录下)

    关闭NameServer:sh mqshutdown namesrv

    关闭Borker:sh mqshutdown broker

 注意:RocketMQ默认的虚拟机内存比较大,启动Broker如果因为内存不许而失败,需要编辑两个配置文件,修改JVM内存大小。

  编辑runbroker.sh和runserver.sh修改默认JVM的大小

vim runbroker.sh

vim runserver.sh

 3.启动nameserver,在bin目录下执行:nohup sh mqnamesrv &     查看启动是否成功的日志命令:tail -f ~/logs/rocketmqlogs/namesrv.log   打印如下表示启动成功:

 4.启动broker,在bin目录下执行:nohup sh mqbroker -n localhost:9876 &   查看日志命令:tail -f ~/logs/rocketmqlogs/broker.log,打印如下表示启动成功:

 三。测试RocketMQ

  这里我用的是putty来测试,连接两台,一个发送消息,一个接收消息

putty:

  链接:https://pan.baidu.com/s/16huhWIZ7wm9P8Q0t1emcdQ
  提取码:q4j5

  1.发送消息<bin目录>

    设置环境变量:export NAME SRV_ADDR=localhost:9876

     使用安装包demo发送消息:sh tools.sh org.apache.rocketmq.example.quickstart.Producer

  2.接收消息<bin目录>

    设置环境变量:export NAME SRV_ADDR=localhost:9876

     使用安装包demo接收消息:sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

 

 到此,RocketMQ初步完成。。。。。。。。。。。。。

原文地址:https://www.cnblogs.com/yangxiaoli/p/13213712.html