diff --git a/driver/wsclient.go b/driver/wsclient.go index fafa3d1..d4f15d7 100644 --- a/driver/wsclient.go +++ b/driver/wsclient.go @@ -125,10 +125,10 @@ func (ws *WSClient) Listen(handler func([]byte, zero.APICaller)) { } continue } - if rsp.Get("meta_event_type").Str != "heartbeat" { // 忽略心跳事件 - log.Debug("[ws] 接收到事件: ", helper.BytesToString(payload)) + if rsp.Get("meta_event_type").Str == "heartbeat" { // 忽略心跳事件 continue } + log.Debug("[ws] 接收到事件: ", helper.BytesToString(payload)) handler(payload, ws) } } diff --git a/driver/wsserver.go b/driver/wsserver.go index 5a2ad43..9ed46b5 100644 --- a/driver/wsserver.go +++ b/driver/wsserver.go @@ -196,10 +196,10 @@ func (wssc *WSSCaller) listen(handler func([]byte, zero.APICaller)) { } continue } - if rsp.Get("meta_event_type").Str != "heartbeat" { // 忽略心跳事件 - log.Debug("[wss] 接收到事件: ", helper.BytesToString(payload)) + if rsp.Get("meta_event_type").Str == "heartbeat" { // 忽略心跳事件 continue } + log.Debug("[wss] 接收到事件: ", helper.BytesToString(payload)) handler(payload, wssc) } }