网站首页 > 博客文章 正文
一 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安装完成,感谢观看,坚持下去,一起努力加油吧
猜你喜欢
- 2025-07-21 开源|一款类excel报表设计系统,支持拖拽式和word模板设计
- 2025-07-21 SpringBoot利用ThreadPoolTaskExecutor批量插入百万级数据实测!
- 2025-07-21 云端藏经阁:一款开源、精美、可独立部署的知识管理神器
- 2025-07-21 电商秒杀/库存扣减:基于JUC的并发控制实战案例
- 2025-07-21 简单易用的.NET免费开源RabbitMQ操作组件EasyNetQ
- 2025-07-21 亿级分库分表,如何丝滑扩容、如何双写灰度
- 2025-07-21 使用mq实现分布式事务-补偿事务一致性
- 2025-07-21 【RocketMQ】消息的拉取(rocketmq消息大小)
- 2025-07-21 RocketMQ消息消费-客户端拉取消息前的准备工作
- 2025-07-21 RocketMQ消费限流的几种方式(rocketmq并发消费与顺序消费)
你 发表评论:
欢迎- 最近发表
-
- 别再用雪花算法生成ID了!试试这个吧
- Cacti监控服务器配置教程(基于CentOS+Nginx+MySQL+PHP环境搭建)
- 业务系统性能问题诊断和优化分析(业务系统性能问题诊断和优化分析报告)
- 数据库中如何批量添加指定数据(数据库批量新增数据)
- Instagram架构的分片和ID的设计(ins的分类)
- VBA数据库解决方案第十四讲:如何在数据库中动态删除和建立数据表
- MySQL数据库安装教程(mysql数据库安装方法)
- SOLIDWORKS Electrical卸载与升级安装操作步骤
- 数据库分库分表解决方案汇总(数据库分库分表思路)
- 根据工作表数据生成数据库(根据excel生成数据库表结构)
- 标签列表
-
- ifneq (61)
- 字符串长度在线 (61)
- googlecloud (64)
- flutterrun (59)
- 系统设计图 (58)
- powershellfor (73)
- messagesource (71)
- plsql64位 (73)
- promise.race (63)
- 2019cad序列号和密钥激活码 (62)
- window.performance (66)
- qt删除文件夹 (72)
- mysqlcaching_sha2_password (64)
- ubuntu升级gcc (58)
- nacos启动失败 (64)
- ssh-add (70)
- yarnnode (62)
- abstractqueuedsynchronizer (64)
- source~/.bashrc没有那个文件或目录 (65)
- springboot整合activiti工作流 (70)
- jmeter插件下载 (61)
- 抓包分析 (60)
- idea创建mavenweb项目 (65)
- qcombobox样式表 (68)
- pastemac (61)
本文暂时没有评论,来添加一个吧(●'◡'●)