各位老铁们,大家好,今天由我来为大家分享GTP赚钱网站源码分享,以及gh赚钱的相关问题知识,希望对大家有所帮助。如果可以帮助到大家,还望关注收藏下本站,您的支持是我们最大的动力,谢谢大家了哈,下面我们开始吧!
今天来分享怎样搭建RocketMQ集群。
本文搭建集群使用的环境是2个云主机,架构如下:
在47.xx.xx.xx和39.xx.xx.xx上分别部署一个NameServer和Broker主节点,这里不搭建从节点。也就是官网介绍的2m-noslave构建模式。
注意:官网有三种配置模式:2m-2s-sync、2m-2s-async、2m-noslave。这三种配置都是使用异步刷盘策略:ASYNC_FLUSH。
集群搭建成功后,Broker会向NameServer注册Topic路由信息,Producer和Consumer则从NameServer获取路由信息,然后Producer根据路由信息向Broker发送消息,Consumer则根据路由信息从Broker拉取消息。
1准备工作
要安装RocketMQ,首先需要在云主机上安装Java环境,Maven环境。这里就不做详细介绍了。
Java和Maven环境安装好以后,从官网下载最新版本,地址如下:
https://dlcdn.apache.org/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip\n
下载完成后,进行解压和编译,执行如下命令:
>unziprocketmq-all-4.9.4-source-release.zip\n>cdrocketmq-all-4.9.4-source-release/\n>mvn-Prelease-all-DskipTestscleaninstall-U\n>cddistribution/target/rocketmq-4.9.4/rocketmq-4.9.4\n
看到下图输出时,编译成功:
2启动
2.1启动NameServer
因为我的云主机内存比较小,而RocketMQ默认启动NameServer需要的JVM堆内存默认是4g,所以需要修改默认堆内存。修改文件为:
rocketmq-all-4.9.4-source-release/distribution/target/rocketmq-4.9.4/rocketmq-4.9.4/bin/runserver.sh\n
修改后的配置如下:
JAVA_OPT=&34;\n
修改完成后,执行下面命令:
nohupshbin/mqnamesrv&\n
启动成功后,nohup.out文件中打印如下日志:
TheNameServerbootsuccess.serializeType=JSON\n
搭建好一台机器后,用同样的方式搭建第二台机器。
2.2启动Broker
同样,RocketMQ启动Broker需要的JVM堆内存默认是8g,所以需要修改堆内存。修改文件为:
rocketmq-all-4.9.4-source-release/distribution/target/rocketmq-4.9.4/rocketmq-4.9.4/bin/runbroker.sh\n
修改后的配置如下:
JAVA_OPT=&34;\n
创建conf.properties文件,内容如下:
brokerClusterName=MyTestCluster\nbrokerName=broker-a\nbrokerId=0\ndeleteWhen=04\nfileReservedTime=48\nbrokerRole=ASYNC_MASTER\nflushDiskType=ASYNC_FLUSH\nnamesrvAddr=127.0.0.1:9876;47.xx.xx.xx:9876\n
配置好后,启动broker-a节点,启动命令如下:
nohupbashbin/mqbroker-cconf/broker.properties&\n
Broker启动成功后,NameServer的日志如下图:
用同样的方式启动broker-b,conf.properties文件配置如下:
broker名称\nbrokerName=broker-b\nbrokerId=0\n未发生更新的消息存储文件的保留时长为48小时,48小时后过期,将会被删除\nfileReservedTime=48\nbrokerRole=ASYNC_MASTER\nflushDiskType=ASYNC_FLUSH\nnamesrvAddr=127.0.0.1:9876;xx.xx.xx.xx:9876\n
启动成功后,执行mqadmin命令查看集群信息:
[root@rocketmq-4.9.4]34;${JAVA_OPT}-server-Xms256m-Xmx256m-Xmn128m-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=128m&shbin/mqadminsendMessage-n127.0.0.1:9876-tMyTestTopic-p&39;\nQIDMsgId\nbroker-a1SEND_OK7F000001D3C3339097527B50D1740000\n
在界面上查看消息,如下图:
4总结
这篇文章主要讲述了RocketMQ集群的搭建,希望能对大家理解RocketMQ有所帮助。
如果你还想了解更多这方面的信息,记得收藏关注本站。