From 6c882edb09dcd3d7979da42d951eddb63bc6f240 Mon Sep 17 00:00:00 2001
From: kercylan98 <kercylan@gmail.com>
Date: Fri, 8 Sep 2023 16:47:23 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20server=20=E4=BF=AE=E5=A4=8D=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E8=AE=A1=E6=95=B0=E5=A7=8B=E7=BB=88=E4=B8=BA1?=
 =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 server/server.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/server.go b/server/server.go
index f6fb3ac..d1b9f66 100644
--- a/server/server.go
+++ b/server/server.go
@@ -592,12 +592,13 @@ func (slf *Server) pushMessage(message *Message) {
 			defer slf.OnShuntChannelCreatedEvent(channelGuid)
 		}
 		if channel != nil {
+			slf.messageCounter.Add(1)
 			channel <- message
 			return
 		}
 	}
+	slf.messageCounter.Add(1)
 	slf.messageChannel <- message
-
 }
 
 func (slf *Server) low(message *Message, present time.Time, expect time.Duration, messageReplace ...string) {
@@ -616,7 +617,6 @@ func (slf *Server) low(message *Message, present time.Time, expect time.Duration
 
 // dispatchMessage 消息分发
 func (slf *Server) dispatchMessage(msg *Message) {
-	slf.messageCounter.Add(1)
 	var (
 		ctx    context.Context
 		cancel context.CancelFunc