合肥建网站b站推广2024mmm已更新
阿里开源的基于MVC架构，JAVA语言开发的，异步的消息序列；消息流转模型；
MQ:MessageQueue消息队列，消息是在不同进程之间传递的数据，可以是一台机器也可以分布在不同机器。队列是具有FIFO特性的结构，用来缓存数据的。
MQ的主要作用：
异步；解耦；削峰
安装
官方下载版本 ：下载 | RocketMQ
下载Binary后解压到本地，如下图：
环境配置
一：配置内存大小
基于自己电脑的配置设置rocketmq的大小
1.bin目录下runserver.sh文件，根据自己jdk的版本，如果为8及以下的调整绿色箭头else之前的;9及以后的放入else之后
调整-Xms4g -Xmx4g （以自己的实际为准，太小了容易OOM）
2.bin目录下runbroker.sh文件，调整 -Xms8g -Xmx8g （以自己的实际为准，太小了容易OOM）
注意：可能会因为jdk版本的问题导致GC失败，加上XX:+UnlockExperimentalVMOptions -XX:+UseG1GC即可如下：
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -XX:+UnlockExperimentalVMOptions -XX:+UseG1GC"
二：启动：
【1】启动NamesrvStartup
1.建一个logs文件夹
2.然后执行 nohup ./mqnamesrv > ../logs/namesrv.log 2>&1 &
3.检查namesrv.log文件发现结尾处有 The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876就成功了；
【2】启动mqbroker
1.给配置环境变量
vim ~/.bash_profile 加入 export NAMESRV_ADDR=localhost:9876 ;
保存完成然后执行 source ~/.bash_profile让配置生效
2.执行 nohup ./mqbroker > ../logs/mqbroker.log 2>&1 &
3.检查mqbroker.log 结尾出现The broker[MacBook-Air.local, IP:10911] boot success. serializeType=JSON and name server is localhost:9876就算成功
整体运行成功就是这样：
测试：
1.bin路径下执行 ./tools.sh org.apache.rocketmq.example.quickstart.Producer
2.看到消息发送成功
3.接受消息，同样bin下执行 ：./tools.sh org.apache.rocketmq.example.quickstart.Consumer
这样就成功了恭喜你安装完整！