2 RocketMQ Server安装

迈不过友情╰ 2021-09-09 11:32 232阅读 0赞

RocketMQ依赖Java环境，要求有JDK 1.8以上版本；

支持Windows和Linux平台；支持源码方式安装和使用已经编译好的安装包安装；

我们用windows平台安装RocketMQ Server编译好的安装包，来讲解RocketMQ；

下载地址：[https://rocketmq.apache.org/dowloading/releases/][https_rocketmq.apache.org_dowloading_releases]

我们用最新版本：4.9.0 release：[https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.0/rocketmq-all-4.9.0-bin-release.zip][https_www.apache.org_dyn_closer.cgi_path_rocketmq_4.9.0_rocketmq-all-4.9.0-bin-release.zip]

解压后的目录：  
![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-tDePCl5N-1629345524250)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210819070553886.png)\]][img-tDePCl5N-1629345524250_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210819070553886.png]  
benchmark：里面是测试Demo；

bin：可执行脚本；

conf：配置文件；

lib：依赖的jar包；

我们把rocketmq解压包放到D盘根目录，重命名`rocketmq`；

## **第一步：系统环境变量加两个配置** ##

ROCKETMQ_HOME="D:\rocketmq"
    NAMESRV_ADDR="localhost:9876"

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70]

## **第二步：启动Name Server** ##

进入命令行执行：

.\bin\mqnamesrv.cmd

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 1]

## **第三步：启动Broker** ##

进入命令行执行：

.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 2]

## **第四步：发送和接收消息测试** ##

进入命令行消息发送执行：

.\bin\tools.cmd  org.apache.rocketmq.example.quickstart.Producer

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 3]  
消息发送成功；

进入命令行消息接收执行：

.\bin\tools.cmd  org.apache.rocketmq.example.quickstart.Consumer

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 4]

消息接收成功；

## **第五步：关闭服务** ##

windows下直接关闭命令行窗口即可；

说明：这个是锋哥的RocketMQ备课笔记，等备课完，会发布配套的视频教程，如有需要，可以先加锋哥WX：java3459 欢迎白嫖

> 微信搜一搜公众号【java1234】关注这个放荡不羁的程序员，关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。

[https_rocketmq.apache.org_dowloading_releases]: https://rocketmq.apache.org/dowloading/releases/
[https_www.apache.org_dyn_closer.cgi_path_rocketmq_4.9.0_rocketmq-all-4.9.0-bin-release.zip]: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.0/rocketmq-all-4.9.0-bin-release.zip
[img-tDePCl5N-1629345524250_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210819070553886.png]: /images/20210901/0b23422351ed437aab3f083cc81e3b55.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70]: /images/20210901/e151b30a71e54bfbabe1111b2addbfd5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 1]: /images/20210901/3cc8d50d30c34e0c85813f7b4064ed84.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 2]: /images/20210901/f039475df7d64f16987647c5439dace3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 3]: /images/20210901/1fc193e95c29465db24cec320cf02b07.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhb2xpMjAxMzE0_size_16_color_FFFFFF_t_70 4]: /images/20210901/b54f65f450b74d1999384354d23a44c1.png