rocketmq

%ignore_a_1%操作rocketmq实现消息过滤的核心方式是tag和sql表达式。1. tag过滤适用于简单分类，通过设置tag并使用||订阅多个tag提高效率；2. sql表达式过滤支持and、or、not及比较运算符，需在broker中开启enablepropertyfilter并设置用…

大家好，我是君哥。 最近有读者参加面试时被问了一个问题，如果消费者拉取了一批消息，比如 100 条，第 100 条消息消费成功了，但是第 50 条消费失败，偏移量会怎样更新？就着这个问题，今天来聊一下，如果一批消息有消费失败的情况时，偏移量怎么保存。 1 拉取消息 1.1 封装拉取请求 以 Rock…

rocketmq事务消息通过“半消息”和“事务回查”机制解决分布式系统中的数据一致性问题。1. 事务生产者（transactionmqproducer）发送半消息，消费者不可见；2. broker回调executelocaltransaction方法执行本地事务，决定提交、回滚或未知状态；3. 若状…