写在前面
简单说明一下,RocketMQ是阿里团队开发,并推到Apache社区,它的入门稍微有点难(主要是环境、网络、社区的资源有限),下面我简单介绍一下
一、安装、部署
这里包括三个
- Windows单机
- Linux单机
- linux多主多从
上文中说到的难点就是,Linux 的版本学习,本地可以部署成功,但客户端Client连接,总是连接不上
这里我先介绍下 本地Windows的版本学习
1.1、Windows单机版
1.1.1、基本环境
- 64bit
- 64bit JDK 1.8+;
- Maven
- Git
三种安装方式,
- 源码
- 二进制文件
- docker
这里我介绍下,二进制的安装方式
然后 解压 -> 配置环境变量 -> 修改配置 -> 启动 nameserver -> 启动 broker
1.1.2、需要注意的地方
- 配置环境变量 ,一定要 用 ROCKETMQ_HOME 来标识
- 修改配置,单机版,只要修改 启动配置即可
修改 这两个配置文件的启动 内存分配,调小 如下
-server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m
1.1.3、启动服务
先启动 mqnamesrv.cmd
再启动 mqbroker.cmd
注意启动Broker 时,指定 自动生成Topicstart mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
1.1.、配置控制台
这里,我有 打好的包,在这里(仅适合本地单机版)
https://kdocs.cn/l/ce6BAkTZo
[金山文档] rocketmq-console-ng-1.0.1.jar
也可从官网,下载源码,修改nameserver 配置,编译,打包,执行