這篇“springboot如何實現(xiàn)接口自動冪等”文章的知識點大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細(xì),步驟清晰,具有一定的借鑒價值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“springboot如何實現(xiàn)接口自動冪等”文章吧。
成都創(chuàng)新互聯(lián)-成都網(wǎng)站建設(shè)公司,專注網(wǎng)站制作、成都網(wǎng)站設(shè)計、網(wǎng)站營銷推廣,域名與空間,虛擬空間,網(wǎng)站改版維護有關(guān)企業(yè)網(wǎng)站制作方案、改版、費用等問題,請聯(lián)系成都創(chuàng)新互聯(lián)。
1.概念: 任意多次執(zhí)行所產(chǎn)生的影響均與一次執(zhí)行的影響相同。
按照這個含義,最終的含義就是 對數(shù)據(jù)庫的影響只能是一次性的,不能重復(fù)處理。如何保證其冪等性,通常有以下手段:
1: 數(shù)據(jù)庫建立唯一性索引,可以保證最終插入數(shù)據(jù)庫的只有一條數(shù)據(jù)
2: token 機制,每次接口請求前先獲取一個 token,然后再下次請求的時候在請求的 header 體中加上這個 token,后臺進行驗證,如果驗證通過刪除 token,下次請求再次判斷 token
3: 悲觀鎖或者樂觀鎖,悲觀鎖可以保證每次 for update 的時候其他 sql 無法 update 數(shù)據(jù) (在數(shù)據(jù)庫引擎是 innodb 的時候, select 的條件必須是唯一索引, 防止鎖全表)
4: 先查詢后判斷,首先通過查詢數(shù)據(jù)庫是否存在數(shù)據(jù),如果存在證明已經(jīng)請求過了,直接拒絕該請求,如果沒有存在,就證明是第一次進來,直接放行。
redis 實現(xiàn)自動冪等的原理圖:
1: 首先是搭建 redis 服務(wù)器。
2: 引入 springboot 中到的 redis 的 stater,或者 Spring 封裝的 jedis 也可以,后面主要用到的 api 就是它的 set 方法和 exists 方法, 這里我們使用 springboot 的封裝好的 redisTemplate
代碼如下:
/* redis工具類 */ @Component public class RedisService { @Autowired private RedisTemplate redisTemplate; /** * 寫入緩存 * @param key * @param value * @return */ public boolean set(final String key,Object value){ boolean result = false; try { ValueOperations<Serializable,Object> operations = redisTemplate.opsForValue(); operations.set(key,value); result = true; }catch (Exception e){ result = false; e.printStackTrace(); } return result; } /** * 寫入緩存有效期 * @return */ public boolean setEx(final String key ,Object value,Long expireTime){ boolean result = false; try { ValueOperations<Serializable,Object> operations = redisTemplate.opsForValue(); operations.set(key,value); redisTemplate.expire(key,expireTime, TimeUnit.SECONDS);//有效期 result = true; }catch (Exception e){ result = false; e.printStackTrace(); } return result; } /** * 判斷緩存中是否有對應(yīng)的value * @param key * @return */ public boolean exists(final String key){ return redisTemplate.hasKey(key); } /** * 讀取緩存 * @param key * @return */ public Object get(final String key){ Object obj = null; ValueOperations<Serializable,Object> operations= redisTemplate.opsForValue(); obj = operations.get(key); return obj; } /** * 刪除對應(yīng)的value * @param key * @return */ public boolean remvoe(final String key){ if(exists(key)){ Boolean delete = redisTemplate.delete(key); return delete; } return false; } }
自定義一個注解,定義此注解的主要目的是把它添加在需要實現(xiàn)冪等的方法上,凡是某個方法注解了它,都會實現(xiàn)自動冪等。后臺利用反射如果掃描到這個注解,就會處理這個方法實現(xiàn)自動冪等,使用元注解 ElementType.METHOD 表示它只能放在方法上,etentionPolicy.RUNTIME 表示它在運行時
package com.yxkj.springboot_redis_interceptor.annotion; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; @Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface AutoIdempotent { }
我們新建一個接口,創(chuàng)建 token 服務(wù),里面主要是兩個方法,一個用來創(chuàng)建 token,一個用來驗證 token。創(chuàng)建 token 主要產(chǎn)生的是一個字符串,檢驗 token 的話主要是傳達 request 對象,為什么要傳 request 對象呢?主要作用就是獲取 header 里面的 token, 然后檢驗,通過拋出的 Exception 來獲取具體的報錯信息返回給前端
public interface TokenService { /** * 創(chuàng)建token * @return */ String createToken(); /** * 檢驗token的合法性 * @param request * @return * @throws Exception */ boolean checkToken(HttpServletRequest request) throws Exception; }
token 引用了 redis 服務(wù),創(chuàng)建 token 采用隨機算法工具類生成隨機 uuid 字符串, 然后放入到 redis 中 (為了防止數(shù)據(jù)的冗余保留, 這里設(shè)置過期時間為 10000 秒, 具體可視業(yè)務(wù)而定),如果放入成功,最后返回這個 token 值。checkToken 方法就是從 header 中獲取 token 到值 (如果 header 中拿不到,就從 paramter 中獲取),如若不存在, 直接拋出異常。這個異常信息可以被攔截器捕捉到,然后返回給前端。
以上就是關(guān)于“springboot如何實現(xiàn)接口自動冪等”這篇文章的內(nèi)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對大家有幫助,若想了解更多相關(guān)的知識內(nèi)容,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
網(wǎng)站題目:springboot如何實現(xiàn)接口自動冪等
文章轉(zhuǎn)載:http://www.rwnh.cn/article10/gjhhdo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供移動網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計公司、企業(yè)建站、自適應(yīng)網(wǎng)站、、小程序開發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)