mq事务-mq事务文档介绍内容-阿里云

MQ 事务消息纳入全局事务管理样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件在把 MQ 事务消息的发送纳入 GTS 管理的全局事务，请先完成以下工作：准备一个可用的 MySQL 环境（可以是阿里云的 RDS）。准备一个可用的 Maven 环境。样例说明样例...

sample-txc-mq 样例

本样例介绍如何把 MQ 事务消息的发送纳入 GTS 管理的全局事务。前提条件在使用 sample-txc-mq 样例前，请先完成以下工作：开通 GTS（创建事务分组）。开通 MQ。具体操作，请参见快速入门概述。准备两个 RDS 实例，用户创建数据库。准备...

TCC 模式接入注意事项

1:AT 2:MT 3:AT&MT-><constructor-arg value="2"/></bean>GTS 对 MQ 事务消息纳入全局事务管理的支持是通过 TCC 模式实现的。所以，使用 AT 模式的同时，又需要把 MQ 事务消息纳入全局事务管理时，就需要同时开启 AT 和 TCC 模式的配置。...

应用场景

消息事务 GTS 与 MQ 打通，提供事务消息处理能力，可以保证业务链路完成时发送消息，任一阶段异常时回滚消息。开发简单，在客户端声明一个注解，用以界定事务边界，调用 MQ 的事务API发送消息。高可靠：在宕机、网络故障等情况下，严格...

什么是全局事务服务GTS

可以与RDS、MySQL、PostgreSQL等数据源，Spring Cloud、Dubbo、HSF及其他RPC框架，MQ消息队列等中间件产品配合使用，轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及各种组合。为什么需要全局事务服务一个完整的业务往往...

事务模式简介

适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。AT 模式下，DRDS 中接入分布式事务与 DRDS版本集成使用时无需@TxcTransaction 注解，且无需引入 GTS 的 SDK，仅需要在用户的 SQL 语句中使用 select ...

AT 模式接入

AT 模式接入适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。本文介绍如何基于@TxcTransaction 注解使用 GTS 服务。前提条件在使用 AT 模式接入 GTS 前，请先完成以下工作：开通 GTS（创建事务分组）...

版本说明

2.8.35 2019-09-30 增强和简化MT模式和MQ消息事务的支持。2.8.34 2019-09-24 解决2.8.32版本引入的对Diamond低版本的兼容问题。2.8.33 2019-09-23 支持fastjson-1.2.60引入的对java.sql.Date类型解析的兼容性问题。2.8.32 2019-09-17 改进...

旧版样例简介

sample-txc-mq：最简 GTS 样例的基础上，将 MQ 加入分布式事务，保证了数据库操作与消息发送的一致性。数据库操作提交，则消息一定发送成功；数据库操作回滚，则消息一定不会被发送出去。本案例是 GTS 和 MQ 综合实践的入门案例。具体使用...

步骤三：开发单元化应用

本文将基于转账、积分等场景分别介绍微服务（MS）中的 SOFARPC、消息队列（MQ）以及分布式事务（DTX）如何完成 LDC 单元化相关的业务开发。前提条件路由参数为 userId，格式如 080066600000002，取第一位+0 作为分片位（sharding key）。...

产品问题

能，GTS 具有全链路事务的能力，已经开通了 EDAS、MQ、RDS、MySQL 之间的事务。GTS 是否支持多机房高可用？GTS 支持双机房高可用。当一个机房由于断网、停电等突发状况造成了全机房不可用时，GTS 可以自动切换到备用机房继续提供服务。切换...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Python SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示...

收发事务消息

} function processAckError($e){ if($e instanceof MQ\Exception\AckMessageException){/如果Commit或Rollback时超过了TransCheckImmunityTime（针对发送事务消息的句柄）或者超过NextConsumeTime（针对consumeHalfMessage的句柄），则...

查询消息轨迹

MQ Server 消息类型普通消息定时消息顺序消息事务消息说明发送的消息为定时消息或延时消息时，消息类型都显示为定时消息。到达Server 消息到达云消息队列 RocketMQ 版服务端的时间。预设DeliverAt 定时消息的预计投递时间。实际...

版本发布说明

修复lookup执行器在执行阶段访问mq获取column信息的并发问题。修复长事务遇到事务日志清理可能会阻塞其他事务的问题。修复 rename table 对多张表操作时，可能产生死锁的问题。修复带分区函数的子分区表点查时路由裁剪有概率报NPE的问题。...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。...

CreateMqttTopic DeleteTopic mq:MqttInstanceAccess mq:DeleteMqttTopic ListTopic mq:MqttInstanceAccess mq:ListMqttTopic UpdateTopic mq:MqttInstanceAccess mq:UpdateMqttTopic CreateMqttInboundRule 实例：acs:mq:*:*:instance/{...

名词解释

事务边界分布式事务需要进行开启，在执行结束后需要进行结束（提交或回滚），事务开启和关闭即划定了一个事务边界。事务模式 GTS 提供的预先定义好的事务模式，不同的事务模式提供了不同的易用性和性能，不同的事务模式组合（详见最佳实践...

权限策略

mq:QueryMqttMsgTransTrend 根据Topic查询消息的收发报表 mq:SendMqttMessageByConsole 控制台发消息测试 mq:CreateMqttTopic 创建Topic mq:DeleteMqttTopic 删除Topic mq:ListMqttTopic 查询Topic mq:UpdateMqttTopic 更新Topic备注信息 ...

使用 API 开启事务

GTS提供一种非Spring框架下直接使用API开启事务的方式。获取单例的全局事务操作对象 TxcTransaction txcTransaction=TxcTransaction.getInstance(vgroup,ak,sk)其中 TxcTransaction 为单例对象，vgroup 为客户申请的事务分组，ak/sk 为用户...

分布式事务框架和事务模式

GTS 定义了一套事务框架以便描述分布式事务，在框架下支持不同事务模式运行。核心组件定义分布式事务包含以下 3 个核心组件：Transaction Coordinator（TC）：事务协调器，维护全局事务的运行状态，负责协调并驱动全局事务的提交或回滚。...

MQ消息回执通知

本文以异步查询OSS数据为例，介绍如何在DLA中使用MQ做消息回执通知。前提条件开通OSS服务说明在DLA中异步执行SQL时，必须开通OSS服务，存储SQL执行结果。创建目录 OSS数据源创建MQ实例、Topic、Group 操作步骤新建RAM角色。使用DLA...

产品功能

GTS 提供了跨数据库、跨服务、消息队列和混合分布式事务，并提供多种事务模式。跨数据库分布式事务系统分库、分表后，跨库事务几乎无法避免，GTS 可以让应用轻松具备跨库事务处理能力。跨服务的分布式事务提供跨库、跨服务的事务支持，...

MQ配置

MQ配置提供了一套通过阿里云RocketMQ产品订阅云价签产品消息的机制。前提条件使用MQ订阅云价签产品消息，您需要先开通 RocketMQ产品并创建实例。开通权限云价签需要获取用户发送MQ消息的权限，需在 RAM控制台创建一个新角色，角色名为...

授权信息

无 mq:DeleteGroup OnsGroupDelete Write 全部资源*无无 mq:DeleteInstance OnsInstanceDelete Write 全部资源*无无 mq:DeleteTopic OnsTopicDelete Write 全部资源*无无 mq:ListGroup OnsGroupList List 全部资源*无无 mq:...

权限策略

MqttInstanceAccess mq:QueryToken ApplyToken mq:MqttInstanceAccess mq:ApplyToken CreateGroupId mq:MqttInstanceAccess mq:CreateGroupId DeleteGroupId mq:MqttInstanceAccess mq:DeleteGroupId ListGroupId mq:MqttInstanceAccess mq...

收费规则

一次全局事务会话一般会包含一个或多个分支事务，实际事务量指的是您的全局事务会话数加上分支事务数的和。按量付费采用后付费，每天按 GTS 事务分组（实例）的实际事务量计费，费用为 1 元/10,000 笔事务。您可以登录 GTS 控制台，为您的...

全面兼容和支持 Seata

这些服务包括（但不限于）：记录全局事务状态记录事务分支的注册驱动事务分支进行最终的提交或回滚事务链路监控异常事务的恢复全局事务超时检测全局事务间隔离机制分布式事务的协调机制被定义为一项标准化的服务，独立部署和运维，...

配置MQ

多活容灾MSHA的异地双活功能依赖阿里云消息队列RocketMQ版，在异地双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件两个地域的应用已接入最新版本的ONS-Client进行消息消费。更...

开通 GTS（创建事务分组）

在开始使用 GTS 前，请先开通 GTS，即创建事务分组。前提条件已经注册了阿里云账号并完成实名认证。操作步骤登录 GTS控制台。在事务总览页面，单击创建事务分组。在全局事务服务页面选择地域，输入事务分组，然后单击立即购买。...

MQ监控

MQ监控可展示消息队列RocketMQ版的Topic发布和订阅消息的情况。应用限制 EDAS标准版不支持MQ监控，专业版和铂金版支持MQ监控。功能入口登录 EDAS控制台。在左侧导航栏，单击应用管理>应用列表，在顶部菜单栏选择地域并在页面上方选择微...

TCC 模式接入

如果您使用了 TCC 事务模式，本文将帮助您了解 TCC 事务模式如何接入 GTS。前提条件在将 TCC 事务模式接入 GTS 前，准备两个 RDS 实例和一个 ECS 实例。背景信息 TCC 事务模式的详细介绍，请参见分布式事务框架和事务模式。TCC 事务模式...

RAM鉴权

mq:MqttInstanceAccess mq:RevokeToken QueryToken mq:MqttInstanceAccess mq:QueryToken ApplyToken mq:MqttInstanceAccess mq:ApplyToken CreateGroupId mq:MqttInstanceAccess mq:CreateGroupId DeleteGroupId mq:MqttInstanceAccess mq...

配置MQ

多活容灾MSHA的异地应用双活功能依赖阿里云消息队列RocketMQ版，在异地应用双活容灾场景下，完成消息层配置后，保障在单地域MQ组件故障场景中消息不丢失。本文介绍如何配置MQ。前提条件两个地域已拥有MQ铂金版实例和MQ多活商品组。具体...

MQ监控

ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布和订阅消息的情况。功能入口登录 ARMS控制台，在左侧导航栏选择应用监控>应用列表。在应用列表页面顶部选择目标地域，然后单击目标应用名称。说明语言列显示图标的...

MQ推送

MQ推送用于监控物联网卡的状态变化以及流量使用情况，并可以直接将消息推送到用户自己的系统中，帮助用户实时接收物联网卡的状态变化、套餐用量等信息。使用说明 MQ推送与自动化规则都是用于监控物联网卡的状态变化以及流量使用情况，主要...

使用问题

服务 A 调用服务 B，服务 A 上加了 GTS 开启事务注解，服务 B 没有注解，那么，A 和 B 是否在同一个分布式事务中？A 和 B 在一个事务中。在使用 EDAS 服务事务的时候，只要客户端 A 的函数上加入了 GTS 注解，那么这个客户端 A 注解函数...

GTS云服务下线迁移方案

阿里云全局事务服务（GTS）已通知于2024年1月22日停止服务。本文介绍如何将GTS云服务迁移至可替代的分布式事务解决方案。前提条件已开通并使用GTS云服务，是否开通GTS云服务可通过控制台查看事务分组列表有无数据进行判断。支持以下地域...

权限策略示例

本文介绍在云消息队列 MQTT ...Effect":"Allow","Action":["mq:CreateMqttOutboundRule","mq:DeleteMqttOutboundRule","mq:ListMqttOutboundRule","mq:UpdateMqttOutboundRule"],"Resource":["acs:mq:*:*:rule/post-cn-09k1noy*/Rule*"]}]}

消息队列

如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。集成消息队列 RocketMQ 说明 ...

mq事务

新品推荐