zoukankan      html  css  js  c++  java
  • RocketMQ单节点搭建

    • RocketMQ服务搭建  

      下载RocketMQ源码: http://mirror.bit.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-source-release.zip 

      执行以下命令:

    unzip rocketmq-all-4.4.0-source-release.zip
    cd rocketmq-all-4.4.0/
    mvn -Prelease-all -DskipTests clean install -U
    cd distribution/target/apache-rocketmq
    最终路径为:rocketmq-all-4.4.0/distribution/target/apache-rocketmq
    

      

      启动nameServer

    nohup sh bin/mqnamesrv &
    

      查看日志 tail -f nohup.out (结尾:The Name Server boot success. serializeType=JSON 表示nameServer启动成功)

      

      启动broker(-n 指定 nameServer地址,nameServer服务端口默认为9876, broker服务默认端口为10911)

    nohup sh bin/mqbroker -n localhost:9876 &
    

      

      关闭nameServer,broker服务

    sh bin/mqshutdown broker
    sh bin/mqshutdown namesrv
    

      

    • 搭建RocketMQ的可视化控制台
    源码下载
    git clone https://github.com/apache/rocketmq-externals
    
    cd rocketmq-console
    
    修改配置文件,需要指定nameServer的地址
    cd src/main/resources/application.properties
    添加配置
    rocketmq.config.namesrvAddr=127.0.0.1:9876 
    编译
    mvn clean package -Dmaven.test.skip=true
    
    进入编译后的目录
    cd target
    

      

      启动服务

    nohup java -jar -Dserver.port=8088 rocketmq-console-ng-1.0.1.jar &
    

      这里不指定端口,服务默认的端口为8080;

      注意事项:

      RocketMQ默认分配的内存较大,如果服务器内存不够,需要自己修改JVM参数

      1.修改bin/runserver.sh

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

      

      2.修改bin/runbroker.sh

    JAVA_OPT="${JAVA_OPT} -server -Xms528m -Xmx528m -Xmn256m"
    

      

     

  • 相关阅读:
    spring mvc文件上传,request对象转换异常
    解决国内android sdk无法更新,google不能的简单办法
    1.5 高速找出机器故障
    图的深度优先搜索与广度优先搜索
    我对ThreadLocal的理解
    Leetcode--3Sum
    <转>Openstack Ceilometer监控项扩展
    怎样利用WordPress创建自己定义注冊表单插件
    java_免费视频课程汇总
    HDU 3641 Pseudoprime numbers(快速幂)
  • 原文地址:https://www.cnblogs.com/coder-zyc/p/12118338.html
Copyright © 2011-2022 走看看