SpringBoot SpringBoot 开发实用篇 5 整合第三方技术 5.25 RocketMQ 安装

SpringBoot

【黑马程序员SpringBoot2全套视频教程，springboot零基础到项目实战（spring boot2完整版）】

SpringBoot 开发实用篇

5 整合第三方技术

5.25 RocketMQ 安装

5.25.1 RocketMQ 下载

官方下载地址：https://rocketmq.apache.org/

哇哦，炫酷的官网

这里笔者也不下了【要下的话点Binary那个】，直接用李老师的资源

5.25.2 安装

笔者就直接复制到E 盘

直接解压就好

可以把版本号去掉

OK，进入目录

• bin：二进制，启动文件…
• conf：配置文件
• lib：依赖jar 包
• benchmark：功能

【配置环境变量】

要配三个

ROCKETMQ_HOME

NAMESRV_ADDR

修改PATH

OK，确定保存

5.25.3 使用

先来解释下 NAMESRV_ADDR 这玩意儿到底是什么？

当我们在进行消息的发送与接收的时候，其实主要的工作就是将消息发给业务服务器，然后业务服务器进行处理，这时候就有个问题

现在有一个业务服务器，生产者和消费者都去连接它，没啥问题

但是如果后面新增 了业务服务器，数量变多了，【减缓压力、不同业务…】

这个时候生产者和消费者需要连接的业务服务器的数量就发生了变化

就变成了这个亚子，每一个都要去连接【这样就变得繁琐了 】

【如何解决这个问题？】

搞一个命名服务器，当这个NameServer 出现后，所有下面的业务服务器都和它打交道

在启动时，它们会把自己的信息注册到命名服务器中，一旦注册，命名服务器就知道了现在有多少台业务服务器

然后生产者和消费者在工作的时候，就不会直接去连接业务服务器了，它会连接命名服务器

通过nameserver 他们俩就知道了哪个服务器在为他提供服务

【所以先启动命名服务器】

进入bin 目录

先双击下面那个，命名服务器

笔者报错了

我nm 服了，改一下吧

我直接重装一个Java 8 新版本

改一下Java 的环境变量

再试一次

OK了，什么玩意儿…

这样命名服务器就启动成功了

启动broker 服务器

双击这个【双击容易闪退】

直接用命令的办法

OK，broker 也跑起来了

测试一下能不能用，用官方给的测试程序

输入命令，生产一些消息

tools org.apache.rocketmq.example.quickstart.Producer

• TopicTest：后面要用
• brokerName：服务器名
• sendStatus：发送成功
• queueId：可以看出一共有4个队列
• queueOffset：队列偏移量

运行消费者

tools org.apache.rocketmq.example.quickstart.Consumer

运行命令

每一条中，body就是发的东西，一个字节数组

这两个命令能够跑就行了，证明服务器安装正常

回顾一下

5.23.4 小结

1. RocketMQ下载与安装（环境变量配置）
2. 命名服务器启动（控制台）
3. broker服务启动（控制台）
4. 消息生产消费测试