MacOS安装RocketMQ+RocketMQ_console消息中间件以及控制台（亲测有效 直接CV）_macos 安装rocketmq

前提

安装RocketMQ运行需要先安装服务才能使用，若要可视化界面，必须安装RocketMQ_console，否则可以通过终端命令行操作进行查看消息队列的服务

RocketMQ
1.环境准备

前提是电脑上已经安装了JDK
2.下载
官网地址：http://rocketmq.apache.org/docs/quick-start/
点此跳转


点击“这里”下载即可
然后～
解压5.1.0的源码包并编译构建二进制可执行文件
记得去掉”$"号

$ unzip rocketmq-all-5.1.0-source-release.zip
$ cd rocketmq-all-5.1.0-source-release/
$ mvn -Prelease-all -DskipTests -Dspotbugs.skip=true clean install -U
$ cd distribution/target/rocketmq-5.1.0/rocketmq-5.1.0```
1
2
3
4

然后～
3.启动RocketMQ
预备：
前提！！！！（必看 启动失败的话 ）：
修改内存配置大小：RocketMq默认内存较大，启动Borker如果因为内存不足启动失败，需要修改如下配置文件，修改JVM内存大小，进入distribution下面的bin文件夹，修改JAVA_OPT

>vim bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -
XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改为：
AVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"


...
> vim bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
修改为：
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
1
2
3
4
5
6
7
8
9
10
11
12
13

参数介绍：
-Xmx4g 初始堆大小 4g
-Xms4g 最大堆大小4g
-Xmn512m 年轻代大小(1.4or lator)整个JVM内存大小=年轻代大小 + 年老代大小 + 持久代大小。持久代一般固定大小为64m，所以增大年轻代后，将会减小年老代大小。此值对系统性能影响较大，Sun官方推荐配置为整个堆的3/8

运行：

知识补充：由于RocketMQ是由alibaba孵化的 所有有一定属性和Nacos差不多 
所以 有主从服务器，要先启动nameserver，再启动broker（可以学习一下RocketMQ相关知识点）
1
2

启动顺序：先启动nameserver，再启动broker
进入rocketMq目录执行下面命令启动nameserver

# nohup用于在系统后台不挂断地运行命令，退出终端不会影响程序的运行。
# &：让命令在后台执行，终端退出后命令仍旧执行。
nohup sh bin/mqnamesrv &
1
2
3

日志查看：

tail -f ~/logs/rocketmqlogs/namesrv.log
1

进入rocketMq目录执行下面命令启动broker

# nohup用于在系统后台不挂断地运行命令，退出终端不会影响程序的运行。
# &：让命令在后台执行，终端退出后命令仍旧执行。
nohup sh bin/mqbroker -n localhost:9876 &
1
2
3

日志查看：

tail -f ~/logs/rocketmqlogs/broker.log
1

也可以直接查看启动日志（就是两个一起看）

cat nohup.out
1

查看nameserver和broker是否成功启动

jps
1

(如果出现NameserverStartup和BrokerStartup就说明启动成功了。

)

3.测试：
三.测试发消息
配置NAMESRV_ADDR到环境变量里

vim ~/.bash_profile
1

将 export NAMESRV_ADDR=localhost:9876 配置进去，然后更新配置使其生效

source .bash_profile
1

发消息：在distribution/target/rocketmq-4.7.0/rocketmq-4.7.0下(生产者)

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
1

可以看到已经在发消息了（消费者）
收消息：

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
1

建议开两个终端测试发收消息。
以上就是rocketMQ的安装了。

4.关闭：
关闭顺序：先关闭broker，再关闭nameserver

关闭broker
sh bin/mqshutdown broker
关闭nameserver
sh bin/mqshutdown namesrv
1
2
3
4

Web界面控制台：
访问：localhost:80xxx
可查询生产者消费者队列以及主题信息等

1、下载工程代码： https://github.com/apache/rocketmq-externals/releases/tag/rocketmq-console-1.0.0
点击此处链接
2、idea mvn工程导入工程代码：修改namesrv地址即可；
PS：有需要可以修改启动端口～～～

3、启动：
先打包

mvn clean package -Dmaven.test.skip=true
1

然后运行jar包

java -jar target/rocketmq-console-ng-1.0.0.jar
1

额外补充：
命令行管理工具

上面已经讲过命令行管理工具已经包含在RocketMQ项目中，我们进入项目下的bin文件夹，并执行命令bash mqadmin,有命令和详细说明。具体如何使用这些命令，可以通过执行bash mqadmin help 来了解细节，我们以常用命令updateTopic为例，执行bash mqadmin help updateTopic,打印如下信息：

举例：创建topic： bash mqadmin updateTopic -n ‘127.0.0.1:9876’ -b ‘10.236.128.69:10911’ -t magicpill_topic

官方开发文档资料：

https://rocketmq-1.gitbook.io/rocketmq-connector/