如何算重复消费 rocket本身其实有一部分思想建立在 at-least-once 基础上，rocket保证了生产者发送的消息，根据持久化刷盘和其他机制保证消息不丢失，消息不丢失请参考 https://www.cnblogs.com/oldEleven/p/17149457.html，但是rocket本身是支持重试的，其实要保证消息消费的能力，它本身是不保证重复消费的。当然现在说的重复消费并不这么简单，...

者组可以订阅多个Topic。消费者实例： 一个消费者组程序部署了多个进程，每个进程都可以称为一个消费者实例。订阅关系： 一个消费者组订阅一个 Topic 的某一个 Tag，这种记录被称为订阅关系。RocketMQ规定消费订阅关系（消费者组名-Topic-Tag）必须一致——在此，笔者想提醒读者，一定要重视这个问题，一个消费者组中的实例订阅的Topic和Tag必须完全一致，否则就是订阅关系不一致。订阅关系不一致...

本文作者：刘涛，阿里云智能技术专家。 01 Compaction Topic介绍 一般来说，消息队列提供的数据过期机制有如下几种，比如有基于时间的过期机制——数据保存多长时间后即进行清理，也有基于数据总量的过期机制——数据分区数据量达到一定值后进行清理。而 Compaction Topic 是一种基于 key 的数据过期机制，即对于相同 key 的数据只保留最新值。该特性的应用场景主要为维护状态信息，或者在需...

什么是事务消息事务消息（Transactional Message）是指应用本地事务和发送消息操作可以被定义到全局事务中，要么同时成功，要么同时失败。RocketMQ的事务消息提供类似 X/Open XA 的分布事务功能，通过事务消息能达到分布式事务的最终一致。事务消息所对应的场景在一些对数据一致性有强需求的场景，可以用 Apache RocketMQ 事务消息来解决，从而保证上下游数据的一致性。 以秒杀购...

文章目录 路由注册角度路由剔除路由发现 路由注册角度 对于ZooKeeper这样的强一致性组件，使用主从分离的架构，数据只写到主节点，主从之间的数据同步通过内部机制来进行数据复制。 对于RocketMQ来说，NameServer节点之间是互相不进行通信的，这样也就无法进行数据复制。RocketMQ采用的机制是：在Broker节点启动的时候，轮询所有的NameServer节点，并与每个NameServer节点建立...

springBoot整合RocketMq 项目地址：https://github.com/apache/rocketmq-spring 在项目wiki界面你可获取相关示例，或者直接下载示例项目 部分概念在我的上一篇文章中有说明，这里仅仅只演示示例代码，不做概念性说明 引入依赖 写文章时rocketmq-spring-boot-starter最新版本是2.2.2 对应的rocketmq-client版本是4.9....

master write body error < 0"); } } } // ... return result; } }} 总结主从同步流程 有新消息写入之后的同步流程 参考丁威、周继锋《RocketMQ技术内幕》RocketMQ版本：4.9.3...

RocketMQ系列-搭建Namesrv源码调试环境在学习任何一个技术框架的时候，我们通常都是先了解是什么，有什么作用、解决什么问题、设计亮点和设计思想是什么；当然对于技术学习上来说，这只是纸上谈兵，一开始比较基础的学习，当我们想要深入的时候，我们必不可少的就是希望能够去调试源码，能够在本地运行一下这个技术框架，能够断点调试一下这个框架最核心的功能或者看一下内部的数据结构。所以我们学习一个技术框架，特别核心的一...

示例 消费者使用Pull方式拉取消息的流程和Push消息的流程基本类似，包括创建消费者对象、设置组名、启动消费者消费。代码如下： package com.wjw; import org.apache.rocketmq.client.consumer.DefaultMQPullConsumer;import org.apache.rocketmq.client.consumer.PullResult;impor...

消息模型单体的消息模型RocketMQ消息模型跟其他的消息队列一样 都是 producer - > topic->consumerproducer 生产消息 也就是发送者topic 消息主题 按topic发送消息 以后消息的存储 分片等都是基于topic做业务处理的consumer 消息消费者 也是基于topic来进行消息的消费 支持推和拉模式(其实内部都是pull模式的变种)。 扩展集群消息模型为了...