AI 助理
备案控制台
开发者社区 微服务 文章 正文

RocketMQ核心架构设计思想（中）

2022-05-02 126
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
应用型负载均衡 ALB，每月750个小时 15LCU
网络型负载均衡 NLB，每月750个小时 15LCU
传统型负载均衡 CLB，每月750个小时 15LCU
简介： RocketMQ核心架构设计思想（中）

Consumer负载均衡

image.png

消息拉取线程在从服务器拉取到一批消息后
然后提交到消息消费线程池后
又马不停蹄的继续向服务器再次尝试拉取消息

一个消费者可以同时消费一个topic下的不同队列

image.png

image.png

image.png

image.png

1、
在Consumer启动后
它就会通过定时任务不断地向RocketMQ集群中的
所有Broker实例发送心跳包
（包含:消息消费分组名称、订阅关系集合、消息通信模式和客户端id的值等信息）
2、
Broker端在收到Consumer的心跳消息后
会将它维护在ConsumerManager的本地缓存变量—consumerTable
同时并将封装后的客户端网络通道信息保存在本地缓存变量—channelInfoTable中
为之后做Consumer端的负载均衡提供可以依据的元数据信息
  • Consumer端实现负载均衡的核心类—RebalanceImpl

image.png

在消费者启动的时候完成负载均衡逻辑

集群模式处理流程

image.png

文章标签：
云消息队列 MQ
负载均衡
消息中间件
负载均衡
RocketMQ
关键词：
rocketmq架构
云消息队列 MQ架构
云消息队列 MQ架构设计
消息队列RocketMQ版架构设计
相关实践学习
消息队列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
平凡人笔记
目录
相关文章
菜菜的后端私房菜
|
2月前
|
消息中间件 存储 Java
RocketMQ（一）：消息中间件缘起，一览整体架构及核心组件
【10月更文挑战第15天】本文介绍了消息中间件的基本概念和特点，重点解析了RocketMQ的整体架构和核心组件。消息中间件如RocketMQ、RabbitMQ、Kafka等，具备异步通信、持久化、削峰填谷、系统解耦等特点，适用于分布式系统。RocketMQ的架构包括NameServer、Broker、Producer、Consumer等组件，通过这些组件实现消息的生产、存储和消费。文章还提供了Spring Boot快速上手RocketMQ的示例代码，帮助读者快速入门。
菜菜的后端私房菜
191 6
郑小健
|
4月前
|
消息中间件 存储 Java
RabbitMQ 在微服务架构中的高级应用
【8月更文第28天】在微服务架构中，服务之间需要通过轻量级的通信机制进行交互。其中一种流行的解决方案是使用消息队列，如 RabbitMQ，来实现异步通信和解耦。本文将探讨如何利用 RabbitMQ 作为服务间通信的核心组件，并构建高效的事件驱动架构。
郑小健
179 2
vohelon
|
3月前
|
消息中间件 弹性计算 运维
云消息队列RabbitMQ 版架构优化评测
云消息队列RabbitMQ 版架构优化评测
vohelon
71 6
VipSoft
|
4月前
|
网络协议 Java 物联网
MQTT(EMQX) - SpringBoot 整合MQTT 连接池 Demo - 附源代码 + 在线客服聊天架构图
MQTT(EMQX) - SpringBoot 整合MQTT 连接池 Demo - 附源代码 + 在线客服聊天架构图
VipSoft
1003 3
土木林森
|
4月前
|
消息中间件 Java RocketMQ
微服务架构师的福音：深度解析Spring Cloud RocketMQ，打造高可靠消息驱动系统的不二之选！
【8月更文挑战第29天】Spring Cloud RocketMQ结合了Spring Cloud生态与RocketMQ消息中间件的优势，简化了RocketMQ在微服务中的集成，使开发者能更专注业务逻辑。通过配置依赖和连接信息，可轻松搭建消息生产和消费流程，支持消息过滤、转换及分布式事务等功能，确保微服务间解耦的同时，提升了系统的稳定性和效率。掌握其应用，有助于构建复杂分布式系统。
土木林森
75 0
萝卜丝丸子
|
5月前
|
消息中间件 存储 缓存
架构设计篇问题之消息队列（MQ）在微服务系统中问题如何解决
架构设计篇问题之消息队列（MQ）在微服务系统中问题如何解决
萝卜丝丸子
46 0
公众号:码到三十五
|
6月前
|
消息中间件 存储 SQL
RocketMQ与Kafka架构深度对比
RocketMQ与Kafka架构深度对比
公众号:码到三十五
183 0
真的很搞笑
|
7月前
|
消息中间件 存储 Apache
MQ产品使用合集之有RocketMQ arm架构的镜像吗
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
真的很搞笑
353 1
喜欢猪猪
|
7月前
|
消息中间件 Java RocketMQ
Spring Cloud RocketMQ：构建可靠消息驱动的微服务架构
【4月更文挑战第28天】消息队列在微服务架构中扮演着至关重要的角色，能够实现服务之间的解耦、异步通信以及数据分发。Spring Cloud RocketMQ作为Apache RocketMQ的Spring Cloud集成，为微服务架构提供了可靠的消息传输机制。
喜欢猪猪
266 1
橘子-青衫
|
7月前
|
消息中间件 存储 数据库
RabbitMQ入门指南(二)：架构和管理控制台的使用
RabbitMQ是一个高效、可靠的开源消息队列系统，广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了RabbitMQ架构和管理控制台的使用等内容。
橘子-青衫
199 0
RabbitMQ入门指南(二)：架构和管理控制台的使用

热门文章

最新文章

  • 1
    一个模型走天下！智源提出全新扩散架构OmniGen，AI生图进入一键生成时代
  • 2
    阿里云云服务诊断工具：合作伙伴架构师的深度洞察与优化建议
  • 3
    微服务架构解析：跨越传统架构的技术革命
  • 4
    从单体到微服务：如何借助 Spring Cloud 实现架构转型
  • 5
    使用PaliGemma2构建多模态目标检测系统：从架构设计到性能优化的技术实践指南
  • 6
    超越Transformer，全面升级！MIT等华人团队发布通用时序TimeMixer++架构，8项任务全面领先
  • 7
    TCP/IP协议架构：四层模型详解
  • 8
    《docker高级篇（大厂进阶）：4.Docker网络》包括：是什么、常用基本命令、能干嘛、网络模式、docker平台架构图解
  • 9
    Mooncake：月之暗面Kimi联合清华等机构推出的大模型推理架构
  • 10
    【AI系统】推理系统架构
  • 1
    RabbitMQ的springboot项目集成使用-01
    150
  • 2
    深入理解MQ消息队列的高可用与可靠性策略
    1352
  • 3
    rabbitmq插件升级-延时队列为列
    670
  • 4
    rabbitmq安装erlang环境后没生效
    1046
  • 5
    Springboot 集成Rabbitmq之延时队列
    194
  • 6
    RabbitMQ高级
    50
  • 7
    rabbitMQ集群
    60
  • 8
    涉及rocketMQ，jemeter等性能测试服务器的安装记录
    82
  • 9
    用docker方式 安装rabbitmq 并配置MQTT
    330
  • 10
    MQTT 5.0 报文解析 02：PUBLISH 与 PUBACK
    447

    • 相关课程

    更多
  • 架构的演进
  • RocketMQ知识精讲与项目实战（第一阶段）
  • MySQL企业常见架构与调优经验分享
  • 企业Web常用架构LAMP-LNMP实战
  • 企业级互联网分布式系统应用架构学习
  • 高校精品课-上海交通大学 -企业级应用体系架构

    • 相关电子书

    更多
  • MaxCompute架构升级及开放性解读
  • MaxCompute Serverless 架构演进
  • 阿里云消息队列的 Serverless架构演进

    • 相关实验场景

    更多
  • 每个IT人都想学的“Web应用上云经典架构”实战
  • MySQL引擎及架构优化
  • 基于数据湖架构的网站访问行为分析
  • 使用SLB+2ECS+NAS，部署电商web网站的高可用架构
  • 消息队列RocketMQ版：定时消息通知功能体验
  • 消息队列RocketMQ版：基础消息收发功能体验
    • 下一篇
    手把手教你白嫖阿里云服务器(免费领服务器)