一、克隆一台用于rocketmq的linux虚拟机:

查看当前虚拟机有没有安装jdk:发现是jdk1.8,
则我们用centos7.7进行克隆:
在这里插入图片描述

关闭当前虚拟机:
在这里插入图片描述
克隆:

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
定义新虚拟机名字和存贮位置:
在这里插入图片描述

在这里插入图片描述

二、配置host文件:

hosts文件位置如下:

Windows/System32/drivers/etc

在这里插入图片描述
添加如下配置:
在这里插入图片描述

三、修改主机名,配置虚拟机的ip地址:

ip地址自己根据自己centos网络配置进行更改:
因为我克隆出来的ip地址是192.168.211.210,所以我配置成那样。

(1)centos修改主机名:

vim /etc/hostname
名字直接修改成: rocketmqOS
然后保存退出

(2)修改克隆机的ip:

配置当前虚拟机的网络配置文件:
vim /etc/sysconfig/network-scripts/ifcfg-ens33
修改内容如下,修改后重启reboot机器

在这里插入图片描述

重启后,记得输密码重新登录:
然后记得修改ip地址后重新连接:我这里用的xshell连接的:
在这里插入图片描述

四、RocketMQ单机安装步骤:

在这里插入图片描述

1. 准备安装环境:

Linux/Unix:64bit OS
64bit JDK 1.8+;
Maven 3.2.x;
Git;
4g+ 内存以上

2. 下载RocketMQ安装包:

地址:https://rocketmq.apache.org/
在这里插入图片描述注意:打开 RocketMQ 官方文档, 我们选择已编译的版本(bin版本)下载,省去 Maven 编译的过程

在这里插入图片描述

在这里插入图片描述

3. 上传linux并解压:

(1)自定义上传到的目录:/usr/src/software
在这里插入图片描述

(2)去到上传目录,解压安装包:

cd /usr/src/software
unzip rocketmq-all-4.9.2-bin-release.zip

在这里插入图片描述

4. 修改初始内存:

安装好后的RocketMQ默认的虚拟机内存较大。为了防止启动失败,报内存不足,我们提前修改下JVM内存参数值。
(4.1)修改runserver.sh:

cd /usr/src/software/rocketmq-4.9.2/bin
cp runserver.sh runserver_bk.sh
vim runserver.sh

4.9.0版本:
在这里插入图片描述
4.9.2版本:
在这里插入图片描述
然后保存退出即可。

(4.2)修改runbroker.sh:

cp runbroker.sh runbroker_bk.sh
vim runbroker.sh

4.9.0版本:
在这里插入图片描述
4.9.2版本:
在这里插入图片描述

5. RocketMQ启动:

5.1 启动 Name Server:

cd /usr/src/software/rocketmq-4.9.2
启动:nohup sh bin/mqnamesrv &
查看日志:tail -f ~/logs/rocketmqlogs/namesrv.log

在这里插入图片描述

启动后查看进程:
在这里插入图片描述
5.2 启动 Broker:

cd /usr/src/software/rocketmq-4.9.2
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log

启动成功后标志:
在这里插入图片描述

查看存储空间:

ll store/

在这里插入图片描述

6. 发送/接收消息测试:

发送测试消息:
cd /usr/src/software/rocketmq-4.9.2
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
出现:SendResult [sendStatus=SEND_OK, msgId= …表示成功

在这里插入图片描述

接收测试消息:
cd /usr/src/software/rocketmq-4.9.2
这个必须要加:export NAMESRV_ADDR=127.0.0.1:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

在这里插入图片描述

Shutdown Servers:

sh bin/mqshutdown broker

sh bin/mqshutdown namesrv

7. 控制台的安装与启动:

控制台的应用程序下载地址: https://github.com/apache/rocketmq-externals/tags

国外网速都比较慢: https://github.com/apache/rocketmq-externals

直接下载并解压到windows机器下。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
windows下直接解压即可:

修改默认的控制台端口号;
在这里插入图片描述
在这里插入图片描述

修改pom文件:

在这里插入图片描述

在这里插入图片描述

<!--jaxb 用于xml绑定java技术,是一个行业标准,是一项可以
        根据xml.schema生成java类的技术-->
 <dependency>
     <groupId>javax.xml.bind</groupId>
     <artifactId>jaxb-api</artifactId>
     <version>2.3.0</version>
 </dependency>
 <dependency>
     <groupId>com.sun.xml.bind</groupId>
     <artifactId>jaxb-impl</artifactId>
     <version>2.3.0</version>
 </dependency>
 <dependency>
     <groupId>com.sun.xml.bind</groupId>
     <artifactId>jaxb-core</artifactId>
     <version>2.3.0</version>
 </dependency>
 <dependency>
     <groupId>javax.activation</groupId>
     <artifactId>activation</artifactId>
     <version>1.1.1</version>
 </dependency>

打包控制台项目为jar包:

mvn clean package -Dmaven.test.skip=true

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

关闭防火墙:systemctl stop firewalld
先到target目录下,人后输入cmd,然后在控制台执行以下命令:
启动jar: java -jar rocketmq-console-ng-1.0.0.jar
运行jar文件会报错,但是不影响浏览器打开控制台。
在这里插入图片描述

浏览器打开控制台:localhost:7000

在这里插入图片描述

五、集群搭建:

集群搭建链接: https://blog.csdn.net/weixin_38568503/article/details/121771040

Logo

更多推荐