1 demo1.1 Producer根据不同订单id的取模，把不同订单的消息分配到不同的MessageQueue，把相同订单消息分配到相同的MessageQueue。public class ProducerInOrder {

1 demo准备1.1 Producer/** * @author zyx * 延时消息-生产者 */ public class ScheduledMessageProducer { public static vo

1 前言RocketMQ支持消息过滤和重试。对于消息过滤，其支持两种方式： TAG过滤：相当于子topic，对同一topic的消息再次进行过滤，分发至相应的消费者。 SQL过滤：支持SQL92标准形式，对于producer传递的属性值进行

1 前言若Broker按照主从方式部署，则需要对主节点的数据进行备份。在生产上，为了实现消息的高可用，避免Broker发生单点故障引起存储在Broker上的消息无法及时消费， RocketMQ引入Broker主备机制，即：消息消费到达主服务

1 问题罗马数字包含以下七种字符： I， V， X， L，C，D 和 M。字符 数值 I 1 V 5 X 10 L 50 C

1 问题罗马数字包含以下七种字符： I， V， X， L，C，D 和 M。字符 数值 I 1 V 5 X 10 L 50 C

1 前言回顾下事务消息流程：RocketMQ事务消息流程 其中分为两个流程：正常事务消息的发送及提交、事务消息的补偿流程。 1.1 正常事务流程 发送消息(half 消息)：图中步骤 1。 服务端响应消息写入结果：图中步骤 2。 根据发送结

1 问题给定一个字符串 s ，请你找出其中不含有重复字符的最长子串的长度。 示例 1 输入: s = “abcabcbb”输出: 3解释: 因为无重复字符的最长子串是 “abc”，所以其长度为 3。 示例 2 输入: s = “bbbbb

1 前言上一章节，我们大致上了解了消息的存储机制，其中在消息写入时，RocketMQ有两种不同的写入机制： 常规方式：通过MMAP(Memory Map，内存映射)写内存映射文件(Memory-Mapped File，MMF)，然后通过同

1 整体流程消息存储整体流程 消息存储架构设计 2 核心类2.1 DefaultMessageStoreDefaultMessageStore 部分属性：private final MessageStoreConfig messageSto

1 Consumer样例这里以集群消费、并发消费为例，采用一般的推模式进行消息消费。public class BalanceConsumer { public static void main(String[] args)

1 Producer样例public class TestProducer { public static void main(String[] args) throws MQClientException, Interr