fix data获取

tcpserver.go

@@ -130,6 +130,7 @@ func readConn(conn net.Conn, readChan chan<- []byte, stopChan chan<- bool) {
 		buffer := new(bytes.Buffer)
 		continueCount := 0
 		// log.Println("yunhorndeug.push.data.tcp.reqLen",reqLen)
+		// log.Println("$$$$$$$$$$$$$$$$$$$$$$$$$",data[:reqLen])
     for i, b := range data[:reqLen] {
 
 				if reqLen<7{
@@ -149,6 +150,8 @@ func readConn(conn net.Conn, readChan chan<- []byte, stopChan chan<- bool) {
 
 				// log.Println(b)
 				//分隔符
+				// log.Println("$$$$$$$$$$$$$$$$$$$$$$$$$",i,reqLen)
+				// log.Println("$$$$$$$$$$$$$$$$$$$$$$$$$",data[reqLen])
 				end :=0
 				if b==254 && i>3{
 					addrs := data[i-4:i]
@@ -156,15 +159,29 @@ func readConn(conn net.Conn, readChan chan<- []byte, stopChan chan<- bool) {
 					dataType := data[i+1]
 					values := make([]byte,0)
 					if data[i+1] == 1 {
+
 						continueCount = 3
 						end = 4
+
+						if i+4>=reqLen{
+							continue
+						}
+
 						//类型为1 数据量为2
 						values = data[i+2:i+4]
+
+
+
 					}else if dataType == 2{
 						//类型为2 数据量位1
-						values = data[i+2:i+3]
+
 						continueCount = 2
 						end = 3
+
+						if i+3 >=reqLen{
+							continue
+						}
+						values = data[i+2:i+3]
 					}
 
 					log.Println("yunhorndeug.push.data.tcp:",buffer.String(),addrs,dataType,values)