介面冪等性如何實現?

来源:https://www.cnblogs.com/Chenjiabing/archive/2020/03/26/12574042.html
-Advertisement-
Play Games

導讀 轉載自 "冪等性如何實現?深入瞭解一波!!!" 現在這個時代大家可能最關心的就是錢了,那麼有沒有想過你銀行轉賬給你沒有一次是轉多的,要麼失敗,要麼成功,為什麼不能失誤一下多轉一筆呢?醒醒吧年輕人,別做夢了,做銀行的能那麼傻x嗎? 今天我們就來談一談為什麼銀行轉賬不能多給我轉一筆?關乎到錢的問題 ...


導讀

  • 轉載自冪等性如何實現?深入瞭解一波!!!
  • 現在這個時代大家可能最關心的就是錢了,那麼有沒有想過你銀行轉賬給你沒有一次是轉多的,要麼失敗,要麼成功,為什麼不能失誤一下多轉一筆呢?醒醒吧年輕人,別做夢了,做銀行的能那麼傻x嗎?
  • 今天我們就來談一談為什麼銀行轉賬不能多給我轉一筆?關乎到錢的問題,小伙伴們打起精神!!!
  • 要想要理解上述的疑惑,不得不提的一個概念就是冪等性,至於什麼是冪等性,如何通過代碼實現冪等性,下麵將會詳細講述。

什麼是冪等性

  • 所謂冪等性通俗的將就是一次請求和多次請求同一個資源產生相同的副作用。用數學語言表達就是f(x)=f(f(x))
  • 維基百科的冪等性定義如下:
冪等(idempotent、idempotence)是一個數學與電腦學概念,常見於抽象代數中。
在編程中一個冪等操作的特點是其任意多次執行所產生的影響均與一次執行的影響相同。冪等函數,或冪等方法,是指可以使用相同參數重覆執行,並能獲得相同結果的函數。這些函數不會影響系統狀態,也不用擔心重覆執行會對系統造成改變。例如,“setTrue()”函數就是一個冪等函數,無論多次執行,其結果都是一樣的,更複雜的操作冪等保證是利用唯一交易號(流水號)實現.

為什麼需要冪等性

  • 在系統高併發的環境下,很有可能因為網路,阻塞等等問題導致客戶端或者調用方並不能及時的收到服務端的反饋甚至是調用超時的問題。總之,就是請求方調用了你的服務,但是沒有收到任何的信息,完全懵逼的狀態。比如訂單的問題,可能會遇到如下的幾個問題:
  1. 創建訂單時,第一次調用服務超時,再次調用是否產生兩筆訂單?
  2. 訂單創建成功去減庫存時,第一次減庫存超時,是否會多扣一次?
  3. 訂單支付時,服務端扣錢成功,但是介面反饋超時,此時再次調用支付,是否會多扣一筆呢?
  • 作為消費者,前兩種能接受,第三種情況就MMP了,哈哈哈!!!這種情況一般有如下兩種解決方式
  1. 服務方提供一個查詢操作是否成功的api,第一次超時之後,調用方調用查詢介面,如果查到了就走成功的流程,失敗了就走失敗的流程。
  2. 另一種就是服務方需要使用冪等的方式保證一次和多次的請求結果一致。

HTTP的冪等性

  • GET:只是獲取資源,對資源本身沒有任何副作用,天然的冪等性。
  • HEAD:本質上和GET一樣,獲取頭信息,主要是探活的作用,具有冪等性。
  • OPTIONS:獲取當前URL所支持的方法,因此也是具有冪等性的。
  • DELETE:用於刪除資源,有副作用,但是它應該滿足冪等性,比如根據id刪除某一個資源,調用方可以調用N次而不用擔心引起的錯誤(根據業務需求而變)。
  • PUT:用於更新資源,有副作用,但是它應該滿足冪等性,比如根據id更新數據,調用多次和N次的作用是相同的(根據業務需求而變)。
  • POST:用於添加資源,多次提交很可能產生副作用,比如訂單提交,多次提交很可能產生多筆訂單。

冪等性的實現方式

  • 對於客戶端交互的介面,可以在前端攔截一部分,例如防止表單重覆提交,按鈕置灰,隱藏,不可點擊等方式。但是前端進行攔截器顯然是針對普通用戶,懂點技術的都可以模擬請求調用介面,所以後端冪等性很重要。
  • 後端的冪等性如何實現?將會從以下幾個方面介紹。

資料庫去重表

  • 在往資料庫中插入數據的時候,利用資料庫唯一索引特性,保證數據唯一。比如訂單的流水號,也可以是多個欄位的組合。
  • 實現比較簡單,讀者可以自己實現看看,這裡不再提供demo了。

狀態機

  • 很多業務中多有多個狀態,比如訂單的狀態有提交、待支付、已支付、取消、退款等等狀態。後端可以根據不同的狀態去保證冪等性,比如在退款的時候,一定要保證這筆訂單是已支付的狀態。
  • 業務中常常出現,讀者可以自己實現看看,不再提供demo。

TOKEN機制

  • 針對客戶端連續點擊或者調用方的超時重試等情況,例如提交訂單,此種操作就可以用Token的機制實現防止重覆提交。
  • TOKEN機制如何實現?簡單的說就是調用方在調用介面的時候先向後端請求一個全局ID(TOKEN),請求的時候攜帶這個全局ID一起請求,後端需要對這個全局ID校驗來保證冪等操作,流程如下圖:

  • 主要的流程步驟如下:
    • 客戶端先發送獲取token的請求,服務端會生成一個全局唯一的ID保存在redis中,同時把這個ID返回給客戶端。
    • 客戶端調用業務請求的時候必須攜帶這個token,一般放在請求頭上。
    • 服務端會校驗這個Token,如果校驗成功,則執行業務。
    • 如果校驗失敗,則表示重覆操作,直接返回指定的結果給客戶端。
  • 通過以上的流程分析,唯一的重點就是這個全局唯一ID如何生成,在分散式服務中往往都會有一個生成全局ID的服務來保證ID的唯一性,但是工程量和實現難度比較大,UUID的數據量相對有些大,此處陳某選擇的是雪花演算法生成全局唯一ID,不瞭解雪花演算法的讀者下一篇文章會著重介紹。

代碼實現

  • 陳某選擇的環境是SpringBoot+Redis單機環境+註解+攔截器的方式實現,只是演示一下思想,具體的代碼可以參照實現。
  • redis如何實現,獲取Token介面將全局唯一Id存入Redis(一定要設置失效時間,根據業務需求),業務請求的時候直接從redis中刪除,根據delete的返回值判斷,返回true表示第一次請求,返回false表示重覆請求。代碼如下:
@Service
public class TokenServiceImpl implements TokenService {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Override
    public String getToken() {
        //獲取全局唯一id
        long nextId = SnowflakeUtil.nextId();
        //存入redis,設置10分鐘失效
        stringRedisTemplate.opsForValue().set(String.valueOf(nextId), UUID.randomUUID().toString(),10, TimeUnit.MINUTES);
        return String.valueOf(nextId);
    }

    /**
    * 刪除記錄,true表示第一次提交,false重覆提交
    */
    @Override
    public Boolean checkToken(String token) {
        return stringRedisTemplate.delete(token);
    }
}
  • 註解的實現如下,標註在controller類上表示當前類上全部介面都做冪等,標註單個方法上,表示單個介面做冪等操作。
/**
 * @Description 冪等操作的註解
 * @Author CJB
 * @Date 2020/3/25 10:19
 */
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RepeatLimiter {
}
  • 請求頭的攔截器,用於提取請求頭和校驗請求頭,如下:
/**
 * @Description 獲取請求頭的信息,具體校驗邏輯讀者自己實現
 * @Author CJB
 * @Date 2020/3/25 11:09
 */
@Component
public class HeaderIntercept implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        //獲取token
        String token = request.getHeader(HeaderConstant.TOKEN);
        //校驗邏輯
        if (!validToken(token))
            throw new TokenInvalidException("TOKEN失效");
        //獲取其他的參數.....
        RequestHeader header = RequestHeader.builder()
                .token(token)
                .build();
        //放入request中
        request.setAttribute(HeaderConstant.HEADER_INFO,header);
        return true;
    }

    /**
     * 校驗token,邏輯自己實現
     * @param token
     * @return
     */
    private boolean validToken(String token){
        return Boolean.TRUE;
    }
}
  • 保證冪等性的攔截器,直接從redis中刪除token,成功則第一次提交,不成功則重覆提交。
@Component
public class RepeatIntercept implements HandlerInterceptor {

    @Autowired
    private TokenService tokenService;

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        if (handler instanceof HandlerMethod){
            //獲取方法上的參數
            RepeatLimiter repeatLimiter = AnnotationUtils.findAnnotation(((HandlerMethod) handler).getMethod(), RepeatLimiter.class);

            if (Objects.isNull(repeatLimiter)){
                //獲取controller類上註解
                repeatLimiter=AnnotationUtils.findAnnotation(((HandlerMethod) handler).getBean().getClass(),RepeatLimiter.class);
            }

            //使用註解,需要攔截驗證
            if (Objects.nonNull(repeatLimiter)){
                //獲取全局token,表單提交的唯一id
                RequestHeader info = RequestContextUtils.getHeaderInfo();

                //沒有攜帶token,拋異常,這裡的異常需要全局捕獲
                if (StringUtils.isEmpty(info.getToken()))
                    throw new RepeatException();

                //校驗token
                Boolean flag = tokenService.checkToken(info.getToken());

                //刪除失敗,表示
                if (Boolean.FALSE.equals(flag))
                    //拋出重覆提交的異常
                    throw new RepeatException();
            }
        }
        return true;
    }
}
  • 介面冪等實現,代碼如下:
@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private OrderService orderService;

    /**
     * 下單
     * @param order
     * @return
     */
    @PostMapping
    @RepeatLimiter  //冪等性保證
    public CommenResult add(@RequestBody Order order){
        orderService.save(order);
        return new CommenResult("200","下單成功");
    }
}

演示

  • 發送getToken的請求獲取Token

  • 攜帶Token下單第一次:

  • 第二次下單:


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • HTML頭部head元素包含關於文檔的概要信息,也被稱為元信息(meta-information),head定義了文檔的信息,title定義了文檔的標題,base定義了頁面鏈接標簽的預設鏈接地址,link定義了一個文檔和外部資源之間的關係,meta定義了HTML文檔中的元數據,script定義了客戶... ...
  • 1、打開setting——plugins 2、下載一個webstorm插件 Sexy Editor 如下圖: 3、下載完成之後重啟 4、重啟之後打開setting 找到 SexyEditor 選項 並點擊右側底部的 Add images 按鈕 5、 選擇自己喜歡的圖片 6、可以調整透明度 尺寸等 7 ...
  • 前端作為互聯網時代直接觸達用戶的視窗,大到我們每天瀏覽到的網站,小到一次點擊按鈕的頁面,前端無處不在。並且在產品的眾多開發環節之中,最能讓用戶直觀感受到的就是前端開發。因而前端行業的廣闊發展前景也吸引了不少人的轉業學習。那麼,零基礎如何學好前端呢?有什麼建議嗎?本文將為初學者詳細解答一下這兩個問題, ...
  • 正常我們寫一個左右兩列,左側一列放置圖片的html,如下所示: <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Title</title> <style> .container{ background-col ...
  • 在vue項目中,為了減少首屏載入的時間,通常會開啟路由的懶載入。路由懶載入配合gizp確實能幫助我們大大的加快首屏的載入時間。 然而,路由懶載入會使得我們在第一次打開一個新頁面的時候,會有一個載入時間。如果在這個時候我們沒有一個提示的話,給人的感覺會是好像我點了頁面跳轉但是沒反應。所以,這個時候我們 ...
  • 先上一張咱們的原始圖 rs7.jpg 如下: 一、mask-image屬性 1.基本的png圖遮罩展示 我們使用的遮罩圖片 ad.png,如下: html: <img src="rs7.jpg" alt="" class="mask-img"> css: .mask-img { width: 300 ...
  • 最詳細的css3選擇器解析 選擇器是什麼? 比較官方的解釋:在 CSS 中,選擇器是一種模式,用於選擇需要添加樣式的元素。 最常見的 CSS 選擇器是元素選擇器。換句話說,文檔的元素就是最基本的選擇器。 看代碼,元素選擇器就是這個: h1作為一個元素標簽,是最基本的選擇器,這樣可以對h1標簽設置屬性 ...
  • 首先保證路徑正確,引入ttf字體,沒有生效 使用線上工具把ttf轉為更多常用的字體格式 網址:https://www.fontke.com/tool/convfont/ css里補全格式: 生效了 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...