RocketMQ Tag 详解！
本文详细介绍了 RocketMQ 中 Tag 的原理及其应用场景。Tag 是一种消息过滤机制，允许生产者在发送消息时指定标签，消费者据此选择性消费。文章通过源码分析展示了 Tag 在消息发送、存储及消费阶段的作用，并提供了完整的示例代码。尽管 Tag 功能简单高效，但也存在单一维度过滤等局限性。适合需要高效、低延迟消息传递的场景，如日志监控、电商系统等。
Rocketmq如何保证消息不丢失
文章分析了RocketMQ如何通过生产者端的同步发送与重试机制、Broker端的持久化存储与消息重试投递策略、以及消费者端的手动提交ack与幂等性处理，来确保消息在整个传输和消费过程中的不丢失。
两个实验让我彻底弄懂了「订阅关系一致」
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：**保证订阅关系一致**。
订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。
如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。
AgentScope x RocketMQ：打造企业级高可靠 A2A 智能体通信基座
Apache RocketMQ 推出轻量级通信模型 LiteTopic，专为 AI 时代多智能体协作设计。它通过百万级队列支持、会话状态持久化与断点续传能力，解决传统架构中通信脆弱、状态易失等问题。结合 A2A 协议与阿里巴巴 AgentScope 框架，实现高可靠、低延迟的 Agent-to-Agent 通信，助力构建稳定、可追溯的智能体应用。现已开源并提供免费试用，加速 AI 应用落地。
