欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

程序员文章站 2022-03-05 12:20:53
...

1.RocketMQ 介绍

Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

  • RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。同时,广泛应用于多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等

具有以下特点:

  • 能够保证严格的消息顺序
  • 提供丰富的消息拉取模式
  • 高效的订阅者水平扩展能力
  • 实时的消息订阅机制
  • 亿级消息堆积能力

2.RocketMQ 基本使用

2.1 下载 RocketMQ

  • 使用浏览器打开:
  • 传送门
  • 这里我们选择 4.4.0 版本的原因在于,我们 spring cloud alibaba 版本为:2.2.0.RELEASE,它里面控制的 rocketMQ 的版是 4.4.0
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

2.2 RocketMQ 目录分析

  • 将该压缩包复制到软件目录里面,使用压缩软件进行解压
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用
  • Benchmark:包含一些性能测试的脚本;
  • Bin:可执行文件目录;
  • Conf:配置文件目录;
  • Lib:第三方依赖;
  • LICENSE:授权信息;
  • NOTICE:版本公告;

2.3 配置环境变量

  • 找到配置环境变量的对话框:
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用
  • 点击新建创建一个环境变量:
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用
  • 变量名:ROCKETMQ_HOME
  • 变量值:D:\devtools\rocketMQ\rocketmq-all-4.4.0-bin-release

2.4 RocketMQ 的启动

  • 我们进入到${rocketMQ}/bin,在此目录里面启动和停止命令。

2.4.1 启动 NameServer

Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

  • 注意:弹出的黑窗口不要关闭

2.4.2 启动 Broker

  • ./mqbroker.cmd -n localhost:9876
  • 其中:
  • -n localhost:9876 是为了指定 nameserver 的地址
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

2.5 RocketMQ 的停止

  • 直接把弹出的黑框关闭,即可停止 RocketMQ 的 namesrv 和 broker。

2.6 RocketMQ 控制台的安装

  • Rocketmq 控制台可以可视化 MQ 的消息发送!

2.6.1 下载 RocketMQ 控制台

  • 直接从官网下载的是源码
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

2.6.2 复制到软件目录里面

Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用

2.6.3 运行该 jar

  • java -jar rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr=127.0.0.1:9876
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用
  • 其中:
--rocketmq.config.namesrvAddr=127.0.0.1:9876 是为了指定 nameserver 的地址
  • 运行成功后:
  • 访问:
    http://localhost:8080/#/
    Java Spring Cloud Alibaba-RocketMQ:(一)RocketMQ 介绍以及基本使用