一文带你理解 RocketMQ 广播模式实现机制

一文带你理解 RocketMQ 广播模式实现机制

大家好,我是君哥。今天聊聊 RocketMQ 的广播消息实现机制。RocketMQ 有两种消费模式,集群模式和广播模式。集群模式是指 RocketMQ 中的一条消息只能被同一个消费者组中的一个消费者消费。如下图,Producer 向 TopicTest 这个 Topic 并发写入 3 条新消息,分别...

5张图带你理解 RocketMQ 顺序消息实现机制

5张图带你理解 RocketMQ 顺序消息实现机制

大家好,我是君哥。今天聊一聊 RocketMQ 的顺序消息实现机制。在有些场景下,使用 MQ 需要保证消息的顺序性,比如在电商系统中,用户提交订单、支付订单、订单出库这 3 个消息应该保证顺序性,如下图:对于 RocketMQ 来说,主要是通过 Producer 和 Consumer 来保证消息顺序...

RocketMQ 客户端负载均衡机制详解及最佳实践

RocketMQ 客户端负载均衡机制详解及最佳实践

作者:玄珏前言本文介绍 RocketMQ 负载均衡机制,主要涉及负载均衡发生的时机、客户端负载均衡对消费的影响(消息堆积/消费毛刺等)并且给出一些最佳实践的推荐。负载均衡意义上图是 RocketMQ 的消息储存模型:消息是按照队列的方式分区有序储存的。RocketMQ 的队列模型使得生产者、消费者和...

RocketMQ 刷盘机制|学习笔记

RocketMQ 刷盘机制|学习笔记

开发者学堂课程【RocketMQ 知识精讲与项目实战(第三阶段):RocketMQ 刷盘机制】学习笔记,与课程紧密联系,让用户快速学习知识。 课程地址:https://developer.aliyun.com/learning/course/704/detail/12450RocketMQ 刷盘机制...

RocketMQ 重试机制详解及最佳实践

RocketMQ 重试机制详解及最佳实践

作者:斜阳引言本文主要介绍在使用 RocketMQ 时为什么需要重试与兜底机制,生产者与消费者触发重试的条件和具体行为,如何在 RocketMQ 中合理使用重试机制,帮助构建弹性,高可用系统的最佳实践。RocketMQ 的重试机制包括三部分,分别是生产者重试,服务端内部数据复制遇到非预期问题时重试&...

请问一下,Eventbridge的消息清理机制是啥?和rocketMQ一样吗?

请问一下,Eventbridge的消息清理机制是啥?和rocketMQ一样吗?

深度解读 RocketMQ 存储机制

深度解读 RocketMQ 存储机制

作者:斜阳RocketMQ 实现了灵活的多分区和多副本机制,有效的避免了集群内单点故障对于整体服务可用性的影响。存储机制和高可用策略是 RocketMQ 稳定性的核心,社区上关于 RocketMQ 目前存储实现的分析与讨论一直是一个热议的话题。近期我一直在负责 RocketMQ 消息多副本和高可用能...

深度解读 RocketMQ 存储机制

深度解读 RocketMQ 存储机制

作者 | 斜阳来源 | 阿里开发者公众号RocketMQ 实现了灵活的多分区和多副本机制,有效的避免了集群内单点故障对于整体服务可用性的影响。存储机制和高可用策略是 RocketMQ 稳定性的核心,社区上关于 RocketMQ 目前存储实现的分析与讨论一直是一个热议的话题。本文想从一个不一样的视角,...

深度解读 RocketMQ 存储机制

深度解读 RocketMQ 存储机制

RocketMQ 实现了灵活的多分区和多副本机制,有效的避免了集群内单点故障对于整体服务可用性的影响。存储机制和高可用策略是 RocketMQ 稳定性的核心,社区上关于 RocketMQ 目前存储实现的分析与讨论一直是一个热议的话题。本文想从一个不一样的视角,着重于谈谈我眼中的这种存储实现是在解决哪...

源码分析RocketMQ ACL实现机制

源码分析RocketMQ ACL实现机制

有关RocketMQ ACL的使用请查看上一篇RocketMQ ACL使用指南,本文从源码的角度,分析一下RocketMQ ACL的实现原理。备注:RocketMQ在4.4.0时引入了ACL机制,本文代码基于RocketMQ4.5.0版本。根据RocketMQ ACL使用手册,我们应该首先看一下Br...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐