fix trans

liuxiaolong

2019-10-11 4712c936939b29a214251578d5a63681413bb8c5

fix trans

 transport.go

@@ -27,14 +27,17 @@
}

func RawReceiveTcpMsg() {
    var tcpAddr *net.TCPAddr
    tcpAddr,_ = net.ResolveTCPAddr("tcp","127.0.0.1:"+strconv.Itoa(TcpTransportPort))

    listener,_ := net.ListenTCP("tcp",tcpAddr)
    tcpAddr := "0.0.0.0:"+strconv.Itoa(TcpTransportPort)
    listener,err := net.Listen("tcp",tcpAddr)
    if err != nil {
        logger.Debug("RawReceive server listen err:",err)
        return
    }
    defer listener.Close()

    for{
        conn,err := listener.AcceptTCP()
        conn,err := listener.Accept()
        if err!=nil {
            logger.Debug("listener.Accept err:", err)
            continue
@@ -44,7 +47,9 @@
    }
}

func readStream(conn *net.TCPConn) {
func readStream(conn net.Conn) {
    defer conn.Close()

    data := make([]byte,0)
    buf := make([]byte, 4096)
    for {