zoukankan      html  css  js  c++  java
  • Linux系统下安装rocketmq

    参考博客地址:https://blog.csdn.net/qq_21561501/article/details/105684989
    https://www.cnblogs.com/pu20065226/p/11390414.html
    https://www.jianshu.com/p/832693e02429
    https://www.freesion.com/article/1961206550/

    //下载最新的rocketmq
    wget http://apache-mirror.8birdsvideo.com/rocketmq/4.6.0/rocketmq-all-4.6.0-bin-release.zip
    //解压
    unzip rocketmq-all-4.6.0-bin-release.zip
    //切换到mq目录
    cd /usr/local/rocketmq-all-4.6.0-source-release/distribution/target/rocketmq-4.6.0/rocketmq-4.6.0
    vim bin/runserver.sh
    vim bin/runbroker.sh
    //启动Nameserver
    nohup sh bin/mqnamesrv &
    //查看日志
    tail -f ~/logs/rocketmqlogs/namesrv.log
    //启动Broker
    nohup sh bin/mqbroker -n localhost:9876 &
    //查看日志
    tail -f ~/logs/rocketmqlogs/broker.log
    //关闭Nameserver
    sh bin/mqshutdown namesrv
    //关闭Broker
    sh bin/mqshutdown broker
    //jps查看进程号
    先cd / 回到根目录下
    再输入命令:jps
    关闭jar(强制杀死进程):kill -9 进程号
    //发送与接受消息测试(linux端)
    //发送消息(bin目录下)
    export NAMESRV_ADDR=localhost:9876
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    //接收消息(bin目录下)
    export NAMESRV_ADDR=localhost:9876
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer


    RocketMq可视化监控平台搭建
    https://github.com/apache/rocketmq-dashboard
    或者直接下载zip然后上传到服务器,我这里还是放到/usr/local下
    //解压
    unzip rocketmq-externals-master.zip
    然后进入cd /rocketmq-externals-master/rocketmq-console
    注意:打包前在rocketmq-console中/src/main/resources/application.properties配置namesrv集群地址:
    #这里将默认的8080改成19876了
    server.port=19876
    #这里是指定Nameserv,也可以不指定,在前端控制台进行指定
    rocketmq.config.namesrvAddr=服务器1IP:9876;服务器2IP:9876
    #这里设置为true,配合users.properties使用,设置登陆账号密码
    rocketmq.config.loginRequired=true
    # 切换到控制台目录
    cd rocketmq-console
    //然后编译打包(跳过测试打包)
    mvn clean package -Dmaven.test.skip=true
    然后 cd target/ 执行运行jar( 端口默认8080) nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=19876 &
    进入cd /usr/local/rocketmq-externals-master/rocketmq-dashboard-master
    然后 cd target/ 执行运行jar( 端口默认8080) nohup java -jar rocketmq-dashboard-2.0.0.jar --server.port=19876 &
    关闭jar(强制杀死进程):kill -9 进程号

    端口开启防火墙
    netstat -an|grep 8080
    firewall-cmd --zone=public --list-ports
    firewall-cmd --zone=public --add-port=8081/tcp --permanent
    firewall-cmd --reload

  • 相关阅读:
    8张图带你轻松温习 Java 知识.md
    关于 Java 序列化你不知道的 5 件事
    为什么 String 是不可变的?
    如何使用 Nginx 优雅地限流?
    JAVA泛型编程笔记
    java_接口的应用
    java_抽象类应用
    深入理解Java的接口和抽象类
    java_重写与重载的区别
    Java:按值传递还是按引用传递详细解说
  • 原文地址:https://www.cnblogs.com/li150dan/p/15686615.html
Copyright © 2011-2022 走看看