前置条件:两台虚拟机centos linux release 7.5.1804(ps:当然也可以都部署在一台机器上)
rocketmq属于天生集群。需要同时启动nameserver和broker进行部署,在通过dashboard进行监控,所以要安装三个东西。
当前在这之前还需要安装jdk
yum -y install java-1.8.0-openjdk-devel.x86_64 sudo cat >> /etc/profile <<-'eof' export java_home=/usr/lib/jvm/java-1.8.0-openjdk export jre_home=$java_home/jre export classpath=$java_home/lib:$jre_home/lib:$classpath export path=$java_home/bin:$jre_home/bin:$path eof source /etc/profile echo $java_home
1.安装nameserver
下载压缩包后通过
#进行解压 unzip rocketmq-all-5.3.0-bin-release.zip cd 到对应解压压缩包内 #修改runserver sed -i 's/-xms4g -xmx4g -xx:metaspacesize=128m/-xms1g -xmx1g -xx:metaspacesize=128m/g' ./bin/runserver.sh #nameserver默认使用9876端口,如果使用虚拟机启动可以忽略这行 firewall-cmd --zone=public --add-port=9876/tcp --permanent firewall-cmd --reload # 非后台启动 # sh ./bin/mqnamesrv #后台启动并查看日志 nohup sh ./bin/mqnamesrv > nqnamesrv.log &
查看启动日志cat nqnamesrv.log 如果输出结果是seccess则表示启动成功

2.安装broker
在另外一台的虚拟机上,也需要
#进行解压 unzip rocketmq-all-5.3.0-bin-release.zip cd 到对应解压压缩包内 #修runbroker sed -i 's/-xms8g -xmx8g/-xms1g -xmx1g/g' ./bin/runbroker.sh #创建broker的的配置 cat > single-master.properties <<-'eof' #集群名称,同一个集群下的broker要求统一 brokerclustername=defaultcluster #broker名称 brokername=broker-a #brokerid=0代表主节点,大于零代表从节点 brokerid=0 #删除日志文件时间点,默认凌晨 4 点 deletewhen=04 #日志文件保留时间,默认 48 小时 filereservedtime=48 #broker 的角色 #- async_master 异步复制master #- sync_master 同步双写master brokerrole=sync_master #刷盘方式 #- async_flush 异步刷盘,性能好宕机会丢数 #- sync_flush 同步刷盘,性能较差不会丢数 flushdisktype=sync_flush #末尾追加,nameserver节点列表,使用分号分割 namesrvaddr=192.168.10.100:9876 autocreatetopicenable=true eof #防火墙设置 firewall-cmd --zone=public --add-port=10911/tcp --permanent firewall-cmd --reload #启动日志 #sh ./bin/mqbroker -c ./single-master.properties nohup sh ./bin/mqbroker -c ./single-master.properties > broker.log &
查看cat broker.log ,如果为success则表示启动成功

3.使用自带工具测试数据发送
在nameserver端
export namesrv_addr=192.168.10.100:9876 sh tools.sh org.apache.rocketmq.example.quickstart.producer

在broker端接收消息
export namesrv_addr=192.168.10.100:9876 sh tools.sh org.apache.rocketmq.example.quickstart.consumer

4.使用dashboard进行查看
https://github.com/apache/rocketmq-dashboard
仓库服务 (aliyun.com) rocketmq-dashboard
默认启动是8080端口
nohup java -jar rocketmq-dashboard-1.0.0.jar > dashboard.log &
启动访问地址http://192.168.10.100:8080/


5.关闭相关设备
# 停止nameserver sh bin/mqshutdown namesrv # 停止broker sh bin/mqshutdown broker #查看关闭是否成功,如果没有返回结果则表示关闭成功 ss -anp | grep 9876 ss -anp | grep 10911
6.启动脚本
虚拟机安装完之后每次启动都很麻烦,所以补充一个一件启动脚本
vim start_mq.sh #!/bin/bash nohup sh /home/namesrv/bin/mqnamesrv > /home/namesrv/nqnamesrv.log 2>&1 & nohup sh /home/brokersrv/bin/mqbroker -c /home/brokersrv/single-master.properties > /home/brokersrv/broker.log 2>&1 & nohup java -jar /home/mq-dash.jar > /home/dashboard.log 2>&1 & chmod 777 start_mq.sh #再次重启 sh ./路径/start_mq.sh
到此这篇关于rocketmq单结点安装/dashboard安装的文章就介绍到这了,更多相关rocketmq单结点安装内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!
发表评论