對于一些用戶請求，在某些情況下是可能重復發送的，如果是查詢類操作并無大礙，但其中有些是涉及寫入操作的，一旦重復了，可能會導致很嚴重的后果，例如交易的介面如果重復請求可能會重復下單，
重復的場景有可能是：
- 黑客攔截了請求，重放
- 前端/客戶端因為某些原因請求重復發送了，或者用戶在很短的時間內重復點擊了，
- 網關重發
- ….
本文討論的是如果在服務端優雅地統一處理這種情況，如何禁止用戶重復點擊等客戶端操作不在本文的討論范疇，
利用唯一請求編號去重
你可能會想到的是，只要請求有唯一的請求編號，那么就能借用Redis做這個去重——只要這個唯一請求編號在redis存在，證明處理過，那么就認為是重復的
代碼大概如下：
String KEY = "REQ12343456788";//請求唯一編號
long expireTime = 1000;// 1000毫秒過期，1000ms內的重復請求會認為重復
long expireAt = System.currentTimeMillis() + expireTime;
String val = "expireAt@" + expireAt;
//redis key還存在的話要就認為請求是重復的
Boolean firstSet = stringRedisTemplate.execute((RedisCallback<Boolean>) connection -> connection.set(KEY.getBytes(), val.getBytes(), Expiration.milliseconds(expireTime), RedisStringCommands.SetOption.SET_IF_ABSENT));
final boolean isConsiderDup;
if (firstSet != null && firstSet) {// 第一次訪問
isConsiderDup = false;
} else {// redis值已存在，認為是重復了
isConsiderDup = true;
}
業務引數去重
上面的方案能解決具備唯一請求編號的場景，例如每次寫請求之前都是服務端回傳一個唯一編號給客戶端，客戶端帶著這個請求號做請求，服務端即可完成去重攔截，
但是，很多的場景下，請求并不會帶這樣的唯一編號！那么我們能否針對請求的引數作為一個請求的標識呢？
先考慮簡單的場景，假設請求引數只有一個欄位reqParam，我們可以利用以下標識去判斷這個請求是否重復， 用戶ID:介面名:請求引數
String KEY = "dedup:U="+userId + "M=" + method + "P=" + reqParam;
那么當同一個用戶訪問同一個介面，帶著同樣的reqParam過來，我們就能定位到他是重復的了，
但是問題是，我們的介面通常不是這么簡單，以目前的主流，我們的引數通常是一個JSON，那么針對這種場景，我們怎么去重呢？
計算請求引數的摘要作為引數標識
假設我們把請求引數（JSON）按KEY做升序排序，排序后拼成一個字串，作為KEY值呢？但這可能非常的長，所以我們可以考慮對這個字串求一個MD5作為引數的摘要，以這個摘要去取代reqParam的位置，
String KEY = "dedup:U="+userId + "M=" + method + "P=" + reqParamMD5;
這樣，請求的唯一標識就打上了！
注：MD5理論上可能會重復，但是去重通常是短時間視窗內的去重（例如一秒），一個短時間內同一個用戶同樣的介面能拼出不同的引數導致一樣的MD5幾乎是不可能的，
繼續優化，考慮剔除部分時間因子
上面的問題其實已經是一個很不錯的解決方案了，但是實際投入使用的時候可能發現有些問題：某些請求用戶短時間內重復的點擊了（例如1000毫秒發送了三次請求），但繞過了上面的去重判斷（不同的KEY值），
原因是這些請求引數的欄位里面，是帶時間欄位的，這個欄位標記用戶請求的時間，服務端可以借此丟棄掉一些老的請求（例如5秒前），如下面的例子，請求的其他引數是一樣的，除了請求時間相差了一秒：
//兩個請求一樣，但是請求時間差一秒
String req = "{\n" +
"\"requestTime\" :\"20190101120001\",\n" +
"\"requestValue\" :\"1000\",\n" +
"\"requestKey\" :\"key\"\n" +
"}";
String req2 = "{\n" +
"\"requestTime\" :\"20190101120002\",\n" +
"\"requestValue\" :\"1000\",\n" +
"\"requestKey\" :\"key\"\n" +
"}";
這種請求，我們也很可能需要擋住后面的重復請求，所以求業務引數摘要之前，需要剔除這類時間欄位，還有類似的欄位可能是GPS的經緯度欄位（重復請求間可能有極小的差別），
請求去重工具類，Java實作
public class ReqDedupHelper {
/**
*
* @param reqJSON 請求的引數，這里通常是JSON
* @param excludeKeys 請求引數里面要去除哪些欄位再求摘要
* @return 去除引數的MD5摘要
*/
public String dedupParamMD5(final String reqJSON, String... excludeKeys) {
String decreptParam = reqJSON;
TreeMap paramTreeMap = JSON.parseObject(decreptParam, TreeMap.class);
if (excludeKeys!=null) {
List<String> dedupExcludeKeys = Arrays.asList(excludeKeys);
if (!dedupExcludeKeys.isEmpty()) {
for (String dedupExcludeKey : dedupExcludeKeys) {
paramTreeMap.remove(dedupExcludeKey);
}
}
}
String paramTreeMapJSON = JSON.toJSONString(paramTreeMap);
String md5deDupParam = jdkMD5(paramTreeMapJSON);
log.debug("md5deDupParam = {}, excludeKeys = {} {}", md5deDupParam, Arrays.deepToString(excludeKeys), paramTreeMapJSON);
return md5deDupParam;
}
private static String jdkMD5(String src) {
String res = null;
try {
MessageDigest messageDigest = MessageDigest.getInstance("MD5");
byte[] mdBytes = messageDigest.digest(src.getBytes());
res = DatatypeConverter.printHexBinary(mdBytes);
} catch (Exception e) {
log.error("",e);
}
return res;
}
}
下面是一些測驗日志：
public static void main(String[] args) {
//兩個請求一樣，但是請求時間差一秒
String req = "{\n" +
"\"requestTime\" :\"20190101120001\",\n" +
"\"requestValue\" :\"1000\",\n" +
"\"requestKey\" :\"key\"\n" +
"}";
String req2 = "{\n" +
"\"requestTime\" :\"20190101120002\",\n" +
"\"requestValue\" :\"1000\",\n" +
"\"requestKey\" :\"key\"\n" +
"}";
//全引數比對，所以兩個引數MD5不同
String dedupMD5 = new ReqDedupHelper().dedupParamMD5(req);
String dedupMD52 = new ReqDedupHelper().dedupParamMD5(req2);
System.out.println("req1MD5 = "+ dedupMD5+" , req2MD5="+dedupMD52);
//去除時間引數比對，MD5相同
String dedupMD53 = new ReqDedupHelper().dedupParamMD5(req,"requestTime");
String dedupMD54 = new ReqDedupHelper().dedupParamMD5(req2,"requestTime");
System.out.println("req1MD5 = "+ dedupMD53+" , req2MD5="+dedupMD54);
}
日志輸出：
req1MD5 = 9E054D36439EBDD0604C5E65EB5C8267 , req2MD5=A2D20BAC78551C4CA09BEF97FE468A3F req1MD5 = C2A36FED15128E9E878583CAAAFEFDE9 , req2MD5=C2A36FED15128E9E878583CAAAFEFDE9
日志說明：
- 一開始兩個引數由于requestTime是不同的，所以求去重引數摘要的時候可以發現兩個值是不一樣的
- 第二次呼叫的時候，去除了requestTime再求摘要（第二個引數中傳入了”requestTime”），則發現兩個摘要是一樣的，符合預期，
總結
至此，我們可以得到完整的去重解決方案，如下：
String userId= "12345678";//用戶
String method = "pay";//介面名
String dedupMD5 = new ReqDedupHelper().dedupParamMD5(req,"requestTime");//計算請求引數摘要，其中剔除里面請求時間的干擾
String KEY = "dedup:U=" + userId + "M=" + method + "P=" + dedupMD5;
long expireTime = 1000;// 1000毫秒過期，1000ms內的重復請求會認為重復
long expireAt = System.currentTimeMillis() + expireTime;
String val = "expireAt@" + expireAt;
// NOTE:直接SETNX不支持帶過期時間，所以設定+過期不是原子操作，極端情況下可能設定了就不過期了，后面相同請求可能會誤以為需要去重，所以這里使用底層API，保證SETNX+過期時間是原子操作
Boolean firstSet = stringRedisTemplate.execute((RedisCallback<Boolean>) connection -> connection.set(KEY.getBytes(), val.getBytes(), Expiration.milliseconds(expireTime),
RedisStringCommands.SetOption.SET_IF_ABSENT));
final boolean isConsiderDup;
if (firstSet != null && firstSet) {
isConsiderDup = false;
} else {
isConsiderDup = true;
}
最后，大家可以關注下公眾號Java技術堆疊，在后臺回復：面試，可以獲取我整理的 Java 系列面試題和答案，非常齊全，
作者：Jaskey Lam，軟體工程師
出處：https://jaskey.github.io/blog/2020/05/19/handle-duplicate-request/
近期熱文推薦：
1.600+ 道 Java面試題及答案整理(2021最新版)
2.終于靠開源專案弄到 IntelliJ IDEA 激活碼了，真香！
3.阿里 Mock 工具正式開源，干掉市面上所有 Mock 工具！
4.Spring Cloud 2020.0.0 正式發布，全新顛覆性版本！
5.《Java開發手冊（嵩山版）》最新發布，速速下載！
覺得不錯，別忘了隨手點贊+轉發哦！
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/262349.html
標籤：Java