HTTP 参考

概述

DTM 可以通过HTTP协议交互。因为事务本身具有特殊性，它和普通的api调用只区分成功和失败不同，DTM的结果状态详情，请参考接口协议

接口主要分为三类： AP调用TM的接口、AP调用RM的接口、TM调用RM的接口。本文主要讲解AP调用TM的接口，其他两类接口参见dtm 架构

AP调用TM的接口

这部分接口的路径前缀为/api/dtmsvr。例如后面介绍的prepare，实际路径为/api/dtmsvr/prepare

这部分接口如果对事务状态进行变更，则dtm会对事务状态做相关的校验，有可能校验失败，而返回错误。以一个实际的例子说明：

如果调用prepare时，这个事务状态已经是failed，那么dtm将返回错误码409，错误内容：

{
    "dtm_result":"FAILURE",
    "message":"current status 'failed', cannot prepare"
}

每个接口的详细说明如下：

newGid 获取Gid

此接口用于获取gid。dtm的gid生成采用ip+snowflake。如果发生短时间内ip重用的情况，有极低概率发生gid重复情况。

因为几乎每个公司都会有自己的唯一id生成基础设置，建议在dtm中使用的gid，采用自己公司内部的唯一id生成算法。

接口名称	请求方法	请求格式	适用事务
newGid	GET	-	-

请求示例

curl 'localhost:36789/api/dtmsvr/newGid'

响应示例

{
    "dtm_result":"SUCCESS",
    "gid":"c0a8038b_4nxAcyxSX8N"
}

prepare 准备事务

此接口用于准备事务，正常情况下，后续将提交事务。

接口名称	请求方法	请求格式	适用事务
prepare	POST	JSON	MSG, TCC, XA

请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/prepare' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid": "xxx",
    "trans_type": "tcc"
}'

响应示例

{
    "dtm_result":"SUCCESS"
}

MSG 的prepare请求还会携带分支信息

MSG的prepare示例

请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/prepare' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid":"TestMsgTimeoutSuccess",
    "trans_type":"msg",
    "steps":[
        {
            "action":"http://localhost:8081/api/busi/TransOut"
        },
        {
            "action":"http://localhost:8081/api/busi/TransIn"
        }
    ],
    "payloads":[
        "{\"amount\":30,\"transInResult\":\"SUCCESS\",\"transOutResult\":\"SUCCESS\"}",
        "{\"amount\":30,\"transInResult\":\"SUCCESS\",\"transOutResult\":\"SUCCESS\"}"
    ],
    "query_prepared":"http://localhost:8081/api/busi/CanSubmit"
}'

steps 指定整个事务会分成多个步骤，每个步骤的正向操作url为action
payloads 表示每个步骤中进行http请求时的body
query_prepared 指定事务消息超时后进行查询的url

submit 提交事务

此接口用于提交全局事务

接口名称	请求方法	请求格式	适用事务
submit	POST	JSON	MSG, SAGA, TCC, XA

请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/submit' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid": "xxx",
    "trans_type": "tcc"
}'

响应示例

{
    "dtm_result":"SUCCESS"
}

其中MSG和SAGA的submit还会携带分支信息

MSG的submit示例

请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/submit' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid":"TestMsgNormal",
    "trans_type":"msg",
    "steps":[
        {
            "action":"http://localhost:8081/api/busi/TransOut"
        },
        {
            "action":"http://localhost:8081/api/busi/TransIn"
        }
    ],
    "payloads":[
        "{\"amount\":30,\"transInResult\":\"SUCCESS\",\"transOutResult\":\"SUCCESS\"}",
        "{\"amount\":30,\"transInResult\":\"SUCCESS\",\"transOutResult\":\"SUCCESS\"}"
    ]
}'

详细字段含义见上述MSG的prepare示例

SAGA的submit示例

请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/submit' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid":"TestSagaNormal",
    "trans_type":"saga",
    "steps":[
        {
            "action":"http://localhost:8081/api/busi/TransOut",
            "compensate":"http://localhost:8081/api/busi/TransOutRevert"
        },
        {
            "action":"http://localhost:8081/api/busi/TransIn",
            "compensate":"http://localhost:8081/api/busi/TransInRevert"
        }
    ],
    "payloads":[
        "{\"amount\":30,\"transInResult\":\"SUCCESS\",\"transOutResult\":\"SUCCESS\"}",
        "{\"amount\":30,\"transInResult\":\"SUCCESS\",\"transOutResult\":\"SUCCESS\"}"
    ]
}'

steps 指定整个事务会分成多个步骤，每个步骤的正向操作url为action，补偿操作url为compensate
payloads 每个步骤http请求的body

abort 回滚事务

此接口用于回滚全局事务

接口名称	请求方法	请求格式	适用事务
abort	POST	JSON	TCC, XA

请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/abort' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid": "xxx",
    "trans_type": "tcc"
}'

响应示例

{
    "dtm_result":"SUCCESS"
}

registerBranch

此接口用于TCC, XA事务模式中，注册事务分支

接口名称	请求方法	请求格式	适用事务
registerBranch	POST	JSON	XA TCC

注册XA分支请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/registerBranch' \
--header 'Content-Type: application/json' \
--data-raw '{
    "branch_id":"0101",
    "gid":"c0a8038b_4nxEEB1M7K3",
    "trans_type":"xa",
    "url":"http://localhost:8081/api/busi/xa"
}'

url: xa事务模式最后进行commit/rollback的服务地址

注册TCC分支请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/registerTccBranch' \
--header 'Content-Type: application/json' \
--data-raw '{
    "branch_id":"01",
    "cancel":"http://localhost:8081/api/busi/TransOutRevert",
    "confirm":"http://localhost:8081/api/busi/TransOutConfirm",
    "data":"{\"amount\":30,\"transInResult\":\"\",\"transOutResult\":\"\"}",
    "gid":"c0a8038b_4nxEEGy7W5h",
    "trans_type":"tcc"
}'

cancel：指定cancel操作的url
confirm：指定confirm操作的url
data：调用cancel/confirm时需要传递的body

响应示例

{
    "dtm_result":"SUCCESS"
}

query 查询事务

此接口用于查询指定gid的事务。

接口名称	请求方法	请求格式	适用事务
query	GET	-	-

请求示例

curl 'localhost:36789/api/dtmsvr/query?gid=xxx'

成功响应示例

{
    "branches":[
    ],
    "transaction":{
        "ID":69,
        "CreateTime":"2021-10-25T08:51:27+08:00",
        "UpdateTime":"2021-10-25T08:51:39+08:00",
        "gid":"xxx",
        "trans_type":"tcc",
        "data":"",
        "status":"failed",
        "query_prepared":"",
        "protocol":"http",
        "CommitTime":null,
        "FinishTime":null,
        "RollbackTime":"2021-10-25T08:51:39+08:00",
        "Options":"{}",
        "NextCronInterval":10,
        "NextCronTime":"2021-10-25T08:51:49+08:00"
    }
}

未找到gid的响应示例

{
    "branches":[
    ],
    "transaction":null
}

all 批量查询事务

此接口用于批量查询事务。dtm将返回id小于last_id，按照id从大到小排序的100条数据

接口名称	请求方法	请求格式	适用事务
all	GET	-	-

请求示例

curl 'localhost:36789/api/dtmsvr/all?last_id='

参数last_id: 上一次请求返回数据的最小id。

成功响应示例

{
    "transactions":[
        {
            "ID":69,
            "CreateTime":"2021-10-25T08:51:27+08:00",
            "UpdateTime":"2021-10-25T08:51:39+08:00",
            "gid":"xxx",
            "trans_type":"tcc",
            "data":"",
            "status":"failed",
            "query_prepared":"",
            "protocol":"http",
            "CommitTime":null,
            "FinishTime":null,
            "RollbackTime":"2021-10-25T08:51:39+08:00",
            "Options":"{}",
            "NextCronInterval":10,
            "NextCronTime":"2021-10-25T08:51:49+08:00"
        }
    ]
}

空响应示例

{
    "transactions":[
    ]
}

事务选项

事务支持以下选项，具体含义参加事务选项文档：

wait_result: 等待事务结果
retry_interval: 重试间隔
timeout_to_fail: 超时失败时间
branch_headers: 自定义header

这些事务选项可以在prepare/submit请求中，发送给TM，请求示例

curl --location --request POST 'localhost:36789/api/dtmsvr/prepare' \
--header 'Content-Type: application/json' \
--data-raw '{
    "gid": "xxx",
    "trans_type": "tcc",
    "wait_result": true,
    "retry_interval": 15,
    "branch_headers":{"test_header":"test"},
    "timeout_to_fail": 60
}'

响应示例

{
    "dtm_result":"SUCCESS"
}

kratos对接

项目概况

HTTP 参考 #

概述 #

AP调用TM的接口 #

newGid 获取Gid #

prepare 准备事务 #

MSG的prepare示例 #

submit 提交事务 #

MSG的submit示例 #

SAGA的submit示例 #

abort 回滚事务 #

registerBranch #

注册XA分支请求示例 #

注册TCC分支请求示例 #

query 查询事务 #

all 批量查询事务 #

事务选项 #

HTTP 参考

概述

AP调用TM的接口

newGid 获取Gid

prepare 准备事务

MSG的prepare示例

submit 提交事务

MSG的submit示例

SAGA的submit示例

abort 回滚事务

registerBranch

注册XA分支请求示例

注册TCC分支请求示例

query 查询事务

all 批量查询事务

事务选项