写在前面

简单说明一下，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 时，指定 自动生成Topic 
start 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 配置，编译，打包，执行

Github 地址

二、基本命令

三、 客户端学习

可参考，Springboot 集成 RocketMQ 的三种方式