Linux搭建RocketMQ_大数据系统

Linux搭建RocketMQ

一、下载

首先去github下载对应的版本：点击跳转,右键复制下载链接，也可以自行使用上传工具传包

https://codeload.github.com/apache/rocketmq/tar.gz/refs/tags/rocketmq-all-4.9.3

二、执行命令

wget https://codeload.github.com/apache/rocketmq/tar.gz/refs/tags/rocketmq-all-4.9.3

tar  -zxvf rocketmq-all-4.9.3

三、maven安装

已经安装了的可以跳过此步骤

注意：由于下载到的源码，我们需要对其进行编译和安装，编译使用的是maven，如果linux中没有maven，我们需要进行maven安装

wget https://mirrors.tuna.tsinghua.edu.cn/apache/maven/maven-3/3.6.3/binaries/apache-maven-3.6.3-bin.tar.gz

tar -zxvf apache-maven-3.6.3-bin.tar.gz

进入maven配置maven镜像

vim /opt/maven3.6.3/apache-maven-3.6.3/conf/settings.xml

添加如下配置


  aliyunmaven
  *
  阿里云公共仓库
  https://maven.aliyun.com/repository/public

配置环境变量

vim /etc/profile

在最下面一行添加如下

MAVEN_HOME=/opt/maven3.6.3/apache-maven-3.6.3 #你自己的安装目录

export MAVEN_HOME

export PATH=${PATH}:${MAVEN_HOME}/bin

刷新配置

 source /etc/profile

验证maven

mvn -v

显示maven信息就表示安装成功

编译rocketmq

在rocketmq目录下执行

mvn -Prelease-all -DskipTests clean install -U

可能编译需等一会，编译成功显示如下：

在rocketmq目录中，进入编译后的rocketmq目录

 cd distribution/target/rocketmq-4.9.3/

启动命令

nohup sh bin/mqnamesrv > /mydata/rocketmq/nameserver.log 2>&1 &

nohup sh bin/mqbroker -n 127.0.0.1:9876 -c conf/broker.conf autoCreateTopicEnable=true > /mydata/rocketmq/broker.log 2>&1 &

查看信息

jps

发现只有一个nameserver服务，broker没运行起来，查看日志

 cat /mydata/rocketmq/broker.log

发现如下报错

内存不够：

注意rocketmq默认运行内存都非常大，我们需要设置一下。

在bin目录下找到 runserver.sh、runbroker.sh 、tools.sh

关闭刚刚启动的nameserver

sh ./mqshutdown namesrv

vim runserver.sh

修改如下

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:metaspaceSize=128m -XX:MaxmetaspaceSize=320m"

vim runbroker.sh

修改如下

 JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

vim tools.sh

修改如下

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m"

重新启动

nohup sh bin/mqnamesrv > /mydata/rocketmq/nameserver.log 2>&1 &

nohup sh bin/mqbroker -n 127.0.0.1:9876 -c conf/broker.conf autoCreateTopicEnable=true > /mydata/rocketmq/broker.log 2>&1 &

发现进程都成功!

服务关闭

关闭nameserver服务

sh bin/mqshutdown namesrv

关闭broker服务

sh bin/mqshutdown broker

Linux搭建RocketMQ