Function connServer

cli/pkg/common/websocket.go:200–239

(key, Addr string)

}

func connServer(key, Addr string) {
	var err error
	defer func() {
		wsclient.mtx.Lock()
		if clientArr[key] != nil {
			_ = clientArr[key].Close()
		}

		clientArr[key] = nil
		defer wsclient.mtx.Unlock()
		WSLog(Addr + " 自动重连")
		//自动重连机制
		time.Sleep(3 * time.Second)
		connServer(key, Addr)
	}()
	wsclient.c, _, err = websocket.DefaultDialer.Dial(Addr, nil)

	if err != nil {
		return
	}
	clientArr[key] = wsclient.c

	for {
		var res []byte
		_, res, err := clientArr[key].ReadMessage()
		if err != nil {
			WSLog("数据读取失败")
			return
		}
		var msg baseMsg
		err = json.Unmarshal(res, &msg)
		if err != nil {
			WSLog("数据解析失败")
			return
		}
		SmartIDELog.ConsoleDebug(fmt.Sprintf("服务器推送数据：%+v\n", msg))
		httpReqMsgReceiver.ClientCodeToFunc(msg)
		// httpReqMsgReceiver.receiveMsg(msg.CmdSequence, res)
	}
}

// 发送给固定客户端
func (w *receiver) receiveMsg(cmd int, msg []byte) {