GTsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

同一批次客户端重试任务上报根据幂等id去重

Browse Source
This commit is contained in:
zuojunlin 2023-11-06 21:10:49 +08:00 committed by byteblogs168
parent f2b1f01588
commit be51abb079
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/generator/task/AbstractGenerator.java
View File

@ -59,7 +59,8 @@ public abstract class AbstractGenerator implements TaskGenerator {
SceneConfig sceneConfig = checkAndInitScene(taskContext); SceneConfig sceneConfig = checkAndInitScene(taskContext);
List<TaskContext.TaskInfo> taskInfos = taskContext.getTaskInfos(); //客户端上报任务根据幂等id去重
List <TaskContext.TaskInfo> taskInfos= taskContext.getTaskInfos().stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(TaskContext.TaskInfo::getIdempotentId))), ArrayList::new));
Set<String> idempotentIdSet = taskInfos.stream().map(TaskContext.TaskInfo::getIdempotentId).collect(Collectors.toSet()); Set<String> idempotentIdSet = taskInfos.stream().map(TaskContext.TaskInfo::getIdempotentId).collect(Collectors.toSet());