wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3578: 处理重复请求

Browse Source
This commit is contained in:
yanglin 2025-01-10 23:17:05 +08:00
parent b245ea6e05
commit ffe0e88f52
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/replay/RequestReplayService.java
View File

@ -1,5 +1,6 @@
package cn.axzo.msg.center.message.service.replay; package cn.axzo.msg.center.message.service.replay;
import cn.axzo.basics.common.exception.ServiceException;
import cn.axzo.msg.center.common.utils.BizAssertions; import cn.axzo.msg.center.common.utils.BizAssertions;
import cn.axzo.msg.center.common.utils.MD5; import cn.axzo.msg.center.common.utils.MD5;
import cn.axzo.msg.center.dal.RequestReplayDao; import cn.axzo.msg.center.dal.RequestReplayDao;
@ -30,7 +31,7 @@ public class RequestReplayService {
if (!isWindowEnabled(requestInfo)) if (!isWindowEnabled(requestInfo))
return supplier.get(); return supplier.get();
if (acquire(requestInfo) == RequestAcquireResult.DUPLICATE_REQUEST) if (acquire(requestInfo) == RequestAcquireResult.DUPLICATE_REQUEST)
return fallbackValue; throw new ServiceException("重复请求!");
try { try {
return supplier.get(); return supplier.get();
} catch (Exception e) { } catch (Exception e) {