diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index b6a0b1340..e7a6e52c8 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -85,11 +85,17 @@ func handleConn(c net.Conn, t *TcpClient) error { for { var ( printNo string //打印机编号 - //buffer = make([]byte, 1024) + buffer = make([]byte, 1024) ) - //n, err := c.Read(buffer) - //io.ReadFull(c, buffer) - buffer, err := ioutil.ReadAll(c) + n, err := c.Read(buffer) + globals.SugarLogger.Debugf("长度0:%d,%v", n, err) + + buffer1 := make([]byte, 1024) + n1, err1 := io.ReadFull(c, buffer1) + globals.SugarLogger.Debugf("长度1:%d,%v", n1, err1) + buffer2, err2 := ioutil.ReadAll(c) + globals.SugarLogger.Debugf("长度2:%d,%v", len(buffer2), err2) + if err != nil { if err == io.EOF { fmt.Println("connection close") @@ -101,12 +107,12 @@ func handleConn(c net.Conn, t *TcpClient) error { } //看是心跳还是打印回调 - data := hex.EncodeToString(buffer[:len(buffer)]) - if strings.Contains(string(buffer[0:len(buffer)]), "print_no_clear") { // 清理缓存 + data := hex.EncodeToString(buffer[:n]) + if strings.Contains(string(buffer[0:n]), "print_no_clear") { // 清理缓存 param := struct { PrintNoClear json.Number `json:"print_no_clear"` }{} - if err := json.Unmarshal(buffer[0:len(buffer)], ¶m); err != nil { + if err := json.Unmarshal(buffer[0:n], ¶m); err != nil { c.Write([]byte(err.Error())) return err }