zoukankan      html  css  js  c++  java
  • rocketmq的linux搭建环境

    3.3. 上传解压【两台机器】
    # 上传 apache-rocketmq.tar.gz 文件至/usr/local

    # tar -zxvf apache-rocketmq.tar.gz -C /usr/local

    # ln -s apache-rocketmq rocketmq ll /usr/local

    3.4. 创建存储路径【两台机器】
    # mkdir /usr/local/rocketmq/store

    # mkdir /usr/local/rocketmq/store/commitlog

    # mkdir /usr/local/rocketmq/store/consumequeue # mkdir /usr/local/rocketmq/store/index
    3.5. RocketMQ 配置文件【两台机器】
    # vim /usr/local/rocketmq/conf/2m-2s-async/broker-a.properties

    # vim /usr/local/rocketmq/conf/2m-2s-async /broker-a-s.properties

    #所属集群名字

    brokerClusterName=rocketmq-cluster

    #broker 名字,注意此处不同的配置文件填写的不一样

    brokerName=broker-a|broker-b

    #0 表示 Master,>0 表示

    Slave brokerId=0

    #nameServer 地址,分号分割

    namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

    #在发送消息时,自动创建服务器不存在的 topic,默认创建的队列数

    defaultTopicQueueNums=4

    #是否允许 Broker 自动创建 Topic,建议线下开启,线上关闭

    autoCreateTopicEnable=true

    #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭

    autoCreateSubscriptionGroup=true

    #Broker 对外服务的监听端口

    listenPort=10911

    #删除文件时间点,默认凌晨 4 点

    deleteWhen=04

    #文件保留时间,默认 48 小时

    fileReservedTime=120

    #commitLog 每个文件的大小默认 1G

    mapedFileSizeCommitLog=1073741824

    #ConsumeQueue 每个文件默认存 30W 条,根据业务情况调整

    mapedFileSizeConsumeQueue=300000

    #destroyMapedFileIntervalForcibly=120000

    #redeleteHangedFileInterval=120000

    #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88

    #存储路径 storePathRootDir=/usr/local/rocketmq/store

    #commitLog 存储路径

    storePathCommitLog=/usr/local/rocketmq/store/commitlog

    #消费队列存储路径存储路径 s

    torePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

    #消息索引存储路径

    storePathIndex=/usr/local/rocketmq/store/index

    #checkpoint 文件存储路径

    storeCheckpoint=/usr/local/rocketmq/store/checkpoint

    #abort 文件存储路径

    abortFile=/usr/local/rocketmq/store/abort

    #限制的消息大小 maxMessageSize=65536

    #flushCommitLogLeastPages=4

    #flushConsumeQueueLeastPages=2

    #flushCommitLogThoroughInterval=1000

    #flushConsumeQueueThoroughInterval=60000 


    #Broker 的角色

    #- ASYNC_MASTER 异步复制 Master

    #- SYNC_MASTER 同步双写 Master

    #- SLAVE

    brokerRole=ASYNC_MASTER

    #刷盘方式 #- ASYNC_FLUSH 异步刷盘

    #- SYNC_FLUSH 同步刷盘

    flushDiskType=ASYNC_FLUSH

    #checkTransactionMessageEnable=false

    #发消息线程池数量

    #sendMessageThreadPoolNums=128

    #拉消息线程池数量

    #pullMessageThreadPoolNums=128

    3.6. 修改日志配置文件【两台机器】
    # mkdir -p /usr/local/rocketmq/logs

    # cd /usr/local/rocketmq/conf && sed -i 's#${user.home}#/usr/local/rocketmq#g' *.xml

    3.7. 修改启动脚本参数【两台机器】
    # vim /usr/local/rocketmq/bin/runbroker.sh

    #============================================================================== # 开发环境 JVM Configuration #============================================================================== JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m XX:MaxPermSize=320m"

    # vim /usr/local/rocketmq/bin/runserver.sh JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m XX:MaxPermSize=320m"


    3.8. 启动 NameServer【两台机器】
    # cd /usr/local/rocketmq/bin

    # nohup sh mqnamesrv &

    3.9. 启动 BrokerServer A【192.168.11.128】
    # cd /usr/local/rocketmq/bin

    # nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &

    # netstat -ntlp

    # jps

    # tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log

    # tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log
    3.10. 启动 BrokerServer B【192.168.11.129】
    # cd /usr/local/rocketmq/bin # nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a-s.properties >/dev/null 2>&1 &

    # netstat -ntlp

    # jps

    # tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log

    # tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log

  • 相关阅读:
    fedora上部署ASP.NET——(卡带式电脑跑.NET WEB服务器)
    SQL Server 请求失败或服务未及时响应。有关详细信息,请参见事件日志或其它适合的错误日志
    8086CPU的出栈(pop)和入栈(push) 都是以字为单位进行的
    FTP 服务搭建后不能访问问题解决
    指定的 DSN 中,驱动程序和应用程序之间的体系结构不匹配
    Linux 安装MongoDB 并设置防火墙,使用远程客户端访问
    svn Please execute the 'Cleanup' command. 问题解决
    .net 操作MongoDB 基础
    oracle 使用绑定变量极大的提升性能
    尝试加载 Oracle 客户端库时引发 BadImageFormatException。如果在安装 32 位 Oracle 客户端组件的情况下以 64 位模式运行,将出现此问题。
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10345585.html
Copyright © 2011-2022 走看看