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 17:26:37 +08:00
parent ea697caf25
commit 933b9ec1da
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -71,7 +71,11 @@ public class RequestReplayService {
replay.setType(requestInfo.getReplayType());
replay.setHash(hash);
replay.setRequest(JSON.parseObject(JSON.toJSONString(requestInfo.getRequest())));
requestReplayDao.save(replay);
try {
requestReplayDao.save(replay);
} catch (Exception e) {
log.warn("save request error, requestInfo={}", requestInfo, e);
}
String key = buildKey(hash);
Duration timeout = Duration.ofSeconds(cfg.getRequestReplayWindowExpireTimeInSeconds());
Boolean success = redisTemplate.opsForValue().setIfAbsent(key, "", timeout);