摘要：顺序消息是指对于一个指定的 Topic ，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。 本文分享自华为云社区《RocketMQ 顺序消费机制》，作者： 勇哥java实战分享 。 顺序消息是指对于一个指定的 Topic ，消息严格按照...[2023/5/30]

顺序消息是指对于一个指定的 Topic ，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。 顺序消息分为分区顺序消息和全局顺序消息。 1、分区顺序消息 对于指定的一个 Topic ，所有消息根据 Sharding Key 进行区块分区，同...[2023/5/29]

NameServer是一个注册中心，提供服务注册和服务发现的功能。NameServer可以集群部署，集群中每个节点都是对等的关系（没有像ZooKeeper那样在集群中选举出一个Master节点），节点之间互不通信。 服务注册 Broker启动的时候会向所有的NameServer节点进行注册，...[2023/5/26]

大家好，我是Leo！今天来和大家分享RocketMQ的一些用法。 领域模型介绍 Producer: 用于生产消息的运行实体。 Topic: 主题，用于消息传输和存储的分组容器。 Me ageQueue: 消息传输和存储的实际单元容器。 Me age: 消息传输的最小单元。 Co...[2023/5/4]

今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分，第一部分实现SpringBoot与RocketMQ的整合，第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们，第三部分介绍如何封装RocketMQ以便更好地使用。 1. SpringBoot整合Rocke...[2023/4/10]

大家好，我是三友~~ 在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。 为什么需要保证幂等性呢？是因为消息会重复消费。 为什么消息会重复消费？ 明明已经消费了，为什么消息会被再次被消费呢？ 不同的MQ产生的原因可能不一样 本文就以RocketMQ为例，来扒...[2023/3/22]

客户端是通过Rebalance服务做到高可靠的。当发生Broker掉线、消费者实例掉线、Topic 扩容等各种突发情况时，消费者组中的消费者实例是怎么重平衡，以支持全部队列的正常消费的呢？ RebalancePullImpl 和 RebalancePushImpl 两个重平衡实现类，分别被 D...[2023/2/28]

消息存储 在 【RocketMQ】消息的存储一文中提到，Broker收到消息后会调用CommitLog的asyncPutMe age方法写入消息，在DLedger模式下使用的是DLedgerCommitLog，进入asyncPutMe ages方法，主要处理逻辑如下： 调用serialize方...[2023/2/27]

需求 将Hbase数据，解析后推送到RocketMQ。 redis使用list数据类型，存储了需要推送的数据的RowKey及表名。 简单画个流程图就是： 分析及确定方案 Redis 明确list中元素结构{"rowkey":rowkey,"table":table}解析出rowkey...[2023/1/20]

目录何时需要削峰通过消息队列的削峰方法有两种消费延时控流总结 何时需要削峰 当上游调用下游服务速率高于下游服务接口QPS时，那么如果不对调用速率进行控制，那么会发生很多失败请求 通过消息队列的削峰方法有两种 控制消费者消费速率和生产者投放延时消息，本质都是控制消费速度 通过消费者参数...[2023/1/20]

大家好，我是三友~~ 这篇文章我准备来聊一聊RocketMQ消息的一生。 不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑： 消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高...[2023/1/11]

RocketMQ在集群模式下，同一个消费组内，一个消息队列同一时间只能分配给组内的某一个消费者，也就是一条消息只能被组内的一个消费者进行消费，为了合理的对消息队列进行分配，于是就有了负载均衡。 接下来以集群模式下的消息推模式DefaultMQPushConsumerImpl为例，看一下负载...[2023/1/11]

本文作者：蒋星韬，网易云音乐服务端开发工程师。 云音乐线上场景众多，比如直播、评论、广告，各个业务线都会有消息场景比如发奖券，也会有延迟消息和事务消息场景，以及大数据做埋点数据、数据清洗、离线处理等。 云音乐线上 RocketMQ topic 为 1 万+/天，QPS 流量峰值为150万...[2022/12/12]

主从同步的实现逻辑主要在HAService中，在DefaultMe ageStore的构造函数中，对HAService进行了实例化，并在start方法中，启动了HAService： public cla DefaultMe ageStore implements Me ageStore { ...[2022/12/5]

本文作者：郝洪范 ，Dubbo-go Committer，京东资深研发工程师。 一、MQ Request Reply特性介绍 什么是 RPC 通信？ 如上图所示，类似于本地调用，A 服务响应调用 B 服务的 helloworld 方法需要怎么做？首先，A 服务的 Client Sub ...[2022/12/2]

笔者是 RocketMQ 的忠实粉丝，在阅读源码的过程中，学习到了很多编程技巧。 这篇文章，笔者结合 RocketMQ 源码，分享并发编程三大神器的相关知识点。 1 CountDownLatch 实现网络同步请求 CountDownLatch 是一个同步工具类，用来协调多个线程之间的...[2022/11/28]

本文作者：郭雨杰，阿里云智能技术专家。 Prometheus 集成的 50 多款云产品中，RocketMQ 在可观测方面实现了非常完善的功能，是一个特别具有代表性的云产品。 01 RocketMQ如何接入Prometheus RocketMQ 诞生于阿里内部的核心电商系统，是业务消息...[2022/11/17]