云消息队列 MQ原理的相关内容

文章 2025-04-01 来自：开发者社区

RocketMQ原理—1.RocketMQ整体运行原理

大纲 1.RocketMQ整体运行原理的介绍顺序 2.RocketMQ生产者是如何发送消息的 3.Broker是如何持久化接收到的消息到磁盘上 4.基于DLedger技术的Broker主从同步原理 5.消费者进行消息拉取和消费的过程 6.消费者从Master或Slave上拉取消息的策略 7.RocketMQ如何基于Netty进行高性能网络通...

文章 2024-11-15 来自：开发者社区

RocketMQ 工作原理图解，看这篇就够了！

关注△mikechen的互联网架构△，10年+BAT架构经验倾囊相授大家好，我是 mikechen | 陈睿。之前我就讲过消息中间件那真的是太重要了，那就是亿级互联网架构的基石，实在是太重要了。如果要学肯定学主流的两个就够了，比如：前一篇Kafka工作原理图解，看这篇就够了，以及本篇我要谈到的RocketMQ的底层架构以及实现原理。希望两篇，对你掌握好消息中间件有所帮助@mikeche....

文章 2024-11-03 来自：开发者社区

MQ 消息队列核心原理，12 条最全面总结！

关注△mikechen的互联网架构△，10年+BAT架构经验倾囊相授大家好，我是 mikechen | 陈睿。消息队列已经逐渐成为分布式应用场景、内部通信、以及秒杀等高并发业务场景的核心手段，它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能。无论是 RabbitMQ、RocketMQ、ActiveMQ、Kafka还是其它...

文章 2024-08-16 来自：开发者社区

深入学习RocketMQ的底层存储设计原理

前言 RocketMQ的是一款追求低延迟的消息队列，虽然他是存储在磁盘上的，但是他的读写性能还是非常之高，本文将分析他的存储设计，看看他是从哪些方面对性能有改善。 RocketMQ存储组成我们可以把RocketMQ的Broker理解成一个数据库一样，数据库存储功能主要是读和写的功能，RocketMQ也一样。在数据库中，我们将数据写入数据和索引中，在RocketMQ中，我们将数据写到c...

文章 2024-08-16 来自：开发者社区

RocketMQ生产者负载均衡(轮询机制)核心原理

前言上文已经分析了RocketMQ消费者负载均衡核心原理，我们经常会讨论消费者负载均衡的原理，我们可能忽略了生产者这端其实也有负载均衡机制。本文将分析RocketMQ生产者是如何负载均衡的。 RocketMQ生产者为什么需要负载均衡？在RocketMQ中，队列是消息发送的基本单位。每个Topic下可能存在多个队列，因此一个生产者实例可以向不同的队列发送消息。当生产者发送消息时，如果不能...

文章 2024-08-16 来自：开发者社区

RocketMQ消费者消费消息核心原理（含长轮询机制）

前言在消息系统中，消费者消费消息有拉和推消息两种实现方式，拉消息是消费者主动向消息服务器发送拉消息请求，消息服务器将消息返回给消费者，而推消息是消息服务器主动向消费者推送消息的形式，这两种消息消费实现各有各的优势和劣势。在RocketMQ中，有两种消费者客户端,一种是Push模式消费者, 一种是Pull模式消费者，这两个其实都是表现，在RocketMQ底层实现中采用长轮询的机制来实现消息...

文章 2024-08-16 来自：开发者社区

2分钟看懂RocketMQ延迟消息核心原理

前言延迟消息在业务场景中使用的非常多，订单失效，过期通知等功能都可以借助延迟消息机制来实现。本文将从源码层面来分析Rocketmq的延迟消息实现原理机制。一、延迟消息的使用先看下延迟消息的使用，发送消息逻辑和普通消息一样，只要在生产者端将Message对象中设置延迟消息的等级，Rocketmq的开源版本支持18个等级，每个等级代表一个延迟时间。 Rocketmq有18个延迟等级...

文章 2024-08-16 来自：开发者社区

RocketMQ发送消息原理（含事务消息）

前言上一篇文章已经介绍了RocketMQ的功能，架构，从本文开始，我们将开始深入源码层面，一步一步学习RocketMQ设计原理。在消息队列中，生产者负责发送消息到Broker,本文分享RocketMQ发送消息的实现原理以及一些注意的事项。一、生产者端的发送流程一般来说我们的业务应用端是生产者，负责和Broker和nameserver通信完成消息投递的功能。在源码中，发送消...

文章 2024-08-14 来自：开发者社区

RocketMQ - 生产者原理

https://rocketmq.apache.org/ Apache RocketMQ是一款开源的、分布式的消息投递与流数据平台。出生自阿里巴巴，在阿里巴巴内部经历了3个版本后，作为Apache 顶级开源项目之一直到现在。在GitHub上有10000+star、5000+fork、170+contributors（在GitHub上提交代码并被采纳的开发者） Rocket...

文章 2024-07-24 来自：开发者社区

MetaQ/RocketMQ 原理问题之避免重复消费问题如何解决

问题一：如何避免重复消费问题？如何避免重复消费问题？参考回答： MetaQ 不能保证消息不重复，因此对于重复消费情况，需要业务自定义唯一标识作为幂等处理的依据。在发送时消息重复或投递时消息重复的情况下，业务逻辑需要能够识别并处理重复的消息。关于本问题的更多回答可点击原文查看： https://developer.aliyun.co...