From 7cd7b6da8f36f9c3b0145d775c39bec87cda800f Mon Sep 17 00:00:00 2001 From: zuojunlin Date: Mon, 6 Nov 2023 21:10:49 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E4=B8=80=E6=89=B9=E6=AC=A1=E5=AE=A2?= =?UTF-8?q?=E6=88=B7=E7=AB=AF=E9=87=8D=E8=AF=95=E4=BB=BB=E5=8A=A1=E4=B8=8A?= =?UTF-8?q?=E6=8A=A5=E6=A0=B9=E6=8D=AE=E5=B9=82=E7=AD=89id=E5=8E=BB?= =?UTF-8?q?=E9=87=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../retry/server/support/generator/task/AbstractGenerator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java index a1731b8aa..b4f023616 100644 --- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java +++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java @@ -57,7 +57,8 @@ public abstract class AbstractGenerator implements TaskGenerator { checkAndInitScene(taskContext); - List taskInfos = taskContext.getTaskInfos(); + //客户端上报任务根据幂等id去重 + List taskInfos= taskContext.getTaskInfos().stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(TaskContext.TaskInfo::getIdempotentId))), ArrayList::new)); Set idempotentIdSet = taskInfos.stream().map(TaskContext.TaskInfo::getIdempotentId).collect(Collectors.toSet());