用python輕松完成一個(gè)分布式事務(wù)TCC，保姆級(jí)教程

@app.post("/api/TransOutTry")
def trans_out_try():
    return {"dtm_result": "SUCCESS"}

@app.post("/api/TransOutConfirm")
def trans_out_confirm():
    return {"dtm_result": "SUCCESS"}

@app.post("/api/TransOutCancel")
def trans_out_cancel():
    return {"dtm_result": "SUCCESS"}

@app.post("/api/TransInTry")
def trans_in_try():
    return {"dtm_result": "SUCCESS"}

@app.post("/api/TransInConfirm")
def trans_in_confirm():
    return {"dtm_result": "SUCCESS"}

@app.post("/api/TransInCancel")
def trans_in_cancel():
    return {"dtm_result": "SUCCESS"}

# 這是dtm服務(wù)地址
dtm = "http://localhost:8080/api/dtmsvr"
# 這是業(yè)務(wù)微服務(wù)地址
svc = "http://localhost:5000/api"

@app.get("/api/fireTcc")
def fire_tcc():
    # 發(fā)起tcc事務(wù)，其中tcc_trans進(jìn)行具體的業(yè)務(wù)處理
    gid = tcc.tcc_global_transaction(dtm, tcc_trans)
    return {"gid": gid}

# tcc事務(wù)的具體處理
def tcc_trans(t):
    req = {"amount": 30} # 業(yè)務(wù)請(qǐng)求的負(fù)荷
    # 調(diào)用轉(zhuǎn)出服務(wù)的Try|Confirm|Cancel
    t.call_branch(req, svc + "/TransOutTry", svc + "/TransOutConfirm", svc + "/TransOutCancel")
    # 調(diào)用轉(zhuǎn)入服務(wù)的Try|Confirm|Cancel
    t.call_branch(req, svc + "/TransInTry", svc + "/TransInConfirm", svc + "/TransInCancel")

# 部署啟動(dòng)dtm
# 需要docker版本18以上
git clone https://github.com/yedf/dtm
cd dtm
docker-compose up

# 另起一個(gè)命令行
git clone https://github.com/yedf/dtmcli-py-sample
cd dtmcli-py-sample
pip3 install flask dtmcli requests
flask run

# 另起一個(gè)命令行
curl localhost:5000/api/fireTcc

@app.post("/api/TransInTry")
def trans_in_try():
    return {"dtm_result": "FAILURE"}