Centos7.6搭建RocketMQ4.8全纪录-低调大师

Centos7.6搭建RocketMQ4.8全纪录

2021-06-16 735

环境说明

ip地址	主机名	操作系统版本	RocketMQ版本	JDK版本	maven版本
172.16.7.91	rabbitmq01	centos 7.6	4.8.0	1.8.0_291	3.6

一、安装jdk

1.下载jdk

下载地址：https://www.oracle.com/java/technologies/javase/javase-jdk8-downloads.html

2.安装jdk

新建目录/opt/java并将下载的包jdk-8u291-linux-x64.rpm 上传

[root@rabbitmq01 ~]# mkdir /opt/java 
[root@rabbitmq01 ~]# cd /opt/java
[root@rabbitmq01 java]# rpm -ivh jdk-8u291-linux-x64.rpm

二、安装maven

1.下载安装包

[root@rabbitmq01 ~]# wget https://mirrors.tuna.tsinghua.edu.cn/apache/maven/maven-3/3.6.3/binaries/apache-maven-3.6.3-bin.tar.gz

也可以到官网下载，下载地址：http://maven.apache.org/download.cgi

2.解压并配置环境变量

[root@rabbitmq01 ~]# tar -zxvf apache-maven-3.6.3-bin.tar.gz -C /usr/local/
[root@rabbitmq01 ~]# mv /usr/local/apache-maven-3.6.3/ /usr/local/maven3.6
[root@rabbitmq01 ~]# sed -i '$a export PATH=$PATH:/usr/local/maven3.6/bin' /etc/profile && source /etc/profile
[root@rabbitmq01 ~]# mvn -v

3.maven优化

3.1配置阿里源

[root@rabbitmq01 ~]# cd /usr/local/maven3.6/conf/
[root@rabbitmq01 conf]# view settings.xml

修改后：

<url>http://maven.aliyun.com/nexus/content/groups/public/</url>

3.2指定资源下载路径

<localRepository>/usr/local/maven3.6/repository</localRepository>

3.3指定JDK版本

将默认的1.4替换为实际的1.8

三、RocketMQ安装

1.版本选取

下载地址：https://github.com/apache/rocketmq/tags

本次选择的版本为最新的4.8.0

2.下载安装包

[root@rabbitmq01 ~]# wget https://github.com/apache/rocketmq/archive/refs/tags/rocketmq-all-4.8.0.tar.gz

3.编译方式安装

[root@rabbitmq01 ~]# tar -zxvf rocketmq-all-4.8.0.tar.gz
[root@rabbitmq01 ~]# cd rocketmq-rocketmq-all-4.8.0/
[root@rabbitmq01 rocketmq-rocketmq-all-4.8.0]# mvn -Prelease-all -DskipTests clean install -U

4.免编译安装

除了使用maven编译安装方式外，还可以直接下载带bin的安装包，免编译安装，步骤3和步骤4执行一个就行。

下载地址：https://apache.claz.org/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip

[root@rabbitmq01 ~]# mkdir rocketmq
[root@rabbitmq01 ~]# cd rocketmq/
[root@rabbitmq01 rocketmq]# wget https://apache.claz.org/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip

rocketmq-all-4.8.0-bin-release.zip带bin版本的介质无需maven编译，解压后即可使用。

5.调整runserver.sh参数

调整前：

JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

调整后：

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

6.调整runbroker.sh参数

调整前：

JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"

调整后：

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

由于默认启动的最大内存比较大，需要修改小点保证服务能正常启动。

7.启动namesrv

[root@rabbitmq01 bin]# nohup sh mqnamesrv &

namesrv启动成功

8.启动broker

[root@rabbitmq01 bin]# nohup sh mqbroker -n localhost:9876 &

broker节点启动成功

9.查看服务是否启动成功

[root@rabbitmq01 ~]# jps -l
41467 org.apache.rocketmq.broker.BrokerStartup
41214 org.apache.rocketmq.namesrv.NamesrvStartup
43887 sun.tools.jps.Jps

namesrv和broker启动正常

四、消息收发测试

1.生产者发送消息

[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# export NAMESRV_ADDR=localhost:9876
[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

消息测试，生产者发送大量的消息。

2.消费者消费消息

[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

五、安装管理面板

1.介质下载

git下载介质

[root@rabbitmq01 ~]# yum -y install git
[root@rabbitmq01 ~]# git clone https://github.com/apache/rocketmq-externals.git

或者下载到本地再上传，下载地址：https://github.com/apache/rocketmq-externals/archive/refs/heads/master.zip

这里选择先下载再上传方式

2.解压

[root@rabbitmq01 ~]# unzip rocketmq-externals-master.zip

3.修改配置文件

[root@rabbitmq01 resources]# pwd
/root/rocketmq-externals-master/rocketmq-console/src/main/resources
[root@rabbitmq01 resources]# view application.properties

自定义应用端口和nameserver端口

4.编译

[root@rabbitmq01 rocketmq-console]# pwd
/root/rocketmq-externals-master/rocketmq-console
[root@rabbitmq01 rocketmq-console]# mvn clean package -Dmaven.test.skip=true

编译过程如图，中间过程省略

编译成功，console目录下会生成target目录

5.运行

[root@rabbitmq01 rocketmq-console]# cd target/
[root@rabbitmq01 target]# java -jar rocketmq-console-ng-2.0.0.jar

6.访问console

原因是跨域造成的，需要修改服务器中broker的配置，添加服务器IP即可

六、重启服务

1.关闭服务

[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# pwd
/root/rocketmq/rocketmq-all-4.8.0-bin-release
[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# sh bin/mqshutdown broker
No mqbroker running.
[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# sh bin/mqshutdown namesrv
No mqnamesrv running.

关闭服务时先停止broker再停止namesrv

2.修改broker配置

[root@rabbitmq01 ~]# sed -i '$a brokerIP1=172.16.7.91' /root/rocketmq/rocketmq-all-4.8.0-bin-release/conf/broker.conf

3.开启服务

[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# pwd
/root/rocketmq/rocketmq-all-4.8.0-bin-release
[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# nohup sh bin/mqnamesrv &
[root@rabbitmq01 rocketmq-all-4.8.0-bin-release]# nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &

启动服务时先启动nameserv再启动broker

启动完成

3.重新登陆console

七、自启动脚本

1.rocketmq服务脚本

[root@rabbitmq01 init.d]# pwd
/etc/rc.d/init.d
[root@rabbitmq01 init.d]# touch rocketmq
[root@rabbitmq01 init.d]# chmod u+x rocketmq

在/etc/rc.d/init.d下新建服务rocketmq，根据实际情况修改配置参数。

2.rocketmq服务启停测试

[root@rabbitmq01 ~]# service rocketmq stop
[root@rabbitmq01 ~]# service rocketmq start
[root@rabbitmq01 ~]# service rocketmq restart

3.rocketmq_console自启停脚本

[root@rabbitmq01 init.d]# touch rocketmq_console
[root@rabbitmq01 init.d]# chmod u+x rocketmq_console
[root@rabbitmq01 init.d]# more rocketmq_console

4.rocketmq_console服务启停测试

[root@rabbitmq01 ~]# service rocketmq_console stop
[root@rabbitmq01 ~]# service rocketmq_console start
[root@rabbitmq01 ~]# service rocketmq_console restart

5.设置服务开机启动

[root@rabbitmq01 ~]# systemctl enable rocketmq
[root@rabbitmq01 ~]# systemctl enable rocketmq_console
[root@rabbitmq01 ~]# chkconfil --list

设置完成后开机会自启动namesrv、broker和console服务

搭建完成，配置和软件包已上传github：RocketMQ_install

微信关注我们

原文链接：https://blog.51cto.com/u_3241766/2908731

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

顺序栈实现C++

顺序栈实现C++ 分析栈的初始化入栈出栈遍历取栈内元素取栈顶元素完整代码分析如果要实现一个顺序栈，首先我们就需要有个静态数组，同时还需要有个数组的长度。其次呢我们需要有两个指针，一个指针指向栈顶，一个指向栈底（主要是方便入栈，出栈操作方便）栈的初始化有了这个思路之后，我们就可以进行栈的初始化了。那么初始化的需要让咱们栈有个固定长度吧，那我们就得给他分配一个数组，其次呢，一开始阶段，我们栈里（目前是个数组）是什么值都没有的，所以我们就需要让两个指针指向数组的最底部吧。有了这些基础之后，我们就可以用代码实现啦。代码见下：内联代码片。 1.定义一个长度 #define MAXSIZE 100 2.需要定义一个结构体，存长度以及两个指针。来表示栈 3.定义一个int类型的新变量typedef int SElemType; （为了方便而定义，不定义用int也行） 4.初始化（即定义一个数组，和两个指针指向相等）。 //顺序栈（后进先出） #include<stdio.h> #include<stdlib.h> #define MAXSIZE 10...

2021-06-16

702

XML <?xml version="1.0" encoding="utf-8"?> <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" tools:context=".checkbox"> <TextView android:id="@+id/showresult" android:layout_width="150dp" android:layout_height="30dp" android:layout_marginTop="68dp" andr...

2021-06-16

568

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。