zoukankan      html  css  js  c++  java
  • linux环境上 rocketmq 安装部署

    Rocketmq-简单部署

     

    一、准备环境

    1.系统:Centos7.3(无硬性要求)

    2. jdk:1.8

    3.maven:3.5(无硬性要求)

    4.git

    5.rocketmq 4.2

    二、环境部署

    1.jdk1.8以及maven可以在另一篇文章查看【http://www.cnblogs.com/dingkailinux/p/8794611.html】

    2.git安装

    # yum -y install git
    # git --version
    git version 2.16.2

    3.部署rocketmq

    参考官方指导【https://rocketmq.apache.org/docs/quick-start/】

    (1)下载源码

    wget 'http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip'

    (2)解压编译

    # unzip rocketmq-all-4.2.0-source-release.zip
    # mv rocketmq-all-4.2.0 /opt/
    # cd /opt/rocketmq-all-4.2.0
    # mvn -Prelease-all -DskipTests clean install -U    #使用mvn编译

    (3)编译完成后,调整配置

    复制代码
    # cd distribution/target/apache-rocketmq  #编译后的程序其实就在’apache-rocketmq‘中,这个目录可以单独拿出来启动
    # cd /opt/
    rocketmq-all-4.2.0/distribution/target/
    # cp -a apache-rocketmq /opt/rocketmq
    # cd /opt/rocketmq

    #########调整启动内存#######
    # vim bin/runserver.sh  #调整nameserver启动的内存(如果服务器内存比较大,可以不调整),如果内存较小,不调整此文件,可能导致无法启动
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"  #需要调整标红部分
    # vim bin/runbroker.sh
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
    ########调整日志文件位置########
    # vim conf/logback_broker.xml
    # vim conf/logback_filtersrv.xml
    # vim conf/logback_namesrv.xml
    # vim conf/logback_tools.xml
    以上四个文件,将类似于[${user.home}/logs/rocketmqlogs/namesrv_default.log]修改为自定义的日志路径,如[/data/logs/rocketmqlogs/
    namesrv_default.log],如果不修改,日志就会写入到用户目录下的logs目录下
    复制代码

     (4)启动服务

    复制代码
    # nohup sh bin/mqnamesrv &    #启动nameserver
    # tail -f nohup.out
    The Name Server boot success  #输出此类信息,说明启动成功

    #nohup sh bin/mqbroker -n 本地IP:9876 &  #启动broker
    # tail -f nohup.out
    INFO main - The broker[localhost, 172.17.154.196:10911] boot success. serializeType=JSON and name server is 172.17.154.196:9876  #日志输出如下信息,证明启动成功
    复制代码

    3.向客户端提供NameServer地址

    复制代码
    export NAMESRV_ADDR=172.17.154.196:9876
    也可以将内容写入/etc/profile中
    cat <<EOF>>/etc/profile
    export NAMESRV_ADDR=172.17.154.196:9876
    EOF
    
    source /etc/profile
    复制代码

    4.模拟消息传送

    复制代码
    (1)模拟producer产生消息
    #cd /opt/rocketmq/
    #sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    
    (2)模拟consumer消费消息
    #cd /opt/rocketmq/
    #sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
    复制代码
     

    关闭服务器
    sh bin/mqshutdown broker //停止 broker

    sh bin/mqshutdown namesrv //停止 nameserver
    常用命令
    上面几个启动和关闭 name server 和 broker 的就不再说了,

    查看集群情况 ./mqadmin clusterList -n 127.0.0.1:9876
    查看 broker 状态 ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911 (注意换成你的 broker 地址)
    查看 topic 列表 ./mqadmin topicList -n 127.0.0.1:9876
    查看 topic 状态 ./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (换成你想查询的 topic)
    查看 topic 路由 ./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic

      

    转自:

        https://blog.csdn.net/shiloh_my/article/details/82977584

    这个地址里讲的很详细,亲测

  • 相关阅读:
    女程序员这么少是因为怕秃头?如果你这样想,那就错了...
    使用简单的c#示例的坚实的架构原则
    第1部分设计模式FAQ(培训)
    为什么微软部分类和Java不?
    现实世界四部分类和部分方法的使用
    回到基础:n层ASP的异常管理设计指南。网络应用
    学习c#(第9天):理解c#中的事件(一种见解)
    EventBroker:同步和异步通知组件,松散耦合的事件处理
    潜水在OOP(第一天):多态和继承(早期绑定/编译时多态)
    学习c#(第8天):c#中的索引器(一种实用方法)
  • 原文地址:https://www.cnblogs.com/houzs/p/10457507.html
Copyright © 2011-2022 走看看