博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
RocketMQ集群安装部署
阅读量:4069 次
发布时间:2019-05-25

本文共 2543 字,大约阅读时间需要 8 分钟。

一、环境:

  • 3台部署nameserver,每台至少2G内存
  • 4台部署broker(两组),每台至少2G内存,
  • Producer、Consumer随具体业务部署,不在文档中说明
  • Centos 7.x 64bit
  • JDK 1.8 + 64bit
  • RocketMQ-4.2.0
  • rocektmq-console-ng-1.0.0

二、准备

关闭防火墙

systemctl stop firewalld.service

systemctl disable firewalld.service

firewall-cmd --state #确保结果为not running

下载安装包

RocketMQ

 

三、安装RocketMQ

 

解压程序包

#创建rocketmq目录:

mkdir /usr/local/rocketmq

#移动安装包rocketmq目录并解压

unzip rocketmq-all-4.2.0-bin-release.zip

#把程序包里的命令软连接到系统默认命令目录

配置环境变量

vi /etc/profile

添加如下信息

export ROCKETMQ_HOME=/usr/local/rocketmq

export PATH=$PATH::$ROCKETMQ_HOME/bin

配置nameserver(3台)

3台按照1~2步配置好即可

配置broker(6台)

6台按照1~2步配置好,再分别配置3组主从:

 

以第1组为例:

 

【主broker配置】

编辑/usr/local/ rocketmq/conf/2m-2s-async/broker-a.properties

 

#namesrvAddr默认为空必须填上不然启动报错,值为上边启动的namesrv的监听地址;如果多个nameser则用“,”隔开

namesrvAddr= 192.168.103.84:9876;192.168.103.85:9876

#broker机器名称 

brokerClusterName=gamelife_broker_cluster

#broker名称,主从关系则主从名称相同,非主从关系则名称要不同

brokerName=gamelife_broker1

#如果为master则为0,slave则为1                   

brokerId=0

#数据存储路径

storePathRootDir=/home/www/data/rocketmq/store

#存储日志路径

storePathCommitLog=/home/www/data/rocketmq/store/commitlog

#主从角色,主

brokerRole=ASYNC_MASTER           

#主从同步方式,异步复制  

flushDiskType=ASYNC_FLUSH

#自动创建topic

autoCreateTopicEnable=true

#自动创建组

autoCreateSubscriptionGroup=true

 

【从broker配置】

编辑/usr/local/rocketmq/conf/2m-2s-async/broker-a-s.properties

 

#namesrvAddr默认为空必须填上不然启动报错,值为上边启动的namesrv的监听地址;如果多个nameser则用“,”隔开

namesrvAddr= 192.168.103.84:9876;192.168.103.85:9876

#broker机器名称 

brokerClusterName=gamelife_broker_cluster

#broker名称,主从关系则主从名称相同,非主从关系则名称要不同

brokerName=gamelife_broker1

#如果为master则为0,slave则为1                   

brokerId=1

#数据存储路径

storePathRootDir=/home/www/data/rocketmq/store

#存储日志路径

storePathCommitLog=/home/www/data/rocketmq/store/commitlog

#主从角色,

brokerRole=SLAVE 

#主从同步方式,异步复制  

flushDiskType=ASYNC_FLUSH

#自动创建topic

autoCreateTopicEnable=true

#自动创建组

autoCreateSubscriptionGroup=true

 

四、启动RocketMQ

 

  1. 启动namesever(3台)

nohup sh mqnamesrv &

 

  1. 启动主broker(3台)

nohup sh mqbroker -c $ROCKETMQ_HOME/conf/2m-2s-async/broker-a.properties &

  1. 启动从broker(3台)

nohup sh mqbroker -c $ROCKETMQ_HOME/conf/2m-2s-async/broker-a-s.properties &

 

五、安装RocketMQ WEB管理服务

      

  1. 安装rocket-mq-console-ng

#创建rocketmq-console目录:

mkdir /usr/local/rocketmq-console

#将离线安装包“rocketmq-console-ng-1.0.0.jar”放到rocketmq-console目录

 

  1. 运行rocket-mq-console-ng

#--server.port为运行的这个web应用的端口,如果不设置的话默认为8080;--rocketmq.config.namesrvAddr为RocketMQ命名服务地址,如果不设置的话默认为“”

nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=192.168.103.84:9876;192.168.103.85:9876 &

 

启动成功后,我们就可以通过浏览器访问http://localhost:8080进入控制台界面了

 

转载地址:http://mjhji.baihongyu.com/

你可能感兴趣的文章
platform_device与platform_driver
查看>>
platform_driver平台驱动注册和注销过程(下)
查看>>
.net强制退出主窗口的方法——Application.Exit()方法和Environment.Exit(0)方法
查看>>
c# 如何调用win8自带的屏幕键盘(非osk.exe)
查看>>
build/envsetup.sh 简介
查看>>
C++后继有人——D语言
查看>>
Android framework中修改或者添加资源无变化或编译不通过问题详解
查看>>
linux怎么切换到root里面?
查看>>
linux串口操作及设置详解
查看>>
安装alien,DEB与RPM互换
查看>>
linux系统下怎么安装.deb文件?
查看>>
编译Android4.0源码时常见错误及解决办法
查看>>
Android 源码编译make的错误处理
查看>>
linux环境下C语言中sleep的问题
查看>>
ubuntu 12.04 安装 GMA3650驱动
查看>>
新版本的linux如何生成xorg.conf
查看>>
xorg.conf的编写
查看>>
启用SELinux时遇到的问题
查看>>
virbr0 虚拟网卡卸载方法
查看>>
No devices detected. Fatal server error: no screens found
查看>>