From 2d1f8cd6dbb4ebb78433420970028d867d0e729b Mon Sep 17 00:00:00 2001 From: jackshenonly <253170334@qq.com> Date: Thu, 6 Jun 2024 10:03:43 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E5=88=A0=E9=99=A4Sse=20Redis=20=E5=88=86?= =?UTF-8?q?=E5=8F=91=E5=99=A8=E4=B8=AD=E7=9A=84=E5=86=97=E4=BD=99=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pigx/common/sse/distribute/RedisMessageDistributor.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java index 4e23f3743..8fd05e312 100644 --- a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java +++ b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java @@ -24,10 +24,7 @@ public class RedisMessageDistributor implements MessageDistributor { */ @Override public void distribute(MessageDO messageDO) { - // 包装 sessionKey 适配分布式多环境 - List sessionKeyList = new ArrayList<>(messageDO.getSessionKeys()); - messageDO.setSessionKeys(sessionKeyList); - + String str = JSONUtil.toJsonStr(messageDO); stringRedisTemplate.convertAndSend(RedisSseEmitterMessageListener.CHANNEL, str); } From 22666e1ffa12774ebf9038fcd98b9c008129e953 Mon Sep 17 00:00:00 2001 From: jackshenonly <253170334@qq.com> Date: Fri, 7 Jun 2024 14:51:02 +0800 Subject: [PATCH 2/2] =?UTF-8?q?[fix]=EF=BC=9A=E5=8E=BB=E6=8E=89SSE?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=99=A8=E4=B8=AD=E8=BF=87=E6=97=B6=E7=9A=84?= =?UTF-8?q?=E4=BB=A3=E7=A0=81=EF=BC=8C=E4=BB=A5=E5=85=8D=E5=AF=BC=E8=87=B4?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=20=20=E3=80=90because=20"sendFailed"=20is=20?= =?UTF-8?q?null=E3=80=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pigx/common/sse/config/SseEmitterMessageSender.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java index c3a4b5922..cee119b5d 100644 --- a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java +++ b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java @@ -39,12 +39,7 @@ public class SseEmitterMessageSender { return false; } - Object sendFailed = ReflectUtil.getFieldValue(sseEmitter, "sendFailed"); - if ((boolean) sendFailed) { - log.error("[send] sseEmitter 已经关闭"); - SseEmitterHolder.removeSseEmitter(sseEmitter); - return false; - } + try { sseEmitter.send(message); }