0
点赞
收藏
分享

微信扫一扫

RocketMQ(二)Centos 7安装

安装前提

保证服务器有jdk1.8+和maven。

下载RocketMQ 安装包

在以下地址选择下载:
https://www.apache.org/dyn/closer.cgi?path=rocketmq

上传至服务器并解压

以下步骤如果下载的是release包的话,可以省略打包过程。

#解压缩
unzip rocketmq-all-4.7.1-source-release.zip
#删除压缩包
rm -rf rocketmq-all-4.7.1-source-release.zip
#修改下文件名
mv rocketmq-all-4.7.1-source-release/ /opt/rocketmq/rocketmq-all-4.7.1/
#进入目录下
cd /rocketmq-all-4.7.1/
#通过maven安装依赖并打包
mvn -Prelease-all -DskipTests clean install -U
#进入打包好的路径下
cd distribution/target/rocketmq-4.7.1/rocketmq-4.7.1

启动Name Server

#后台启动
nohup sh bin/mqnamesrv -n ip:9876 &
#查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log

启动Broker

#后台启动并指定端口,执行配置文件(解决内网ip注册导致无法连接)
#当前是默认配置启动,broker是不允许创建topic的
nohup sh bin/mqbroker -n ip:9876 -c conf/broker.conf &
#查看日志
tail -f ~/logs/rocketmqlogs/broker.log

发送/接收测试

export NAMESRV_ADDR=localhost:9876
#发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
#接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

控制台安装

#git下载源码
https://github.com/apache/rocketmq-externals.git
#进入控制台路径
cd \rocketmq-console
#修改配置文件application.properties,如下
server.port=你指定的后台端口
rocketmq.config.namesrvAddr=rocketMQ部署的服务器ip:9876
#在rocketmq-console目录下执行maven打包命令
mvn clean package -Dmaven.test.skip=true
#将target下生成的jar包上传至服务器,并后台启动
nohup java -jar rocketmq-console-ng-2.0.0.jar &>/dev/null &
#访问控制台
http://服务器ip:你指定的端口
例如:http://192.168.1.2:8080

注意:如果存在服务无法启动,请自行修改启动脚本中的参数-Xms -Xmx等,满足自己机器要求即可。

举报

相关推荐

0 条评论