centos7 安装rocketmq4.7.0以及RocketMQ-Console-Ng控制台

2024-09-08 10:18

本文主要是介绍centos7 安装rocketmq4.7.0以及RocketMQ-Console-Ng控制台,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、前置工作

1.1安装jdk8

https://blog.csdn.net/pang_ping/article/details/80570011

1.2安装maven

https://www.cnblogs.com/116970u/p/11211963.html

1.3安装git

https://blog.csdn.net/xwj1992930/article/details/96428998

 

二、安装rocketmq

大部分的步骤在官网上面都有显示,链接:http://rocketmq.apache.org/docs/quick-start/

不过需要注意单机情况下,尤其是内存不足的时候有许多的注意事项,下面从头开始安装。

2.1 下载最新版rocketmq 4.7.0,并且解压

mkdir /opt/software/
cd /opt/software/
wget https://archive.apache.org/dist/rocketmq/4.7.0/rocketmq-all-4.7.0-source-release.zip
unzip  rocketmq-all-4.7.0-source-release.zip
cd rocketmq-all-4.7.0-source-release/
mvn -Prelease-all -DskipTests clean install -U

2.2 修改三个sh文件

cd /opt/software/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0
vim bin/runserver.sh
vim bin/runbroker.sh
vim bin/tools.sh

将三个文件中的Xms,Xmx,Xmn三个参数修改为合适的数值

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

将三个文件27-29行中的JAVA_HOME设置为本机的java路径,并注释下面两行,不然会报java环境错误

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=JAVA_HOME=/usr/local/java/
# [ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
# [ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

修改完毕后保存

三、校验安装

3.1启动mqnamesrv

nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log

出现

  The Name Server boot success...为成功

3.2启动Broker

nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log 

出现

  The broker[%s, 172.30.30.233:10911] boot success...为成功

如果部署在外网上面,需要公网ip访问的话,最好修改conf/broker.conf,新增

brokerIP1=X.X.X.X(公网IP)

同时启动时采用命令:

nohup sh bin/mqbroker -n <公网ip>:9876 -c conf/broker.conf autoCreateTopicEnable=true &

 

注意:利用公网部署的时候需要关闭selinux,开放端口9876和10911

 

3.3 利用rocketmq中的快速启动类校验收发消息

 > export NAMESRV_ADDR=localhost:9876> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer出现SendResult [sendStatus=SEND_OK, msgId= ...为发送成功> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
出现ConsumeMessageThread_%d Receive New Messages: [MessageExt...为消费成功

 

四、安装可视化控制台

4.1 官方地址:

https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

4.2 git拉取源码

cd /opt/software
git clone https://github.com/apache/rocketmq-externals.git

 

4.3 修改配置文件

cd /opt/software/rocketmq-externals/rocketmq-console/src/main/resources
vim application.properties 

将rocketmq.config.isVIPChannel设置为false,配置rocketmq.config.namesrvAddr为 本机地址:9876,可以选择性修改port或者下一步再命令中指定


server.contextPath=
server.port=7777### SSL setting
#server.ssl.key-store=classpath:rmqcngkeystore.jks
#server.ssl.key-store-password=rocketmq
#server.ssl.keyStoreType=PKCS12
#server.ssl.keyAlias=rmqcngkey#spring.application.index=true
spring.application.name=rocketmq-console
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
logging.config=classpath:logback.xml
#if this value is empty,use env value rocketmq.config.namesrvAddr  NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876
rocketmq.config.namesrvAddr=192.168.50.195:9876
#if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true
rocketmq.config.isVIPChannel=false
#rocketmq-console's data path:dashboard/monitor
rocketmq.config.dataPath=/tmp/rocketmq-console/data
#set it false if you don't want use dashboard.default true
rocketmq.config.enableDashBoardCollect=true
#set the message track trace topic if you don't want use the default one
rocketmq.config.msgTrackTopicName=
rocketmq.config.ticketKey=ticket#Must create userInfo file: ${rocketmq.config.dataPath}/users.properties if the login is required
rocketmq.config.loginRequired=false

利用maven打包

mvn clean package -Dmaven.test.skip=true

关于打包报错:https://blog.csdn.net/qq_37495786/article/details/102620550

运行jar包,启动项目,这里也可以设置rocketmq.config.namesrvAdd:和port

java -jar rocketmq-console-ng-1.0.1.jar 
#或者加入addr和port
java -jar rocketmq-console-ng-1.0.0.jar --server.port=7777 --rocketmq.config.namesrvAddr=192.168.50.195:9876

需要后台启动加入nohup,启动后的首页如图

http://192.168.50.195:7777/#/

 

 

这篇关于centos7 安装rocketmq4.7.0以及RocketMQ-Console-Ng控制台的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1147838

相关文章

RabbitMQ 延时队列插件安装与使用示例详解(基于 Delayed Message Plugin)

《RabbitMQ延时队列插件安装与使用示例详解(基于DelayedMessagePlugin)》本文详解RabbitMQ通过安装rabbitmq_delayed_message_exchan... 目录 一、什么是 RabbitMQ 延时队列? 二、安装前准备✅ RabbitMQ 环境要求 三、安装延时队

linux系统上安装JDK8全过程

《linux系统上安装JDK8全过程》文章介绍安装JDK的必要性及Linux下JDK8的安装步骤,包括卸载旧版本、下载解压、配置环境变量等,强调开发需JDK,运行可选JRE,现JDK已集成JRE... 目录为什么要安装jdk?1.查看linux系统是否有自带的jdk:2.下载jdk压缩包2.解压3.配置环境

Python库 Django 的简介、安装、用法入门教程

《Python库Django的简介、安装、用法入门教程》Django是Python最流行的Web框架之一,它帮助开发者快速、高效地构建功能强大的Web应用程序,接下来我们将从简介、安装到用法详解,... 目录一、Django 简介 二、Django 的安装教程 1. 创建虚拟环境2. 安装Django三、创

linux安装、更新、卸载anaconda实践

《linux安装、更新、卸载anaconda实践》Anaconda是基于conda的科学计算环境,集成1400+包及依赖,安装需下载脚本、接受协议、设置路径、配置环境变量,更新与卸载通过conda命令... 目录随意找一个目录下载安装脚本检查许可证协议,ENTER就可以安装完毕之后激活anaconda安装更

C#控制台程序同步调用WebApi实现方式

《C#控制台程序同步调用WebApi实现方式》控制台程序作为Job时,需同步调用WebApi以确保获取返回结果后执行后续操作,否则会引发TaskCanceledException异常,同步处理可避免异... 目录同步调用WebApi方法Cls001类里面的写法总结控制台程序一般当作Job使用,有时候需要控制

Jenkins的安装与简单配置过程

《Jenkins的安装与简单配置过程》本文简述Jenkins在CentOS7.3上安装流程,包括Java环境配置、RPM包安装、修改JENKINS_HOME路径及权限、启动服务、插件安装与系统管理设置... 目录www.chinasem.cnJenkins安装访问并配置JenkinsJenkins配置邮件通知

Win10安装Maven与环境变量配置过程

《Win10安装Maven与环境变量配置过程》本文介绍Maven的安装与配置方法,涵盖下载、环境变量设置、本地仓库及镜像配置,指导如何在IDEA中正确配置Maven,适用于Java及其他语言项目的构建... 目录Maven 是什么?一、下载二、安装三、配置环境四、验证测试五、配置本地仓库六、配置国内镜像地址

Python安装Pandas库的两种方法

《Python安装Pandas库的两种方法》本文介绍了三种安装PythonPandas库的方法,通过cmd命令行安装并解决版本冲突,手动下载whl文件安装,更换国内镜像源加速下载,最后建议用pipli... 目录方法一:cmd命令行执行pip install pandas方法二:找到pandas下载库,然后

解决RocketMQ的幂等性问题

《解决RocketMQ的幂等性问题》重复消费因调用链路长、消息发送超时或消费者故障导致,通过生产者消息查询、Redis缓存及消费者唯一主键可以确保幂等性,避免重复处理,本文主要介绍了解决RocketM... 目录造成重复消费的原因解决方法生产者端消费者端代码实现造成重复消费的原因当系统的调用链路比较长的时

Linux系统中查询JDK安装目录的几种常用方法

《Linux系统中查询JDK安装目录的几种常用方法》:本文主要介绍Linux系统中查询JDK安装目录的几种常用方法,方法分别是通过update-alternatives、Java命令、环境变量及目... 目录方法 1:通过update-alternatives查询(推荐)方法 2:检查所有已安装的 JDK方