PDF《消息队列 CMQ》

【 队列】. 2. 单击操作列的【发送消息】,向消息接受侧发送测试消息. 消息内容:填写发送的内容. 延迟发送:可开启延迟消息,开启后消息会在延迟时间后发送,延迟时间范围1秒到1小时. 生产消息 最近更新时间:2019-03-29 16:39:31 消息队列 CMQ 版权所有:腾讯云计算(北京)有限责任公司 第15 共20页 当消息生产者本地事务处理成功与消息发送成功不一致时,传统的处理方式无法解决该问题,事务消息实现了消息 生产者本地事务与消息发送的原子性,保证了消息生产者本地事务处理成功与消息发送成功的最终一致.用户实现 类似 X/Open XA 的分布事务功能,通过 CMQ 事务消息能达到分布式事务的最终一致. 模块交互图 其中,事务消息发送对应步骤

1、

2、

3、4,事务消息回查对应步骤

5、

6、7. 1. 生产者向 MQ 服务端发送消息(为了方便说明,整个 MQ 服务端用 MQ server 来表示). 2. MQ Server 将消息持久化成功之后,向生产者 ACK 确认消息已经发送成功,此时消息为半消息(暂不能投递的 消息). 3. 生产者发送消息成功后,开始执行本地事务逻辑. 4. 生产者根据本地事务执行结果向 MQ Server 提交二次确认(Commit 或是 Rollback),MQ Server 收到 Commit 状态则将半消息标记为可投递,消费者最终将收到该消息;

MQ Server 收到 Rollback 状态则删除半消 息(直接置消息已消费状态),消费者将不会接受该消息. 5. 在断网或者是生产者应用重启的特殊情况下,上述步骤4提交的二次确认最终未到达 MQ Server,经过固定时间 后MQ Server 将对该消息发起消息回查. 6. 生产者收到消息回查后,需要检查对应消息的本地事务执行的最终结果. 生产者根据检查得到的本地事务的最终状态再次提交二次确认,MQ Server 仍按照步骤4对半消息进行操作. 事务消息 最近更新时间:2019-06-27 10:30:01 说明: 该功能目前处于灰度测试阶段,暂时支持广州、上海、印度地域,其他地域在逐步支持中,如需试用请通过 提交工单 的方式开通白名单. 消息队列 CMQ 版权所有:腾讯云计算(北京)有限责任公司 第16 共20页 发送事务消息 发送事务消息包含以下两个步骤: 1. 发送半消息并执行本地事务 2. 提交本地事务执行状态 其中,提交本地事务执行状态有两种方式: 执行本地事务完成后,SDK 主动提交. 执行本地事务后一直没有提交状态,MQ Server 会主动发送回查,此时 SDK 提交本地事务执行状态. 事务执行状态有以下三种情况: TransactionSt........