网站首页 > 技术文章 正文
一 RocketMQ基础
1.1 介绍
MQ是一种提供消息队列服务的中间件,也称为消息中间件,是一套提供了消息生产、存储、消费全过程API的软件系统。
RocketMQ是使用Java语言开发的一款MQ产品,经过数年阿里双11的考验,性能与稳定性非常高,其没有遵循任何常见的MQ协议,而是使用自研协议。
1.2 官网地址
https://rocketmq.apache.org/
1.3 下载地址
https://rocketmq.apache.org/zh/download
1.4 系统要求
64位操作系统,推荐 Linux/Unix/macOS
64位 JDK 1.8+
我这里使用CentOS7.8的操作系统
二 安装
2.1 下载安装包到指定路径
cd /web
wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.0/rocketmq-all-5.1.0-bin-release.zip
2.2 解压缩安装包
unzip rocketmq-all-5.1.0-bin-release.zip
mv rocketmq-all-5.1.0-bin-release/ rocketmq-5.1.0
2.3 修改初始内存
cd /web/rocketmq-5.1.0/bin
vim runserver.sh
vim runbroker.sh
2.4 新增启动脚本
cat >>setenv.sh<<EOF
export JAVA_HOME=/web/jdk1.8.0_361
export JRE_HOME=/web/jdk1.8.0_361/jre
EOF
cat >>start.sh<<EOF
#!/bin/bash
source /web/rocketmq-5.1.0/bin/setenv.sh
nohup /web/rocketmq-5.1.0/bin/mqnamesrv > /web/rocketmq-5.1.0/logs/mqnamesrv.log 2>&1 &
nohup /web/rocketmq-5.1.0/bin/mqbroker -c /web/rocketmq-5.1.0/conf/broker.conf -n "192.168.0.103:9876" > /web/rocketmq-5.1.0/logs/mqbroker.log 2>&1 &
EOF
chmod +x setenv.sh start.sh
2.5 创建日志目录
mkdir -p /web/rocketmq-5.1.0/logs
2.6 启动Name Server和Broker服务
cd /web/rocketmq-5.1.0/bin
./startRocketmq.sh
2.7 安装控制台
下载地址
https://github.com/apache/rocketmq-externals/releases
wget https://github.com/apache/rocketmq-externals/archive/refs/tags/rocketmq-console-1.0.0.zip
解压缩安装包
unzip rocketmq-console-1.0.0.zip
mv rocketmq-externals-rocketmq-console-1.0.0/rocketmq-console ./
rm -fr rocketmq-externals-rocketmq-console-1.0.0/
修改配置文件
cd /web/rocketmq-console/src/main/resources
vim application.properties
2.8 添加依赖
cd /web/rocketmq-console
vim pom.xml
<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>
2.9 打包
需要maven环境
下载安装maven
https://mirrors.cnnic.cn/apache/maven/maven-3/3.6.3/binaries/
cd /web
unzip apache-maven-3.6.3-bin.zip
mv apache-maven-3.6.3-bin maven
配置环境变量
vim /etc/profile
M2_HOME=/web/maven
export PATH=$M2_HOME/bin
生效
source /etc/profile
查看版本
mvn -v
cd /web/rocketmq-console
mvn clean package -Dmaven.test.skip=true
执行完成,会多出一个target目录。在target目录下生成了需要运行的jar包
rocketmq-console-ng-1.0.0.jar
mv rocketmq-console-ng-1.0.0.jar /web/rocketmq-console/
2.10 启动
cd /web/rocketmq-console/
nohup java -jar rocketmq-console-ng-1.0.0.jar &
tailf nohup.out
2.11 浏览器访问
http://192.168.0.103:8099
至此,RocketMQ安装完成,感谢观看,坚持下去,一起努力加油吧
- 上一篇: Java通用树结构数据管理
- 下一篇: 从放弃到入门:消息队列之RocketMQ
猜你喜欢
- 2025-01-23 记录:RocketMQ在使用上的一些排坑和优化
- 2025-01-23 消息队列选型(RabbitMq、RocketMq、Kafaka)
- 2025-01-23 Modbus新手教程(modbusrtu)
- 2025-01-23 性能调优篇:困扰我半年之久的RocketMQ timeout exception 被破解了
- 2025-01-23 RocketMQ - 如何实现顺序消息(rocketmq+-+如何实现顺序消息功能)
- 2025-01-23 10 张图 | 一文带你用 Mac M1 跑 RocketMQ
- 2025-01-23 RocketMQ - RocketMQ集群可视化的监控和管理
- 2025-01-23 RocketMQ中的线程池是如何创建的?
- 2025-01-23 手把手教你,从零开始搭建Spring Cloud Alibaba!这份笔记太牛了
- 2025-01-23 RocketMQ每秒要写入几十万并发,是怎么实现的?
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- oraclesql优化 (66)
- 类的加载机制 (75)
- feignclient (62)
- 一致性hash算法 (71)
- dockfile (66)
- 锁机制 (57)
- javaresponse (60)
- 查看hive版本 (59)
- phpworkerman (57)
- spark算子 (58)
- vue双向绑定的原理 (68)
- springbootget请求 (58)
- docker网络三种模式 (67)
- spring控制反转 (71)
- data:image/jpeg (69)
- base64 (69)
- java分页 (64)
- kibanadocker (60)
- qabstracttablemodel (62)
- java生成pdf文件 (69)
- deletelater (62)
- com.aspose.words (58)
- android.mk (62)
- qopengl (73)
- epoch_millis (61)
本文暂时没有评论,来添加一个吧(●'◡'●)