消息中间件之RocketMQ(二)事务消息与顺序消费以及过滤消息

    技术2024-07-27  15

    思路:生产者发送消息并行执行事务单元。执行成功确认消息发送,消息可见状态。执行失败,进入check回调。如果一开始发送消息失败,进入消息check回调。MQ自己维护了一个消息的状态表从而确保消息的可靠性投递。 

     

     

     

    过滤消息 

    Tag方式进行过滤使用sql表达式过滤使用filter server 过滤

     

    Processed: 0.012, SQL: 9