1 SpringBoot整合RocketMQ简单四步即可将两者整合在一起。 1.1 引入依赖<dependency> <groupId>org.apache.rocketmq</groupId> <artif
2023-08-22
【RocketMQ学习】15.源码之顺序消息1 demo1.1 Producer根据不同订单id的取模，把不同订单的消息分配到不同的MessageQueue，把相同订单消息分配到相同的MessageQueue。 public class ProducerInOrder {
2023-08-18
【RocketMQ学习】14.源码之延迟消息1 demo准备1.1 Producer/** * @author zyx * 延时消息-生产者 */ public class ScheduledMessageProducer { public static vo
2023-08-18
【RocketMQ学习】13.源码之消息过滤与重试1 前言RocketMQ支持消息过滤和重试。对于消息过滤，其支持两种方式： TAG过滤：相当于子topic，对同一topic的消息再次进行过滤，分发至相应的消费者。 SQL过滤：支持SQL92标准形式，对于producer传递的属性值进行
2023-08-11
【RocketMQ学习】12.源码之数据同步及异步机制1 前言若Broker按照主从方式部署，则需要对主节点的数据进行备份。在生产上，为了实现消息的高可用，避免Broker发生单点故障引起存储在Broker上的消息无法及时消费， RocketMQ引入Broker主备机制，即：消息消费到达主服务
2023-08-11
【RocketMQ学习】11.源码之事务消息1 前言回顾下事务消息流程： RocketMQ事务消息流程 其中分为两个流程：正常事务消息的发送及提交、事务消息的补偿流程。 1.1 正常事务流程 发送消息(half 消息)：图中步骤 1。 服务端响应消息写入结果：图中步骤 2。 根据发
2023-08-10
【RocketMQ学习】10.源码之堆外内存1 前言上一章节，我们大致上了解了消息的存储机制，其中在消息写入时，RocketMQ有两种不同的写入机制： 常规方式：通过MMAP(Memory Map，内存映射)写内存映射文件(Memory-Mapped File，MMF)，然后通过同
2023-08-07
【RocketMQ学习】9.源码之Store1 整体流程消息存储整体流程 消息存储架构设计 2 核心类2.1 DefaultMessageStoreDefaultMessageStore 部分属性： private final MessageStoreConfig messag
2023-08-02
【RocketMQ学习】8.源码之Consumer1 Consumer样例这里以集群消费、并发消费为例，采用一般的推模式进行消息消费。 public class BalanceConsumer { public static void main(String[] args
2023-07-28
【RocketMQ学习】7-源码之Producer1 Producer样例public class TestProducer { public static void main(String[] args) throws MQClientException, Interr
2023-07-27
【RocketMQ学习】6.源码之Remoting0 前言RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色。在【RocketMQ学习】1.基础知识一文中，我们了解了其物理架构，本章将深入
2023-07-25
【RocketMQ学习】5.源码之NameServer和Broker启动1 准备JDK：1.8.0_181Maven：apache-maven-3.5.3RocketMQ：4.8.0（官网目前最新版本是5.1.3），参见 快速指南 ，各版本源码及二进制执行文件下载参见 这里下载环境变量：ROCKETMQ_HOM
2023-07-21