创建TCP连接

func createTcpServer(host string, port int) (*net.TCPListener, error) {
    logger.Debug("create tcp listener")
    tcpListener, err := net.Listen("tcp", host+":"+strconv.Itoa(port))
    if err != nil {
        logger.Error("listen error: ", err)
        return nil, err
    }
    return tcpListener.(*net.TCPListener), nil
}

创建TCP连接2

func createTcpServer(host string, port int) (*net.TCPListener, error) {
    logger.Debug("create udp listener")
    udpAddr, err := net.ResolveTCPAddr("udp", host+":"+strconv.Itoa(port))
    if err != nil {
        logger.Error("", err)
        return nil, err
    }
    //监听端口
    udpConn, err := net.ListenTCP("tcp", udpAddr)
    if err != nil {
        logger.Error("", err)
        return nil, err
    }
    return udpConn, nil
}

创建UDP连接

func createUdpServer(host string, port int) (*net.UDPConn, error) {
    logger.Debug("create udp listener")
    udpAddr, err := net.ResolveUDPAddr("udp", host+":"+strconv.Itoa(port))
    if err != nil {
        logger.Error("", err)
        return nil, err
    }
    //监听端口
    udpConn, err := net.ListenUDP("udp", udpAddr)
    if err != nil {
        logger.Error("", err)
        return nil, err
    }
    return udpConn, nil
}

发表评论