谷粒分布式事務(wù)

1、谷粒分布式事務(wù)1 介紹庫(kù)存結(jié)果和物流返回訂單支付服務(wù)訂單服務(wù)庫(kù)存服務(wù)訂單業(yè)務(wù)的完成Db事務(wù)協(xié)調(diào)器事務(wù)訂單Db事務(wù)支付事務(wù)庫(kù)存Db事務(wù)其他Db1 xa協(xié)議下的兩段式提交在xa協(xié)議下，提交一個(gè)事務(wù)需要經(jīng)過(guò)兩個(gè)階段階段一：預(yù)備提交階段二：提交2 xa兩段式提交的進(jìn)階版：tcc(try confirm cancle)需要在業(yè)務(wù)層實(shí)現(xiàn)，try，confirm，和cancle的接口3基于消息的，采取最終一致性策略的分布式事務(wù)(消息隊(duì)列MQ)在一個(gè)事務(wù)正在進(jìn)行的同時(shí)，發(fā)出消息給其他的業(yè)務(wù)如果消息發(fā)送失敗，或者消息的執(zhí)行失敗，則回滾消息，重復(fù)執(zhí)行反復(fù)執(zhí)行失敗后，記錄失敗信息，后期補(bǔ)充性的處理在消息系統(tǒng)中開(kāi)啟事

2、務(wù)，消息的事務(wù)是指，保證消息被正常消費(fèi)，否則回滾的一種機(jī)制2 消息隊(duì)列中間件1 activeMq，由apache開(kāi)發(fā)，基于jms的接口規(guī)則2 RabbitMQ，c開(kāi)發(fā)，基于amqp協(xié)議3 kafka，大數(shù)據(jù)的消息中間件4 zeroMq，基于socket協(xié)議5 mateMq，阿里的產(chǎn)品啟動(dòng)activeMq start3 消息隊(duì)列的模式Consumer監(jiān)聽(tīng)器queueproducerConsumer監(jiān)聽(tīng)器Consumer監(jiān)聽(tīng)器topicproducerConsumer監(jiān)聽(tīng)器拉消息到消費(fèi)端ConsumerMqAQueue記錄消費(fèi)狀態(tài)AA記錄消費(fèi)狀態(tài)B記錄消費(fèi)狀態(tài)Topic4 mq整合spring1

3、編寫(xiě)mq的工廠2 將mq工廠初始化到spring容器中3 將mq的監(jiān)聽(tīng)器封裝到spring的容器中5 分布式事務(wù)的業(yè)務(wù)模型0 提交訂單的延遲檢查(支付服務(wù))PAYMENT_CHECK_QUEUE1 支付完成(支付服務(wù))PAYHMENT_SUCCESS_QUEUE2 訂單已支付(訂單服務(wù))ORDER_PAY_QUEUE3 庫(kù)存鎖定(庫(kù)存系統(tǒng))SKU_DEDUCT_QUEUE4 訂單已出庫(kù)(訂單服務(wù))ORDER_SUCCESS_QUEUE購(gòu)物車(chē)合并隊(duì)列商品管理同步隊(duì)列6 分布式事務(wù)的復(fù)習(xí)1 分布式事務(wù)事務(wù)：保證數(shù)據(jù)的一致性分布式事務(wù)：在分布式環(huán)境下保證數(shù)據(jù)的一致性2 分布式事務(wù)的解決方案xa協(xié)議，

4、事務(wù)管理器，資源管理器之間協(xié)議兩端式提交，xa和tcc(try,confirm,concle)消息，最終一致性的解決方案3 基于消息隊(duì)列的解決方案將消息的事務(wù)和普通事務(wù)放在一起，同時(shí)提交或者回滾7 延遲隊(duì)列1 延遲隊(duì)列解決的問(wèn)題定時(shí)任務(wù)(延遲隊(duì)列)在提交支付時(shí)，向消息隊(duì)列發(fā)送一個(gè)延遲執(zhí)行的消息任務(wù)，當(dāng)該任務(wù)被支付服務(wù)執(zhí)行時(shí)，在消費(fèi)任務(wù)的程序中去查詢當(dāng)前交易的交易狀態(tài)，根據(jù)交易狀態(tài)(支付結(jié)束)決定解除延遲任務(wù)還是繼續(xù)再設(shè)置新的延遲任務(wù)配置消息隊(duì)列的延遲屬性：schedulerSupport=true2 消費(fèi)延遲隊(duì)列(支付服務(wù))檢查當(dāng)前訂單的交易狀態(tài)，根據(jù)交易狀態(tài)(沒(méi)有成功支付)，設(shè)置重新發(fā)送延遲

5、檢查的時(shí)間和隊(duì)列檢查當(dāng)前訂單的交易狀態(tài)，根據(jù)交易狀態(tài)(成功支付)，更新支付信息發(fā)送訂單隊(duì)列(冪等性檢查)再支付服務(wù)的mq消費(fèi)端PaymentServiceMqListener調(diào)用阿里的支付查詢接口（通過(guò)paymentService）3 延遲檢查的限制服務(wù)Mq隊(duì)列監(jiān)聽(tīng)4 檢查支付情況的接口A 交易未創(chuàng)建B 交易已創(chuàng)建，但未付款C 交易已成功5 冪等性服務(wù)器資源對(duì)于相同的請(qǐng)求，一次或者多次，所返回的結(jié)果狀態(tài)應(yīng)該保持一致8 庫(kù)存系統(tǒng)的介紹1 庫(kù)存表Wms_ware_info2 庫(kù)存系統(tǒng)和商品(sku)的對(duì)應(yīng)關(guān)系表Wms_ware_sku多對(duì)多3 wms_ware_order_task庫(kù)存系統(tǒng)根據(jù)庫(kù)存情況，對(duì)訂單的拆分結(jié)果4 wms_ware_order_task_detail庫(kù)存拆單后的，庫(kù)存訂單詳情按照支付訂單的商品信息進(jìn)行庫(kù)存鎖定庫(kù)存拆單訂單消息