源码云消息队列 MQ 的相关内容

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

深入源码理解MQ长轮询优化机制

引言在分布式系统中，消息队列（MQ）作为一种重要的中间件，广泛应用于解耦、异步处理、流量削峰等场景。其中，延时消息和定时消息作为MQ的高级功能，能够进一步满足复杂的业务需求。为了实现这些功能，MQ系统需要进行一系列优化，长轮询机制便是其中的关键一环。本文将深入探讨MQ如何设计延时消息和定时消息的优化机制，特别是长轮询机制的实现原理及其在Java中的模拟实现。一、MQ基础概念与...

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

深度写作：深入源码理解MQ长轮询优化机制

引言在分布式系统中，消息队列（Message Queue, MQ）扮演着至关重要的角色。MQ不仅实现了应用间的解耦，还提供了异步消息处理、流量削峰等功能。而在MQ的众多特性中，长轮询（Long Polling）机制因其能有效提升消息处理的实时性和效率，备受关注。本文将深入源码，探讨MQ长轮询优化机制，从底层原理、业务场景、概念、功能点等方面进行详细剖析，并通过Java代码模拟长轮询功能...

文章 2023-07-21 来自：开发者社区

C# Queue与RabbitMQ的爱恨情仇（文末附源码）：Q与MQ消息队列简单应用（二）

上一章我们讲了队列（ Queue），这一章我们讲Message Queue消息队列，简称MQ。定义：　　MQ是MessageQueue，消息队列的简称（是流行的开源消息队列系统，利用erlang语言开发）。MQ是一种应用程序对应用程序的通信方法。应用程序通过读写入队和出队的消息来通信，无需专用连接来链接它们。消息传递是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，一般应用于....

文章 2023-07-21 来自：开发者社区

C# Queue与RabbitMQ的爱恨情仇（文末附源码）：Q与MQ消息队列简单应用（一）

首先我们简单了解一下什么堆、栈、队列。堆是在程序运行时，而不是在程序编译时，申请某个大小的内存空间。即动态分配内存，对其访问和对一般内存的访问没有区别。栈就是一个容器，后放进去的先拿出来，它下面本来有的东西要等它出来之后才能出来。（先进后出or后进先出）队列只能在队头做删除操作,在队尾做插入操作.而栈只能在栈顶做插入和删除操作。（先进先出）注意：当前展示的是队列（Queue），下一章....

问答 2023-04-25 来自：开发者社区

从proxy的源码来看会在进行org.apache.rocketmq.acl.plain.Plai

从proxy的源码来看会在进行org.apache.rocketmq.acl.plain.PlainAccessValidator#validate校验，如果proxy都校验不通过，更加不会走broker，这个解决了我第一层疑惑（为什么要在proxy配置plain_acl.yaml才能生效），另外第二层疑惑就是我在proxy的acl_plain.yaml加了一个新的ak/sk 但是broker....

文章 2022-12-13 来自：开发者社区

从源码上看，RocketMQ 5.0 跟 RocketMQ 4.x相比增加了哪几个模块

大家好，我是君哥。今天来介绍一下 RocketMQ 5.0 源码上的变化。RocketMQ 5.0 是一个里程碑式的版本，经历了近 5 年的打磨，代码变更达到 60%。首先看一下源码中模块的变化，如下图：从图中可以看到，RocketMQ 5.0 主要增加了 4 个模块儿，下面介绍一下这 4 个模块儿。1 bazelbazel 是 Google 开源的构建工具，目前广泛用于云计算领域的开源软件（如....

文章 2022-11-02 来自：开发者社区

搭建源码调试环境—RocketMQ源码分析（一）

你好，我是程序员Alan,很高兴遇见你。一、RocketMQ目录结构在正式开始搭建调试环境之前，我们先了解一下RockeMQ源码的整体架构。这是因为掌握了整体架构，可以让我们迅速了解各个方面的特性，并且可以方便我们后续快速定位功能模块对应的代码文件。话不多说，我们开始看RocketMQ目录结构。acl: 权限控制。可以给话题指定权限，只有拥有权限的消费者才可以进行消费。broker: Rocke....

文章 2022-06-13 来自：开发者社区

源码阅读技巧篇：RocketMQ DLedger 多副本即主从切换专栏回顾

RocketMQ DLedger 多副本即主从切换专栏总共包含9篇文章，时间跨度大概为2个月的时间，笔者觉得授人以鱼不如授人以渔，借以这个系列来展示该系列的创作始末，展示笔者阅读源码的技巧。首先在下决心研读 RocketMQ DLedger 多副本(主从切换)的源码之前，首先还是要通过官方的分享、百度等途径对该功能进行一些基本的了解。我们了解到 RocketMQ 在 4.5.0 之前....

文章 2022-06-13 来自：开发者社区

深入源码聊聊RocketMQ刷盘机制

本章概括同步刷盘整个同步刷盘策略由 FlushCommitLogService 与 GroupCommitService 实现。FlushCommitLogService 是 GroupCommitService 刷盘服务的父类，它是一个抽象类，本身没有实现，只是一个标记类，刷盘策略由子类负责完成。同步刷盘时，只有消息被真正持久化到磁盘才会响应 ACK，可靠性非常高，但是性能会受到较大影响，适用....

文章 2022-02-17 来自：开发者社区

技术干货 | 源码解析 Github 上 14.1k Star 的 RocketMQ

前言Apache RocketMQ 作为广为人知的开源消息中间件，诞生于阿里巴巴，于 2016 年捐赠给了 Apache。从 RocketMQ 4.0 到如今最新的 v4.7.1，不论是在阿里巴巴内部还是外部社区，都赢得了广泛的关注和好评。本文将站在发送方视角，通过阅读 RocketMQ Producer 源码，来分析在事务消息发送中 RocketMQ 是如何工作的。需要说明的是，本文所贴代码....