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