Rocket MQ 部署 | 学习笔记

简介: 快速学习 Rocket MQ 部署代理,介绍了 Rocket MQ 部署系统机制, 以及在实际应用过程中如何使用。

开发者学堂课程【微服务实战-RocketMQ Binder Rocket MQ 部署代理】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/617/detail/9419


Rocket MQ 部署


内容介绍:

一、 Rocket MQ 单机部署

二、 Rocket MQ 集群部署(2m-noslave


一、Rocket MQ 单机部署

1、Rocket MQ 单机部署步骤

首先需要下载 Rocket MQ 的安装包,它是一个 zip 压缩包,然后对压缩包进行解压,解压之后启动 Nameserver 和 Broker ,最后查看 nameserver 和 broker 日志,确保启动成功。

2、具体操作过程:

首先进入官网,它的域名是 rocketmq.apache.org

image.png

进入官网之后,看到 Latest release v4.5.1 为最新版本,

image.png

然后进入,进入之后有两个下载地址,分别为

Source:rocketmq-all-4.5.1-source-release.zip [PGP][SHA512]

Binary: rocketmq-all-4.5.1-bin-release.zip [PGP] [SHA512]

选择进入 Binary 二进制的链接,它推荐了下载的最佳地址,进行拷贝后进入 Binary 目录,然后启动 Nameserver ,等待 Rocket MQ Nameserver 的启动,启动成功,接下来启动 mqbroker ,此时需要指定 Nameserver 的地址,默认 Nameserver 的端口是9876Broker 启动成功,它的端口对应的是10911

3、安装详细

1下载 RocketMQ 安装包:

$wget http://mirror.cogentco.com/pub/apache/rocketma/4.4.0/rocketmq-all-4.4.0-bin-release.zip·

2解压安装包:

$ unzip rocketmq-all-4.4.0-bin-release.zip

(3) 启动 nameserver&broker:

$ nohup sh bin/mqnamesrv &

$ nohup sh bin/mqbroker -n localhost:9876 &

(4) 查看 nameserver 和 broker 日志,确保启动成功

$ tail -f ~/logs/rocketmqlogs/namesrv.log

The Name Server boot success...

$ tail-f ~/logs/rocketmqlogs/broker.log

The broker[%s,172.30.30.233:10911] boot success..


二、Rocket MQ 集群部署

1、目前 Rocket MQ 集群部署支持三种方式:

单 Master 二多 Master ,多 Master 多 Slave 。

2、与单机部署的区别

PPT 上介绍的是多 Master 方式,它跟单机部署的区别是,在启动 broker 的时候不需要加上一个隐藏数,之后可以指定 broker 配置文件,看这里,分别指定了两个broker 配置文件是 brokera brokerb ,在 brokera 上,它的配置文件里面,它的 brokername 是 broker-a ,在 broker-b 的配置文件上它的 brokername 是 broker-b。

当然启动完毕之后,要去查询 broker 是否启动成功,如果控制台显示两个 broker,表示部署成功。

3、安装详细

1下载 RocketMQ 安装包:$wgethttp://mirror.cogentco.com/pub/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-bin-release.zip

2解压安装包:

$unzip rocketmq-all-4.4.0-bin-release.zip

3不是集群 nameserver:

进入192.168.1.10启动

nameserver:$nohupshbin/mqnamesrv&

进入192.168.1.11启动

nameserver:$nohupshbin/mqnamesrv&

4修改各节点 broker 配置并启动

进入192.168.11编辑预制的配置文件

conf/2m-noslave/broker-aproperties,追加 namesrv 地址

启动

brokera:$nohupshbin/mgbrokerc/cont/2m-noslave/broker-aproperties

进入192.168.1.2编辑预制的配置文件

conf/2m-noslave/broker-bproperties, 追加 namesrv 地址

启动

broker-b:$nohupshbin/mqbroker-c/conf/2m-noslave/broker-b.properties.

5查看 nameserver 和 broker 日志,确保启动成功

$sh bin/mgadmin

clusterlist-n192168110:9876192168111:9876控制台显示两个broker表示部署成功

namesrvAddr=192.168.110:9876;192.168.1.11:9876

brokerClusterName=DefaultCluster brokerName=broker-a brokerld=0

deleteWhen=04

fileReservedTime=48

brokerRole=ASYNC MASTER flushDiskType=ASYNC_FLUSH

namesrvAddr=192.1681109876192168.1.11:9876

brokerClusterName=DefaultCluster brokerName=broker-b brokerld=0

deleteWhen=04

fileReservedTime=48

brokerRole=ASYNC MASTER flushDiskType=ASYNC FLUSH

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
3月前
|
消息中间件 编解码 Docker
Docker部署RabbitMQ消息中间件
【7月更文挑战第4天】Docker部署RabbitMQ消息中间件
242 3
|
1月前
|
NoSQL 关系型数据库 Redis
mall在linux环境下的部署(基于Docker容器),Docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongo
mall在linux环境下的部署(基于Docker容器),docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongodb、minio详细教程,拉取镜像、运行容器
mall在linux环境下的部署(基于Docker容器),Docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongo
|
2月前
|
消息中间件 存储 Kubernetes
k8s快速部署rocketMq及rocketMq-console-ng
k8s快速部署rocketMq及rocketMq-console-ng
|
2月前
|
消息中间件 监控 数据可视化
安装部署RabbitMQ
安装部署RabbitMQ
|
3月前
|
消息中间件 数据可视化 RocketMQ
【RocketMQ系列二】通过docker部署单机RocketMQ
【RocketMQ系列二】通过docker部署单机RocketMQ
855 4
|
4月前
|
消息中间件 Kubernetes Android开发
消息队列 MQ产品使用合集之如何在kubernetes环境里面部署
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
|
4月前
|
消息中间件 监控 RocketMQ
Docker Compose 一键快速部署 RocketMQ
Docker Compose 一键快速部署 RocketMQ
77 0
|
5月前
|
消息中间件 Shell 数据处理
rocket mq 查看消费进度,消息堆积,清除堆积数据命令
该内容是关于RocketMQ的消费进度管理和堆积数据处理的指导。首先,需进入RocketMQ的bin目录,然后使用`mqadmin consumerProgress`命令查看消费者或生产者的消费进度。`broker offset`和`consumer offset`的差值表示未消费消息。通过`resetOffsetByTime`命令可重置消费位点来清除堆积数据,未消费消息默认3天后会被丢弃。此外,`CONSUME_FROM WHERE`枚举类定义了消费起点选项,包括从最后、最开始或指定时间点消费。
1239 3
|
4月前
|
消息中间件 存储 数据安全/隐私保护
docker部署rabbitmq
docker部署rabbitmq
54 0
|
4月前
|
消息中间件 Apache C语言
消息队列 MQ产品使用合集之在Cluster部署模式下,使用dashboard无法查询到消费组信息,一般是什么导致的
阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
下一篇
无影云桌面