From 554243d5537cb8464bb2766b3db83ad3ff519272 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Thu, 20 Nov 2025 11:41:54 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E7=A7=BB=E5=8A=A8=E5=B9=B3?= =?UTF-8?q?=E5=8F=B0=E5=A4=9A=E7=AB=AF=E6=9C=AA=E6=94=B6=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E8=AE=A1=E6=95=B0=E9=87=8D=E5=A4=8D=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java index d04806cc..dfc3609f 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -230,6 +230,7 @@ public class MessagesPublisher { } } + boolean unreadCountIncreased = false; for (Session targetSession : sessions) { //超过7天不活跃的用户忽略 if(System.currentTimeMillis() - targetSession.getLastActiveTime() > m_messagesStore.getPushExpiredTimes()) { @@ -314,8 +315,9 @@ public class MessagesPublisher { } if (!StringUtil.isNullOrEmpty(pushContent) || messageContentType == 400) { - if (!isConvSilent && (persistFlag & 0x02) > 0) { + if (!isConvSilent && (persistFlag & 0x02) > 0 && !unreadCountIncreased) { m_messagesStore.increaseUnreceivedMsgCount(user); + unreadCountIncreased = true; } } }