1

business/jxstore/event/event_tcp.go

@@ -10,7 +10,6 @@ import (
 	"git.rosy.net.cn/jx-callback/business/model/dao"
 	"git.rosy.net.cn/jx-callback/globals"
 	"io"
-	"io/ioutil"
 	"net"
 	"strings"
 	"time"
@@ -59,38 +58,14 @@ func ListenTcp() {
 			}
 		}
 		Poll.AddJob(fn)
-		//go func() {
-		//	defer func() {
-		//		// 捕获异常 防止waitGroup阻塞
-		//		if err := recover(); err != nil {
-		//			fmt.Println("recover err = ", err)
-		//			return
-		//		}
-		//	}()
-		//
-		//	t := NewTcpClient()
-		//	if err := handleConn(c, t); err != nil {
-		//		t = nil
-		//		return
-		//	}
-		//}()
 	}
 }
 
-func ConReadAll(c net.Conn) ([]byte, int, error) {
-	data, err := ioutil.ReadAll(c)
-	return data, len(data), err
-}
 func ConnRead(c net.Conn) ([]byte, int, error) {
 	buffer := make([]byte, 1024*2)
 	n, err := c.Read(buffer)
 	return buffer, n, err
 }
-func ConnReadFull(c net.Conn) ([]byte, int, error) {
-	buffer := make([]byte, 1024)
-	n, err := io.ReadFull(c, buffer)
-	return buffer, n, err
-}
 
 func handleConn(c net.Conn, t *TcpClient) error {
 	if c == nil {