更新

pkg/coap/manager.go

@@ -110,7 +110,7 @@ func (m *Manager) serve(w *Request) {
 		token := msg.GetToken()
 		// TODO:想别的deviceid的
 		var err error
-		deviceid :=""
+		deviceid := ""
 		if err != nil {
 			server.Log.Errorf("device id error:%s", msg.Path()[0])
 			return
@@ -145,7 +145,7 @@ func (m *Manager) serve(w *Request) {
 			Id:                deviceid,
 			ClientIP:          w.Addr.String(),
 			AccessRPCHost:     server.GetRPCHost(),
-			HeartbeatInterval: 30,
+			HeartbeatInterval: 300,
 		}
 
 		ack := &BaseMessage{

pkg/mqtt/connection.go

@@ -209,7 +209,7 @@ func (c *Connection) RcvMsgFromClient() {
 				ClientIP:      host,
 				AccessRPCHost: server.GetRPCHost(),
 				//HeartbeatInterval: uint32(c.KeepAlive),
-				HeartbeatInterval: 60000,
+				HeartbeatInterval: 300,
 			}
 
 			c.Mgr.AddConn(c.DeviceCode, c)