zoukankan      html  css  js  c++  java
  • 关于rocketmq的配置启动

    #集群名称
    brokerClusterName=rocket-nameserver
    #broker-a,注意其它两个分别为broker-b和broker-c
    brokerName=broker-a
    #brokerId等于0表示是MASTER节点,小于0是SLAVE节点,我这里全设置成主节点
    brokerId=0
    deleteWhen=04
    fileReservedTime=48
    #配置nameserver地址,多台以;分割:
    namesrvAddr=rocket-nameserver-01:9876;rocket-nameserver-02:9876;rocket-nameserver-03:9876
    #存储路径
    storePathRootDir=/opt/rocketmq432/store
    #commitlog存储路径
    storePathCommitLog=/opt/rocketmq432/store/commitlog
    #消息队列
    storePathConsumeQueue=/opt/rocketmq432/store/consumequeue
    #消息索引
    storePathIndex=/opt/rocketmq432/store/index
    #checkpoint文件存储过径
    storeCheckpoint=/opt/rocketmq432/store/checkpoint
    #abort文件存储路径
    abortFile=/opt/rocketmq432/store/abort
    #限制的消息大小
    maxMessageSize=65536
    #角色和刷盘方式
    brokerRole=ASYNC_MASTER
    flushDiskType=ASYNC_FLUSH

    启动a:
    1. nohup sh mqnamesrv &

    2. nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-a.properties autoCreateTopicEnable=true >/tmp/logs/mq.log 2>&1 &

    启动b:
    1. nohup sh mqnamesrv &

    2. nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-b.properties autoCreateTopicEnable=true >/tmp/logs/mq.log 2>&1 &

    启动c:

    1. nohup sh mqnamesrv &

    2. nohup sh mqbroker -c /opt/rocketmq432/conf/2m-noslave/broker-c.properties autoCreateTopicEnable=true >/tmp/logs/mq.log 2>&1 &


    停止服务:
    先执行: sh mqshutdown broker

    再执行: sh mqshutdown namesrv

    消息队列样例测试导入:

    export NAMESRV_ADDR=localhost:9876
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

  • 相关阅读:
    高斯消元(模板及bitset优化异或方程)
    dsu on tree
    拉格朗日插值
    [CF] CF900D Unusual Sequences
    【模板】Polya 定理
    Min-25筛学习笔记
    [CF] CF156C Cipher
    基于 Flink + Kafka 的广告实时数据分析建设与实践
    开源中国【面经】Java后台开发
    spring boot中连接数据库报错500(mybatis)
  • 原文地址:https://www.cnblogs.com/lhlucky/p/10767534.html
Copyright © 2011-2022 走看看