RocketMQ学习

1 SpringBoot整合RocketMQ简单四步即可将两者整合在一起。 1.1 引入依赖<dependency> <groupId>org.apache.rocketmq</groupId> <artif

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

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

0 前言RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色。在【RocketMQ学习】1.基础知识一文中，我们了解了其物理架构，本章将深入了解其各个

1 准备JDK：1.8.0_181Maven：apache-maven-3.5.3RocketMQ：4.8.0（官网目前最新版本是5.1.3），参见 快速指南 ，各版本源码及二进制执行文件下载参见 这里下载环境变量：ROCKETMQ_HOM