RocketMQ 安装以及测试

本贴最后更新于 1598 天前,其中的信息可能已经东海扬尘

RocketMQ 简介

RocketMQ 是阿里巴巴 2016 年 MQ 中间件,使用 Java 语言开发,在阿里内部,RocketMQ 承接了例如“双 11”等高并发场景的消息流转,能够处理万亿级别的消息。

RocketMQ 的安装

点击官方下载链接,会看到 RocketMQ 的各个版本,目前最新的发行版是 4.5.2,点击下载二进制文件进行安装。
image.png
下载完后,将其放到要安装的服务器或虚拟机上,这里以 linux 系统为例。
使用命令将其剪切到 /usr/local/ mv rocketmq-all-4.5.2-bin-release.zip /usr/local/,然后进行解压 unzip rocketmq-all-4.5.2-bin-release.zip
安装完成!

启动 RocketMQ

  1. 启动 NameServer
    进入安装目录的 bin 文件夹下,执行命令 nohup sh mqnamesrv & 启动 NameServer。使用 tail -f ~/logs/rocketmqlogs/broker.log 查看启动日志。

image.png
表示启动成功。如果启动失败就先修改两个配置文件 runbroker.sh 和 runserver.sh,这两个文件都在 bin 目录,先说明怎样改第一个配置文件 vim runbroker.sh,将里面的这三个 JVM 参数调低,-Xms256m -Xmx256m -Xmn128m。然后对于 runserver.sh 配置文件也做同样的更改。下图所示是更改位置。

image.png

  1. 启动 Broker
    执行 nohup sh mqbroker autoCreateTopicEnable=true -n localhost:9876 & 启动 Broker,tail -f ~/logs/rocketmqlogs/broker.log

image.png

启动成功!

测试 RocketMQ

1、打开两个终端,分别进入 MQ 的 bin 目录,一个发消息,一个收消息。
2、发消息端配置
先设置环境变量,export NAMESRV_ADDR=localhost:9876,使用安装包的 Demo 发送消息 sh tools.sh org.apache.rocketmq.example.quickstart.Producer
image.png

正在发送消息ing。
3、接受消息端配置
先设置环境变量,export NAMESRV_ADDR=localhost:9876,接受消息 sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
image.png
成功!此时发送端再执行发送消息命令,接受端就会自动打印第二次发送端发送的消息了。

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...