前言 在分布式消息系统中,确保消息在生产、传递和消费过程中的可追溯性至关重要。消息跟踪机制使得开发者和运维人员能够监控和调试消息流转过程,快速定...
一、RocketMQ 的前世今生 RocketMQ 是阿里巴巴开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订...
创建maven工程,引入RocketMQ依赖 创建Producer发送同步消息,异步消息,单向消息 创建Consumer消费消息 Consume...
消息存储的结构 1、RocketMQ消息的存储结构 2、存储特点 如上图所示: 1、消息主体以及元数据都存储在CommitLog文件当中,完全顺...
基于RocketMQ源代码版本:rocketmq-all-4.5.2-source-release 1、RocketMQ生产者-核心参数 参数名...
PushConsumer核心参数详解 参数名默认值说明consumerGroupDEFAULT_CONSUMERConsumer组名,多个Con...
RocketMQ基于Spring编程模型的消息收发 添加rocketmq-spring-boot-starter等相关依赖 RocketMQ P...
简介 官方简介:RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点: 1、能够保证严格的消息顺序 2、提供丰富的消息拉取模式 3、...
简介 官方简介:RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点: 1、能够保证严格的消息顺序 2、提供丰富的消息拉取模式 3、...
文集作者