windows 设置 rocketmq环境变量

马不停蹄的又开始了Apache RocketMQ 的学习

RocketMQ 是阿里巴巴在2012年开源的分布式消息中间件，目前已经捐赠给 Apache 软件基金会，并于2017年9月25日成为Apache 的顶级项目。作为经历过多次阿里巴巴双十一这种“超级工程”的洗礼并有稳定出色表现的国产中间件，以其高性能、低延时和高可靠等特性近年来已经也被越来越多的国内企业使用。其主要功能有1.灵活可扩展性、2.海量消息堆积能力、3.支持顺序消息、4.多种消息过滤方式、5.支持事务消息、6.回溯消费等常用功能。

使用视频

RocketMQ系统精讲，经受历年双十一狂欢节考验的分布式消息中间件_哔哩哔哩 (゜-゜)つロ干杯~-bilibiliwww.bilibili.com

安装我用的是windows版本,linux的,视频中有强调一点,不是偷懒,

而是快速学习其中的内容

下载地址

Release Notes - Apache RocketMQ - Version 4.7.1rocketmq.apache.org

配置环境变量

启动

启动NAMESERVER
Cmd命令框执行进入至‘MQ文件夹bin’下，然后执行‘start mqnamesrv.cmd’，启动NAMESERVER。成功后会弹出提示框，此框勿关闭。

操作是cmd命令窗口下,进入mq所在文件夹,然后执行下方命令

启动namesrv: start mqnamesrv.cmd
启动broker: start mqbroker.cmd -n 127.0.0.1:9876 -c ../conf/broker.conf autoCreateTopicEnable=true

也可通过bat脚本启动, 方便快速高效, 复制下面文本, 保存为bat, 双击即可

set CATALINA_HOME=你的mq解压目录
start %CATALINA_HOME%/bin/mqnamesrv.cmd
start %CATALINA_HOME%/bin/mqbroker.cmd -n 127.0.0.1:9876 -c %CATALINA_HOME%/conf/broker.conf autoCreateTopicEnable=true

window 的黑窗口别关

RocketMQ插件部署

下载
地址：https://github.com/apache/rocketmq-externals.git

git clone https://github.com/apache/rocketmq-externals.git
下载完成之后，进入‘rocketmq-externalsrocketmq-consolesrcmainresources’文件夹，打开‘application.properties’进行配置。

server.contextPath=
server.port=8080### SSL setting
#server.ssl.key-store=classpath:rmqcngkeystore.jks
#server.ssl.key-store-password=rocketmq
#server.ssl.keyStoreType=PKCS12
#server.ssl.keyAlias=rmqcngkey#spring.application.index=true
spring.application.name=rocketmq-console
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
logging.config=classpath:logback.xml
#if this value is empty,use env value rocketmq.config.namesrvAddr  NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876
rocketmq.config.namesrvAddr=127.0.0.1:9876
#if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true
rocketmq.config.isVIPChannel=
#rocketmq-console's data path:dashboard/monitor
rocketmq.config.dataPath=/tmp/rocketmq-console/data
#set it false if you don't want use dashboard.default true
rocketmq.config.enableDashBoardCollect=true
#set the message track trace topic if you don't want use the default one
rocketmq.config.msgTrackTopicName=
rocketmq.config.ticketKey=ticket#Must create userInfo file: ${rocketmq.config.dataPath}/users.properties if the login is required
rocketmq.config.loginRequired=false

编译
用CMD进入‘rocketmq-externalsrocketmq-console’文件夹，执行maven命令编译生成jar包。

mvn clean package -Dmaven.test.skip=true’，

启动
编译成功之后，Cmd进入‘target’文件夹，执行命令，启动‘rocketmq-console-ng-1.0.0.jar’。

 java -jar rocketmq-console-ng-1.0.0.jar

测试
浏览器中输入‘127.0.0.1:配置端口’，成功后即可查看。
eg：http://127.0.0.1:8088

集群篇幅省略,快速学习使用为主

解释

首先producer会去NameServer中询问一下可以为其提供服务的Broker的地址,然后再将消息投递到Broker中,(换句话来表达就是,你到邮局去寄信,你先到柜台(NameServer)问一下你要寄信,然后柜台给你分配一下窗口(Broker),然后你去窗口寄信)

然后

Consumer 的原理一样,他会去先从NameServer中获取能够为其提供服务的地址,然后找到分配的Broker并且从中获取信息(换句话说,就是你去邮局取信,你先到柜台(NameServer)问一下你要接收的信件去那个窗口(Broker)去取,然后你再到窗口去取信)

集群搭建省略

解释

实际上NameServer是无状态的,每增加一个NameServer的数量,Broker都会去新增加的节点上,上报自己的信息,所以NameServer直接启动多个就好了,然后Producer的集群搭建喝Consumer的集群搭建也是同理

唯一关注的是Broker的集群搭建

一般不同的Broker服务器会通过BrokerId进行分组区分

主节点的BrokerId=0

从节点的BrokerId=1

一个主节点可以有多个从节点