RocketMQ安装

Posted Lossdate

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RocketMQ安装相关的知识,希望对你有一定的参考价值。

一、 环境

  1. RocketMQ: 4.5.1
    https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip

二、安装

  1. 下载rocketmq
    4.5.1

    wget https://archive.apache.org/dist/rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip
    
  2. 解压

    unzip rocketmq-all-4.5.1-bin-release.zip -d /opt
    cd /opt/
    mv rocketmq-all-4.5.1-bin-release/rocketmq
    cd rocketmq/
    
  3. 配置环境变量

    vim /etc/profile
    
    export ROCKET_HOME=/opt/rocketmq
    export PATH=$PATH:$ROCKET_HOME/bin
    
  4. 生效配置

    . /etc/profile
    
  5. 修改脚本
    rocketmq默认需要4G空间,虚拟机搭建可以修改小点
    bin/runserver.sh
    bin/runbroker.sh
    例:

    #虚拟机内存比较小,由4G改为256M
    JAVA_OPT="$JAVA_OPT -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=64mm -XX:MaxMetaspaceSize=160mm"
    

    jdk如果是8以上,则需要修改以下脚本
    1)bin/runserver.sh

    cd /opt/rocketmq/
    vim bin/runserver.sh
    
    #删除 
    UseCMSCompactAtFullCollection 
    UseParNewGC 
    UseConcMarkSweepGC
    #虚拟机内存比较小,由4G改为256M
    JAVA_OPT="$JAVA_OPT -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=64mm -XX:MaxMetaspaceSize=160mm"
    -Xloggc修改为-Xlog:gc
    

    2)bin/runbroker.sh

    cd /opt/rocketmq/
    vim bin/runbroker.sh
    
    #删除
    PrintGCDateStamps 
    PrintGCApplicationStoppedTime 
    PrintAdaptiveSizePolicy 
    UseGCLogFileRotation 
    NumberOfGCLogFiles=5 
    GCLogFileSize=30m
    

    3)bin/tools.sh

    cd /opt/rocketmq/
    vim bin/tools.sh
    
    #删除 
    JAVA_OPT="$JAVA_OPT -Djava.ext.dirs=$BASE_DIR/lib:$JAVA_HOME/jre/lib/ext"
    
  6. 测试(jdk8以上测试修改脚本)

    mqnamesrv
    

    mqbroker -n localhost:9876
    

  7. 启动

    #启动NameServer 
    mqnamesrv 
    
    #新开窗口
    #启动Broker 
    mqbroker -n localhost:9876 
    
  8. 启用SQL92消息过滤 (可选)

    cd /opt/rocketmq/conf/
    vim broker.conf
    #启用SQL92消息过滤
    enablePropertyFilter=true
    
    #生效配置
    mqbroker -c /opt/rocketmq/conf/broker.conf -p | grep -i propertyfilter
    #启动broker
    mqbroker -n localhost:9876 -c /opt/rocketmq/conf/broker.conf 
    

三、RocketMQ环境测试

  1. 接收消息
    #设置环境变量 
    export NAMESRV_ADDR=localhost:9876 
    #接收消息 
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
    
  2. 发送消息
    #设置环境变量 
    export NAMESRV_ADDR=localhost:9876 
    #使用安装包的Demo发送消息
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    
  3. 关闭
    #依次停止broker和namesrv
    mqshutdown broker
    mqshutdown namesrv
    
  4. etc
    #查看主题
    mqadmin topicList -n localhost:9876
    #创建主题
    mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t tp_demo -w 6
    #查看broker名
    mqbroker -p
    #创建主题,88读
    mqadmin updateTopic -b nodeA:10911 -n localhost:9876 -r 8 -t tp_demo -w 8
    #删除主题的操作
    mqadmin deleteTopic -c DefaultCluster deleteTopic -n localhost:9876 -t tp_demo
    #主题描述
    mqadmin topicStatus -n localhost:9876 -t tp_demo
    

四、可视化工具 rocketmq-console

  1. 下载地址
    https://github.com/apache/rocketmq-externals/archive/rocketmq-console-1.0.0.zip
  2. 编译
    IDEAD导入,JDK选择1.8
    properties修改namesrvAddr
    rocketmq.config.namesrvAddr=nodeA:9876
    
    打包
    mvn clean package -DskipTests
    
  3. 启动
    通过cmd启动
    java -jar rocketmq-console-ng-1.0.0.jar
    
    访问http://localhost:8080/

以上是关于RocketMQ安装的主要内容,如果未能解决你的问题,请参考以下文章

Windows安装RocketMQ,RocketMQ Windows安装和使用

centos 7 安装rocketmq

RocketMQ安装

RocketMQ安装

RocketMQ安装

RocketMQ 安装与配置(单实例)