---

1.前言简介

rocketmq消息队列相关操作

各位 谨慎操作, 低版本的会被攻击呦(使用4.9.7或者5.1.1 )
建议下载更换到高版本 或者端口号10909和10911仅当前ip可访问即可

• 或者增加鉴权
  

1.2 常规mq对比

1.3 专栏传送门(rabbitmq)

=> 传送门: 分布式必备服务配置 <=

2. rocketmq使用及安装

docker镜像版本后续补充

2.0 开放端口

8000 10911 10909 9876 9877
如图所示

2.1 rocketmq版本说明

=> 传送门: rocketmq官网

rocketmq-all-4.7.0-bin-release 版本
rocketmq-all-4.9.7-bin-release 版本
source是源码下载
两个版本修改启动参数略有不同

2.2 具体操作

测试环境中 参数调整小一点

-server -Xms256m -Xmx256m -Xmn128m 

2.2.1 修改文件

• runserver.sh # 启动nameserver
• runbroker.sh # 启动broker

2.2.2 具体启动指令

nohup sh mqnamesrv &  # 启动nameserver简易注册中心
nohup sh mqbroker -n localhost:9876 &  # 启动broker 指定nameserver

ps: 查看日志

不指定输出位置, 则默认在nohup执行文件夹下生成nohup.out的文件, 即为启动日志

2.3.3 jps查看java进程

jps -l # 查看启动是否成功
ps -ef | grep java # 方法二

2.3.4 测试运行情况

rocketmq自带 生产者和消费者(测试)

=> 步骤一: 临时指定nameserver注册中心位置

export NAMESRV_ADDR=localhost:9876

=> 步骤二: 测试发送

sh tools.sh org.apache.rocketmq.example.quickstart.Producer

=> 步骤三: 测试接收

sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

3. rocketmq-console可视化界面

3.1 源码地址

下载管理页面(更换新的方法了)

git clone  https://github.com/apache/rocketmq-externals.git

3.2 打包启动方式(两种)

3.2.1 方法一: 直接下载jar包启动

可以本地拉取打包后 将jar包上传到服务器

下载地址: => 传送门: (永久免费)rocketmq-console可视化jar包 <=

3.2.2 方法二: 源码下载,maven打包

步骤一: linux上安装git

请看 3 功能

步骤二: 下载maven并打包

# yum下载maven
yum install -y maven 

# 进入下载文件位置
cd rocketmq-console 

mvn clean package -Dmaven.test.skip=true 

3.2.3 启动指令

cd target 

# 启动jar包, 指定namesrv地址
nohup java -jar rocketmq-console-ng-1.0.1.jar --server.port=8000 --rocketmq.config.namesrvAddr=150.158.151.196:9876 &

3.3 报错解决(汇总)

3.3.1 问题一: 连接nameserver超时

有docker环境, 可能会连接容器虚拟地址

# 进入rocketmq所在的文件夹下
cd conf

# 编辑conf文件
vim broker.conf 

# broker的自己IP地址
brokerIP1=192.168.1.29

关闭并启动broker服务

# 关闭broker服务
mqshutdown broker 

# 启动broker
nohup sh mqbroker -n localhost:9876 -c /usr/local/src/rocketmq/rocketmq-all-4.7.0-bin-release/conf/broker.conf &

3.3.2 问题二:

4. linux上安装git(补)

centos7.9环境上

4.1 git下载地址

传送门: => git官网下载 <=

4.2 解压git文件

tar -zxvf git-2.45.2.tar.gz

4.3 yum下载编译环境

很慢

yum install curl-devel expat-devel gettext-devel openssl-devel zlib-devel gcc perl-ExtUtils-MakeMaker

4.4 编译并安装

4.4.1 进入git-2.45.2包

cd git-2.45.2/

4.4.2 编译(相当慢)

make prefix=/opt/git all

4.4.3 安装git

make prefix=/opt/git install

4.5 配置系统环境变量PATH

4.5.1 编辑环境变量配置

vim /etc/profile

4.5.2 添加以下配置

export GIT_HOME=/opt/git
export PATH=$GIT_HOME/bin:$PATH

4.5.3 刷新配置

source /etc/profile

4.5.4 查看git版本

git --version
git -v

5. 文章的总结与预告

5.1 本文总结

• git的安装
• rocketmq的安装
• rocketmq-console的安装
• maven的安装

5.2 下文预告

• springcloud如何使用
• rocketmq进阶操作

---

@author: pingzhuyan
@description: ok
@year: 2024