栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

【RocketMq安装】

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

【RocketMq安装】

1. 官方下载地址

http://rocketmq.apache.org/dowloading/releases/
使用最新的4.8的版本

2. 环境要求
  • Linux64位系统
  • JDK1.8(64位)
  • 源码安装需要安装Maven 3.2.x
3. 目录介绍
  • bin:启动脚本,包括shell脚本和CMD脚本
  • conf:实例配置文件 ,包括broker配置文件、logback配置文件等
  • lib:依赖jar包,包括Netty、commons-lang、FastJSON等
4. RocketMQ的windows下的安装

RocketMQ的存储设计,包括分页设计,设计上都是基于Linux上的。所以生产服务器推荐使用Linux.

1. 解压

D:rocketmq-all-4.8.0-bin-release

2. 配置环境变量

变量名:ROCKETMQ_HOME
变量值:D:rocketmq-all-4.8.0-bin-release

3. 注意事项

RocketMQ默认的虚拟机内存较大,启动Broker如果因为内存不足失败,需要编辑如下两个配置文件,修改JVM内存大小。

但是这个也仅仅是在测试环境中,RocketMQ在生产上最低要求至少8G内存(官方推荐)才能确保RocketMQ的效果

编辑runbroker.sh和runserver.sh修改默认JVM大小(windows上对应cmd文件)

  • runbroker.sh broker的配置
  • runserver.sh nameServer的配置

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:metaspaceSize=128m -XX:MaxmetaspaceSize=320m"

4. 启动

RocketMQ的物理架构中,都是需要先启动NameServer再启动Broker的。所以启动顺序一定不要搞反了。

启动NAMESERVER

Cmd命令框执行进入至‘MQ文件夹bin’下,然后执行‘start mqnamesrv.cmd’,启动NAMESERVER。成功后会弹出提示框,此框勿关闭。

启动BROKER

Cmd命令框执行进入至‘MQ文件夹bin’下,然后执行start mqbroker.cmd –n 127.0.0.1:9876 autoCreateTopicEnable=true,启动BROKER。成功后会弹出提示框,此框勿关闭。

假如弹出提示框提示‘错误:找不到或无法加载主类xxxxxx’。打开runbroker.cmd,然后将‘%CLASSPATH%’加上英文双引号。保存并重新执行start语句。

5. 存储

rocketmq取的默认路径是user.home路径,也就是用户的根目录,一般存储放在了路径下的/store目录

源码中可以得到验证,如下图:

所以这里会有一个问题,RocketMQ很容易导致C盘空间不够,在使用过程中,创建一个主题默认就是要创建1G的文件,很可能会导致出问题。
所以在windows上容易导致C盘空间吃满。
解决方式有两种:

  • 修改源码,比如:全局替换user.home参数为mq.store,然后重新打包
  • 使用源码方式启动,源码启动时通过参数设置指定存储位置
6. 安装可视化插件

运行前确保:已经有jdk1.8,Maven(打包需要安装Maven3.2.x
下载:https://codeload.github.com/apache/rocketmq-externals/zip/master

console已经重命名为rocketmq-dashboard并移到了性的仓库下:
https://github.com/apache/rocketmq-dashboard

正在克隆代码时候git不可以 2021年11月24日00:59:571
(旧版很多文章,这里就不说了)
下载完成之后,进入‘rocketmq-dashboard-mastersrcmainresources’文件夹,打开‘application.properties’进行配置

进入‘rocketmq-dashboard-master’文件夹,执行‘mvn clean package -Dmaven.test.skip=true’,编译生成。

编译成功之后,Cmd进入‘target’文件夹,执行‘java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar’,启动 rocketmq-dashboard-1.0.1-SNAPSHOT.jar。

浏览器中输入‘127.0.0.1:8089’,成功后即可查看。

5. RocketMQ在Linux下的安装

运行前确保:已经有jdk1.8

记得Linux上修改文件权限:命令如下:chmod -R 777 /home/linux

假设服务的外网IP地址:192.168.56.101

  • 注意事项
    RocketMQ默认的虚拟机内存较大,启动Broker如果因为内存不足失败,需要编辑如下两个配置文件,修改JVM内存大小。
    但是这个也仅仅是在测试环境中,RocketMQ在生产上最低要求至少8G内存(官方推荐)才能确保RocketMQ的效果
    编辑runbroker.sh和runserver.sh修改默认JVM大小(windows上对应cmd文件)
vi runbroker.sh           --broker的配置
vi runserver.sh            --nameServer的配置
JAVA_OPT="${JAVA_OPT} -server -Xms1024m -Xmx1024m -Xmn512m -XX:metaspaceSize=128m -XX:MaxmetaspaceSize=320m"
1. 启动NAMESERVER

进入至‘MQ文件夹bin’下,然后执行‘nohup sh mqnamesrv &’,启动NAMESERVER。
查看日志的命令:tail -f ~/logs/rocketmqlogs/namesrv.log

2. 启动BROKER

进入至‘MQ文件夹bin’下,启动BROKER。
修改配置文件增加外网地址(你启动加载哪个配置文件就修改哪个,这里修改broker.conf)
brokerIP1=192.168.56.101
启动命令如下:
nohup sh mqbroker -c …/conf/broker.conf -n 192.168.56.101:9876 autoCreateTopicEnable=true &
这样启动的服务器可以自动创建主题(客户端),不过生产一般不推荐。
查看日志的命令:tail -f ~/logs/rocketmqlogs/broker.log

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/591032.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号