rocketmq

大家好，我是君哥。 最近有读者参加面试时被问了一个问题，如果消费者拉取了一批消息，比如 100 条，第 100 条消息消费成功了，但是第 50 条消费失败，偏移量会怎样更新？就着这个问题，今天来聊一下...

RocketMQ 是笔者非常喜欢的消息队列，4.9.X 版本是目前使用最广泛的版本，但它的消费逻辑相对较重，很多同学学习起来没有头绪。,这篇文章，笔者梳理了 RocketMQ 的消费逻辑，希望对大家有...

这篇文章，笔者想聊聊那些在业务系统中较少被使用，但却活跃于中间件或者框架里，强大却又低调的缓存，笔者愿称他们为缓存世界的扫地僧。,,HashMap 是一种基于哈希表的集合类，它提供了快速的插入、查找和...

Apache RocketMQ 诞生至今，历经十余年大规模业务稳定性打磨，服务了 100% 阿里集团内部业务以及阿里云数以万计的企业客户。作为金融级可靠的业务消息方案，RocketMQ 从创建之初就一...

,大家好，我是君哥，今天分享 RocketMQ 是怎样保存消息的。,首先，在 RocketMQ 集群中创建一个 Topic，叫做 MyTestTopic，配置如下图：,,这里解释一下图中的几个参数...

,RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。主要功能是异步解耦和流量削峰。,,常见的MQ主要有：ActiveMQ、R...

,RocketMQ集群架构图,如图所示，RocketMQ集群由4部分组成：Producer会根据业务需要发送消息；Broker负责接收、存储和分发消息；Consumer负责按需消费消息；Name Se...

在线业务侧主要从RocketMQ集群部署架构、平台系统架构、日常运维操作平台、监控告警一体化实践以及vivo如何通过建设AMQP消息网关的方式完成所有在线业务服务从RabbitMQ到RocketMQ的...

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

前天发完版本好不容易休息一下，又遇到一个问题，项目组反馈说RocketMQ的一个消费组一条消息，消费了两次，但两者之间的间隔超过了10个小时，现象如下图所示：,这是为什么呢?两者之间相差了差不多10个...

,大家好，我是君哥。,今天来介绍一下 RocketMQ 5.0 源码上的变化。,RocketMQ 5.0 是一个里程碑式的版本，经历了近 5 年的打磨，代码变更达到 60%。,首先看一下源码中模块的变...

RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时、高可靠的消息发布与订阅服务。,这篇文章，笔者整理了 RocketMQ 源码中创建线程的几点技巧，希望大家读完之后，能...

,是这样的，我在学习rocketmq的时候遇到了一个奇怪的问题，就是同一个消费者组内的消费者订阅同一个主题topic，不同的tag的时候看到一个消息丢失的问题,这个问题我也是向《RocketMQ技术内...

​Rocketmq和kafka这两个消息队列大家应该都比较熟悉吧，哪怕不是很熟悉，应该也听说过的吧，你别告诉我，作为一个资深的程序员，你没听过这两门技术。,我之前使用这两个消息队列的时候就遇到一个很奇...

大家好，我是三友，我又来了~~,最近仍然畅游在RocketMQ的源码中，这几天刚好翻到了消费者的源码，发现RocketMQ的对于push消费方式的实现简直太聪明了，所以趁着我脑子里还有点印象的时候，赶...

,大家好，我是君哥。今天分享 RocketMQ 的 Broker 挂了，会带来什么影响。,面试官：你好，如果 RocketMQ 集群中的一个 Broker 挂了，会造成什么影响呢？ ,我：Broker...

​大家好，我是君哥。,在 RocketMQ 4.x 版本，使用延时消息来实现消息的定时消费。延时消息可以一定程度上实现定时发送，但是有一些局限。,RocketMQ 新版本基于时间轮算法引入了定时消息...

大家好，我是君哥。,RocketMQ 消息消费有两种模式，PULL 和 PUSH,今天我们来看一下这两种模式有什么区别。,首先看一段 RocketMQ 推模式的一个官方示例：,消费者会定义一个消息监听...

RocketMQ是由阿里巴巴开源的分布式消息中间件，支持顺序消息、定时消息、自定义过滤器、负载均衡、pull/push消息等功能。RocketMQ主要由 Producer、Broker、Consume...

最近一周一来，总是有项目组中反馈遇到了消息重复推送的问题，连续出现单条消息短时被多个消费者消费的问题：,,同时给出了证据，相同的msgId的消息被打印了两条，并且两者相隔7s。,,讲真，由于最近负责的...

消息中间件在高并发的业务场景占据了非常重要的位置，其中国内的典型代表Java实现的RocketMQ需要重点掌握。,本文重点详解如下5点：,1.RocketMQ的介绍,2.RocketMQ的技术演进,3...

大家好，我是指北君。,,消息中间件是我们工作中使用最频繁的一类中间件，它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如...

,大家好，我是君哥。,对消息队列来说，偏移量是一个非常重要的概念，如果偏移量保存失败，可能会造成消息丢失、消息重复消费等问题。今天来聊一聊 RocketMQ 是怎么保存消息偏移量的。,RocketMQ...

大家好，我是君哥。今天来聊一聊 RocketMQ 的延时消息是怎么实现的。,延时消息是指发送到 RocketMQ 后不会马上被消费者拉取到，而是等待固定的时间，才能被消费者拉取到。,延时消息的使用场景...

大家好，我是君哥。,今天来分享 RocketMQ 的定时任务。通过这些定时任务，能让我们更加理解 RocketMQ 的消息处理机制和设计理念。,从 RocketMQ 4.9.4 的源代码上看，Rock...

,今天我们就来带大家如何玩转MQ的消息。,消息中间件，英文Message Queue，简称MQ。它没有标准定义，一般认为：消息中间件属于分布式系统中一个子系统，关注于数据的发送和接收，利用高效可靠的异...

大家好，我是君哥。,RocketMQ 选择了自己写 NameServer 做注册中心而没有选择 Zookeeper，这是为什么呢？,首先看一下 RocketMQ 的架构，如下图：,,RocketMQ ...

,大家好，我是君哥。,RocketMQ 5.0 已经发布一段时间了，今天来分享一下 RocketMQ 5.0 有哪些新特性。,RocketMQ 5.0 架构上的变化主要是为了更好的走向云原生。,Roc...

大家好，我是三友~~,这篇文章我准备来聊一聊RocketMQ消息的一生。,不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑：,本文就通过探讨上述问题来探秘消息在RocketMQ中短暂而又...

大家好，我是君哥。,今天来分享 RocketMQ 中一个关键的知识点，消费者的启动过程。,多数消息队列中，消费者和 Broker 通信的方式有两种，PUSH 模式和 PULL 模式：,首先看下面这张图...

RocketMQ作为阿里系的一款开源的MQ中间件，经历了双十一的高并发场景的消息流转，能够处理万亿级别的消息。,这篇文章将作为《RocketMQ 进阶》专栏的第一篇文章，介绍一下实际生产中如何搭建一个...

​有位工作五年的小伙伴在面试的时候被问到RocketMQ的分布式事务实现原理。他说他只知道RocketMQ能够支持事务，但是没有了解过它的事务实现原理。,今天，我给大家分享一下我对这个问题的理解。,随...

最近在新项目开发中遇到一个有趣的问题，如何在 SpringBoot 项目中控制 RocketMQ 消费线程数量。如何设置单个 topic 消费线程的最小数量和最大数量，用来区分不同 topic 吞吐量...

,5G时代，万物互联，越来越多的企业期望搭建数据分析业务中台，利用大数据技术、通过全局规划来治理企业的数据资产。而在业务系统，或者大数据系统中异构数据源之间的数据同步是十分有必要的，传统的点对点的数据...

笔者是 RocketMQ 的忠实粉丝，在阅读源码的过程中，学习到了很多编程技巧。,这篇文章，笔者结合 RocketMQ 源码，分享并发编程三大神器的相关知识点。,,CountDownLatch 是一个...

,大家好，我是君哥。,事务消息是分布式事务的一种解决方案，RocketMQ 有成熟的事务消息模型，今天就来聊一聊 RocketMQ 事务消息实现机制。,假如有一个电商场景，用户下单后，账户服务从用户账...

,大家好，我是君哥。今天聊聊 RocketMQ 的广播消息实现机制。,RocketMQ 有两种消费模式，集群模式和广播模式。,集群模式是指 RocketMQ 中的一条消息只能被同一个消费者组中的一个消...

大家好，我是君哥。今天来聊一聊 RocketMQ 客户端消息消费失败，怎么办？,下面是 RocketMQ 推模式的一段代码：,从这段代码可以看出，消费者消费消息后会返回一个消费状态，那消费状态有哪些呢...

大量业务使用消息中间件进行系统间的解耦、异步化、削峰填谷设计实现。公司内部前期基于RabbitMQ实现了一套高可用的消息中间件平台。随着业务的持续增长，消息体量随之增大，对消息中间件平台提出了更高的要...

,大家好，我是君哥。,今天来聊一聊 RocketMQ 的灰度方案。,灰度发布是指在黑与白之间，平滑过渡的一种发布方式。在大流量的系统中，如果一次升级改造范围比较大，或者影响内容不太确定，一般会采用切量...

作者｜vivo 互联网中间件团队- Liu Runyun,大量业务使用消息中间件进行系统间的解耦、异步化、削峰填谷设计实现。公司内部前期基于RabbitMQ实现了一套高可用的消息中间件平台。随着业务的...