1

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)], &param); err != nil {
+			if err := json.Unmarshal(buffer[0:n], &param); err != nil {
 				c.Write([]byte(err.Error()))
 				return err
 			}