测试mqtt ping req

pkg/mqtt/connection.go

@@ -3,6 +3,7 @@ package mqtt
 import (
 	"encoding/hex"
 	"errors"
+	"fmt"
 	"net"
 	"sparrow/pkg/models"
 	"sparrow/pkg/rpcs"
@@ -277,6 +278,7 @@ func (c *Connection) RcvMsgFromClient() {
 			}
 
 		case *PingReq:
+			println(fmt.Sprintf("收到ping req:%s", c.DeviceCode))
 			pingrsp := &PingResp{}
 			err := c.Mgr.Provider.OnDeviceHeartBeat(c.DeviceCode)
 			if err != nil {