RocketMQ-4.9.2安装与启动
修改主机名:修改克隆机的ip:单机安装步骤:1.下载:2.安装环境:64bit OS, Linux/Unix/64bit JDK 1.8+;Maven 3.2.x;Git;4g+ 内存以上上传并解压:unzip rocketmq-all-4.9.2-source-release.zip启动 Name Server:启动:nohup sh bin/mqnamesrv &查看日志:tail -
目录
一、克隆一台用于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
更多推荐
所有评论(0)