From 0f27517b924c01cab6c6fa5c29b246fd24d62d33 Mon Sep 17 00:00:00 2001 From: Hccake Date: Sat, 23 Apr 2022 16:30:58 +0800 Subject: [PATCH] =?UTF-8?q?:fire:=20=E7=A7=BB=E9=99=A4=20MessageDistributo?= =?UTF-8?q?r=20=E4=B8=AD=E5=AE=9A=E4=B9=89=E7=9A=84=20doSend=20=E6=96=B9?= =?UTF-8?q?=E6=B3=95=EF=BC=8C=E9=98=B2=E6=AD=A2=E7=94=A8=E6=88=B7=E8=AF=AF?= =?UTF-8?q?=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../websocket/distribute/AbstractMessageDistributor.java | 7 +++++-- .../common/websocket/distribute/MessageDistributor.java | 6 ------ .../common/websocket/message/JsonWebSocketMessage.java | 1 - 3 files changed, 5 insertions(+), 9 deletions(-) diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java index 41b5d38d2..04f936cb3 100644 --- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java +++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/AbstractMessageDistributor.java @@ -20,8 +20,11 @@ public abstract class AbstractMessageDistributor implements MessageDistributor { this.webSocketSessionStore = webSocketSessionStore; } - @Override - public void doSend(MessageDO messageDO) { + /** + * 对当前服务中的 websocket 连接做消息推送 + * @param messageDO 消息实体 + */ + protected void doSend(MessageDO messageDO) { // 是否广播发送 Boolean needBroadcast = messageDO.getNeedBroadcast(); diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java index 865986211..0c7ccc693 100644 --- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java +++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/distribute/MessageDistributor.java @@ -14,10 +14,4 @@ public interface MessageDistributor { */ void distribute(MessageDO messageDO); - /** - * 发送消息 - * @param messageDO 发送的消息 - */ - void doSend(MessageDO messageDO); - } diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java index 0a3672478..47fa235ed 100644 --- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java +++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/message/JsonWebSocketMessage.java @@ -20,4 +20,3 @@ public abstract class JsonWebSocketMessage { } } -