快捷導(dǎo)航

Java接口冪等性設(shè)計(jì)原理解析

更新時(shí)間：2020年05月30日 11:22:17 作者：隨風(fēng)而逝,只是飄零

這篇文章主要介紹了Java接口冪等性設(shè)計(jì)原理解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

在微服務(wù)架構(gòu)下，我們?cè)谕瓿梢粋€(gè)訂單流程時(shí)經(jīng)常遇到下面的場(chǎng)景：

一個(gè)訂單創(chuàng)建接口，第一次調(diào)用超時(shí)了，然后調(diào)用方重試了一次
在訂單創(chuàng)建時(shí)，我們需要去扣減庫(kù)存，這時(shí)接口發(fā)生了超時(shí)，調(diào)用方重試了一次
當(dāng)這筆訂單開(kāi)始支付，在支付請(qǐng)求發(fā)出之后，在服務(wù)端發(fā)生了扣錢(qián)操作，接口響應(yīng)超時(shí)了，調(diào)用方重試了一次
一個(gè)訂單狀態(tài)更新接口，調(diào)用方連續(xù)發(fā)送了兩個(gè)消息，一個(gè)是已創(chuàng)建，一個(gè)是已付款。但是你先接收到已付款，然后又接收到了已創(chuàng)建
在支付完成訂單之后，需要發(fā)送一條短信，當(dāng)一臺(tái)機(jī)器接收到短信發(fā)送的消息之后，處理較慢。消息中間件又把消息投遞給另外一臺(tái)機(jī)器處理

以上問(wèn)題，就是在單體架構(gòu)轉(zhuǎn)成微服務(wù)架構(gòu)之后，帶來(lái)的問(wèn)題。當(dāng)然不是說(shuō)單體架構(gòu)下沒(méi)有這些問(wèn)題，在單體架構(gòu)下同樣要避免重復(fù)請(qǐng)求。但是出現(xiàn)的問(wèn)題要比這少得多。

為了解決以上問(wèn)題，就需要保證接口的冪等性，接口的冪等性實(shí)際上就是接口可重復(fù)調(diào)用，在調(diào)用方多次調(diào)用的情況下，接口最終得到的結(jié)果是一致的。有些接口可以天然的實(shí)現(xiàn)冪等性，比如查詢(xún)接口，對(duì)于查詢(xún)來(lái)說(shuō)，你查詢(xún)一次和兩次，對(duì)于系統(tǒng)來(lái)說(shuō)，沒(méi)有任何影響，查出的結(jié)果也是一樣。

除了查詢(xún)功能具有天然的冪等性之外，增加、更新、刪除都要保證冪等性。那么如何來(lái)保證冪等性呢？

全局唯一ID

如果使用全局唯一ID，就是根據(jù)業(yè)務(wù)的操作和內(nèi)容生成一個(gè)全局ID，在執(zhí)行操作前先根據(jù)這個(gè)全局唯一ID是否存在，來(lái)判斷這個(gè)操作是否已經(jīng)執(zhí)行。如果不存在則把全局ID，存儲(chǔ)到存儲(chǔ)系統(tǒng)中，比如數(shù)據(jù)庫(kù)、redis等。如果存在則表示該方法已經(jīng)執(zhí)行。

從工程的角度來(lái)說(shuō)，使用全局ID做冪等可以作為一個(gè)業(yè)務(wù)的基礎(chǔ)的微服務(wù)存在，在很多的微服務(wù)中都會(huì)用到這樣的服務(wù)，在每個(gè)微服務(wù)中都完成這樣的功能，會(huì)存在工作量重復(fù)。另外打造一個(gè)高可靠的冪等服務(wù)還需要考慮很多問(wèn)題，比如一臺(tái)機(jī)器雖然把全局ID先寫(xiě)入了存儲(chǔ)，但是在寫(xiě)入之后掛了，這就需要引入全局ID的超時(shí)機(jī)制。

使用全局唯一ID是一個(gè)通用方案，可以支持插入、更新、刪除業(yè)務(wù)操作。但是這個(gè)方案看起來(lái)很美但是實(shí)現(xiàn)起來(lái)比較麻煩，下面的方案適用于特定的場(chǎng)景，但是實(shí)現(xiàn)起來(lái)比較簡(jiǎn)單。

去重表

這種方法適用于在業(yè)務(wù)中有唯一標(biāo)的插入場(chǎng)景中，比如在以上的支付場(chǎng)景中，如果一個(gè)訂單只會(huì)支付一次，所以訂單ID可以作為唯一標(biāo)識(shí)。這時(shí)，我們就可以建一張去重表，并且把唯一標(biāo)識(shí)作為唯一索引，在我們實(shí)現(xiàn)時(shí)，把創(chuàng)建支付單據(jù)和寫(xiě)入去去重表，放在一個(gè)事務(wù)中，如果重復(fù)創(chuàng)建，數(shù)據(jù)庫(kù)會(huì)拋出唯一約束異常，操作就會(huì)回滾。

插入或更新

這種方法插入并且有唯一索引的情況，比如我們要關(guān)聯(lián)商品品類(lèi)，其中商品的ID和品類(lèi)的ID可以構(gòu)成唯一索引，并且在數(shù)據(jù)表中也增加了唯一索引。這時(shí)就可以使用InsertOrUpdate操作。在mysql數(shù)據(jù)庫(kù)中如下：

insert into goods_category (goods_id,category_id,create_time,update_time)
values(#{goodsId},#{categoryId},now(),now())
on DUPLICATE KEY UPDATE
update_time=now()

多版本控制

這種方法適合在更新的場(chǎng)景中，比如我們要更新商品的名字，這時(shí)我們就可以在更新的接口中增加一個(gè)版本號(hào)，來(lái)做冪等

boolean updateGoodsName(int id,String newName,int version);

在實(shí)現(xiàn)時(shí)可以如下

update goods set name=#{newName},version=#{version} where id=#{id} and version<${version}

狀態(tài)機(jī)控制

這種方法適合在有狀態(tài)機(jī)流轉(zhuǎn)的情況下，比如就會(huì)訂單的創(chuàng)建和付款，訂單的付款肯定是在之前，這時(shí)我們可以通過(guò)在設(shè)計(jì)狀態(tài)字段時(shí)，使用int類(lèi)型，并且通過(guò)值類(lèi)型的大小來(lái)做冪等，比如訂單的創(chuàng)建為0，付款成功為100。付款失敗為99

在做狀態(tài)機(jī)更新時(shí)，我們就這可以這樣控制

update `order` set status=#{status} where id=#{id} and status<#{status}

以上就是保證接口冪等性的一些方法。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: