一、生产者端优化（发得快、不阻塞） 异步发送 同步发送会阻塞业务线程，高并发下必须用异步发送。 配合回调处理成功 / 失败，不影响主线程吞吐量。 批量发送（batch） 攒一批消息再一次性发送，大幅减少网络 IO。 控制好批
2026-03-24
一、消息队列的本质模型 所有 MQ 本质上都是同一个模型： 生产者（Producer） → 消息队列（Queue/Topic） → 消费者（Consumer） 再抽象一层： 发消息的人 → 存消息的地方 → 收消息的人 二、通用核心概念（所有 MQ 都有） 1.
2026-03-23
MQ（消息队列）基础配置主要围绕连接、服务端、生产者、消费者、可靠性、性能五大核心维度展开，下面以RabbitMQ、Kafka、RocketMQ三大主流 MQ 为例，给出可直接落地的基础配置说明。 一、通用基础配置（三大 MQ 共性） 1. 连接配置（必配） 所有 MQ 客户端第一
2026-03-20
保证 RocketMQ 事务消息的最终一致性（即「本地事务执行结果」与「消息投递 / 消费结果」最终一致），核心是构建「生产端一致性 + 消费端一致性 + 全局兜底补偿」的闭环体系，依托 RocketMQ 事务消息的原生机制，结合业务层的可靠性设计。以下是可落地的全流程方案，覆盖核心原理、关键措施和
2025-12-25
保证 RocketMQ 事务消息的最终一致性（即「本地事务执行」与「消息投递 / 消费」的最终一致），核心是依托 RocketMQ 事务消息的「半消息 + 本地事务 + 事务回查」机制，同时配合生产端可靠性、消费端幂等性、异常兜底策略形成闭环。以下是分维度的落地方案，覆盖核心原理、关键措施和避坑要点
2025-12-24
RocketMQ 事务消息的「半消息（Half Message）」是实现「消息投递与本地事务一致性」的核心机制，本质是Broker 接收到但标记为「暂不可投递」的特殊消息，其实现依赖 RocketMQ 对消息存储、状态标记、事务回查的特殊设计。以下从「底层实现原理、核心流程、关键机制」三方面拆解半消
2025-12-23
RocketMQ 事务消息和普通消息是 RocketMQ 针对不同业务场景设计的两种消息类型，核心差异体现在消息生命周期、可靠性机制、使用场景等方面。以下是全方位的对比分析，结合实操场景说明两者的核心区别： 一、核心定义与设计目标 类型 核心定义 设计目标
2025-12-22
以下是 Spring Boot + RocketMQ 事务消息 的极简可运行代码示例，仅保留核心逻辑，剔除所有冗余代码，可直接复制运行。 一、环境准备 本地启动 RocketMQ（NameServer: 9876，Broker 正常运行）； JDK 8+、Spring Boot 2
2025-12-19
以下是 Spring Boot 中使用 RocketMQ 事务消息的核心配置 + 极简可运行代码示例，聚焦关键配置和核心逻辑，剔除冗余代码，便于快速集成到项目中。 一、核心依赖（仅保留关键） xml <!-- pom.xml
2025-12-18
以下是 Spring Boot + RocketMQ 事务消息 完整可运行的代码示例，包含生产者（事务消息发送）、消费者（消息接收）、核心配置，基于 RocketMQ 4.9.x + Spring Boot 2.7.x 实现，可直接复制到项目中运行。 一、前置依赖（pom.xml）
2025-12-17