Golang学习之net包详解

Go 前端之家
前端之家收集整理的这篇文章主要介绍了Golang学习之net包详解，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。
/** * Created by Administrator on 13-12-9. */
package main

import (
    "fmt"
    "os"
    "net"
)

/** * 将string类型的ip地址转换为IP对象 */
func main() {

    name := "192.168.1.97"

    ip := net.ParseIP(name)

    if ip == nil {
        fmt.Fprintf(os.Stderr,"Err:无效的地址")
        return
    }

    fmt.Fprintf(os.Stdout,"IP: %s %s\n",ip,ip.String())
    defaultMask := ip.DefaultMask()
    fmt.Fprintf(os.Stdout,"DefaultMask: %s %s\n",defaultMask,defaultMask.String())

    ones,bits := defaultMask.Size()
    fmt.Fprintf(os.Stdout,"ones: %d bits: %d\n",ones,bits)
}
/** * Created by Administrator on 13-12-9. */
package main

import (
    "net"
    "fmt"
    "os"
)

/** * 根据IP和掩码获得网络 */
func main() {
    name := "192.168.1.97"

    ip := net.ParseIP(name)

    mask := ip.DefaultMask()

    network := ip.Mask(mask)

    fmt.Fprintf(os.Stdout,"network: %s",network.String()) // 192.168.1.0

    // ip: 192.168.1.97
    // mask: 255.255.255.0
    // network: 192.168.1.0
}
/** * Created by Administrator on 13-12-9. */
package main

import (
    "net"
    "fmt"
    "os"
)

/** * 将域名解析Ip地址 * 获得域名对应的所有Ip地址 */
func main() {

    domain := "www.baidu.com"
    ipAddr,err := net.ResolveIPAddr("ip",domain)
    if err != nil {
        fmt.Fprintf(os.Stderr,"Err: %s",err.Error())
        return
    }
    fmt.Fprintf(os.Stdout,"%s IP: %s Network: %s Zone: %s\n",ipAddr.String(),ipAddr.IP,ipAddr.Network(),ipAddr.Zone)

    // 百度，虽然只有一个域名，但实际上，他对应电信，网通，联通等又有多个IP地址
    ns,err := net.LookupHost(domain)
    if err != nil {
        fmt.Fprintf(os.Stderr,err.Error())
        return
    }

    for _,n := range ns {
        fmt.Fprintf(os.Stdout,"%s",n) // 115.239.210.26 115.239.210.27 这2个地址打开都是百度
    }
}
/** * Created by Administrator on 13-12-9. */
package main

import (
    "net"
    "fmt"
    "os"
)

/** * 查看主机服务器（service）占用的端口,这些服务，都是tcp或者udp的 */
func main() {

    port,err := net.LookupPort("tcp","telnet") // 查看telnet服务器使用的端口

    if err != nil {
        fmt.Fprintf(os.Stderr,"未找到指定服务")
        return
    }

    fmt.Fprintf(os.Stdout,"telnet port: %d",port)

}
/** * Created by Administrator on 13-12-9. */
package main

import (
    "net"
    "fmt"
    "os"
)

func main() {

    // TCPAddr 包涵IP 和 Port

    // 将一个host地址转换为TCPAddr。host=ip:port
    pTCPAddr,err := net.ResolveTCPAddr("tcp","www.baidu.com:80")
    if err != nil {
        fmt.Fprintf(os.Stderr,err.Error())
        return
    }

    fmt.Fprintf(os.Stdout,"www.baidu.com:80 IP: %s PORT: %d",pTCPAddr.IP.String(),pTCPAddr.Port)
}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
    "io/IoUtil"
)

func main() {

    url := "www.baidu.com:80"

    pRemoteTCPAddr,err := net.ResolveTCPAddr("tcp4",url)

    if err != nil {
        fmt.Fprintf(os.Stderr,"Error: %s",err.Error())
        return
    }

    // pLocalTCPAddr,err := net.ResolveTCPAddr("tcp","127.0.0.1:7070")

    pTCPConn,err := net.DialTCP("tcp",nil/*pLocalTCPAddr*/,pRemoteTCPAddr)

    if err != nil {
        fmt.Fprintf(os.Stderr,err.Error())
        return
    }


    n,err := pTCPConn.Write([]byte("HEAD / HTTP/1.0\r\n\r\n"))
    if err != nil {
        fmt.Fprintf(os.Stderr,err.Error())
        return
    }
    defer pTCPConn.Close()

    fmt.Fprintf(os.Stdout,"writed: %d\n",n)

    buf,err := IoUtil.ReadAll(pTCPConn)
    r := len(buf)
    fmt.Fprintf(os.Stdout,string(buf[:r]))
    fmt.Fprintf(os.Stdout,"readed: %d\n",r)

}
/**
 * Created by Administrator on 13-12-10.
 */
package main

import (
    "net"
    "fmt"
    "os"
    "time"
)

func main() {

    pTCPAddr,error := net.ResolveTCPAddr("tcp4",":7070")
    if error != nil {
        fmt.Fprintf(os.Stdout,error.Error())
        return
    }
    pTCPListener,error := net.ListenTCP("tcp4",pTCPAddr)
    if error != nil {
        fmt.Fprintf(os.Stdout,error.Error())
        return
    }
    defer pTCPListener.Close()

    for {
        pTCPConn,error := pTCPListener.AcceptTCP()
        if error != nil {
            fmt.Fprintf(os.Stdout,error.Error())
            continue
        }
        go connHandler(pTCPConn)
    }
}

func connHandler(conn *net.TCPConn) {
    defer conn.Close()
    now := time.Now()
    conn.Write([]byte(now.String() + "\n"))
}
/**
 * Created by Administrator on 13-12-10.
 */
package main

import (
    "net"
    "fmt"
    "os"
    "time"
)

func main() {

    //url := "baidu.com:80"
    url := "facebook.com:80"
    conn,error := net.DialTimeout("tcp",url,time.Second * 10) // 带有超时限制的conn
    if error != nil {
        fmt.Fprintf(os.Stderr,error.Error())
        return
    }

    n,error := conn.Write([]byte("HEAD / HTTP/1.0\r\n\r\n"))
    if error != nil {
        fmt.Fprintf(os.Stderr,error.Error())
        return
    }

    fmt.Fprintf(os.Stdout,"writed: %d",n)

    buf := make([]byte,2048)
    n,error = conn.Read(buf)
    if error != nil {
        fmt.Fprintf(os.Stderr,string(buf[:n]))
}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
)

/** * UDP 服务器 */
func main() {
    pUDPAddr,err := net.ResolveUDPAddr("udp",":7070")

    if err != nil {
        fmt.Fprintf(os.Stderr,err.Error())
        return
    }

    pUDPConn,err := net.ListenUDP("udp",pUDPAddr)

    if err != nil {
        fmt.Fprintf(os.Stderr,err.Error())
        return
    }

    defer pUDPConn.Close()

    for {

        buf := make([]byte,256)
        n,pUDPAddr,err := pUDPConn.ReadFromUDP(buf)

        if err != nil {
            fmt.Fprintf(os.Stderr,err.Error())
            return
        }
        fmt.Fprintf(os.Stdout,"readed: %d",n)

        n,err = pUDPConn.WriteToUDP(buf,pUDPAddr)
        if err != nil {
            fmt.Fprintf(os.Stderr,n)
    }
}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
)

/** * UDP 客户端 */
func main() {

    pUDPAddr,"127.0.0.1:7070")

    if err != nil {
        fmt.Fprintf(os.Stderr,"Error ResolveUDPAddr: %s",err := net.DialUDP("udp",nil,"Error DialUDP: %s",err.Error())
        return
    }

    n,err := pUDPConn.Write([]byte("你好啊！！！"))

    if err != nil {
        fmt.Fprintf(os.Stderr,"Error WriteToUDP: %s",n)

    buf := make([]byte,1024)
    n,_,err = pUDPConn.ReadFromUDP(buf)

    if err != nil {
        fmt.Fprintf(os.Stderr,"Error ReadFromUDP: %s","readed: %d %s",n,string(buf[:n]))
}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
)

/* 很多时候，服务器会处理多个端口的监听！可以使用select轮询处理这种情况 */
func main() {

    lsr,err := net.Listen("tcp",err.Error())
        return
    }

    for {
        conn,err := lsr.Accept()
        if err != nil {
            fmt.Fprintf(os.Stderr,err.Error())
            continue
        }

        go connHandler(conn)

    }

    fmt.Println("Done !")
}

func connHandler(conn net.Conn) {
    defer conn.Close()

    var buf[512]byte
    for {
        n,err := conn.Read(buf[0:])
        if err != nil {
            fmt.Fprintf(os.Stderr,err.Error())
            return
        }
        _,err = conn.Write(buf[0:n])
        if err != nil {
            fmt.Fprintf(os.Stderr,err.Error())
            return
        }
    }
}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
    "bufio"
)

func main() {

    conn,err := net.Dial("tcp","192.168.1.97:7070")
    if err != nil {
        fmt.Sprint(os.Stderr,err.Error())
        return
    }


    go func() {
        var buf [512]byte
        for {
            n,err := conn.Read(buf[0:])
            if err != nil {
                fmt.Fprintf(os.Stderr,err.Error())
                return
            }
            fmt.Fprintf(os.Stdout,string(buf[0:n]))
        }

    }()

    for {
        fmt.Fprintf(os.Stdout,"\n输入:")
        pReader := bufio.NewReader(os.Stdin)
        line,err := pReader.ReadLine()
        if err != nil {
            fmt.Fprintf(os.Stderr,err.Error())
            return
        }
        conn.Write(line[0:])
    }
}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
)

/** UDP Server */
func main() {

    packetConn,err := net.ListenPacket("udp",":7070")

    if err != nil {
        fmt.Fprintf(os.Stdout,err.Error())
        return
    }
    defer packetConn.Close()

    var buf [512]byte
    for {
        n,addr,err := packetConn.ReadFrom(buf[0:])
        if err != nil {
            fmt.Fprintf(os.Stdout,err.Error())
            return
        }

        fmt.Fprintf(os.Stdout,"recv: %s",string(buf[0:n]))

        _,err = packetConn.WriteTo(buf[0:n],addr)
        if err != nil {
            fmt.Fprintf(os.Stdout,err.Error())
            return
        }
    }


}
/** * Created by Administrator on 13-12-10. */
package main

import (
    "net"
    "fmt"
    "os"
    "time"
)

/** UDP Client */
func main() {
    conn,err := net.Dial("udp","127.0.0.1:7070")

    if err != nil {
        fmt.Fprintf(os.Stdout,err.Error())
        return
    }

    defer conn.Close()


    _,err = conn.Write([]byte("你好啊UDP"))
    if err != nil {
        fmt.Fprintf(os.Stdout,err.Error())
        return
    }

    var buf [512]byte
    conn.SetReadDeadline(time.Now().Add(time.Second * 1))  // 阻塞，直到接收到消息,设置阻塞时间1秒
    n,err := conn.Read(buf[0:])
    if err != nil {
        fmt.Fprintf(os.Stdout,string(buf[0:n]))

}

转自：http://blog.csdn.net/eclipser1987/article/details/17247519?hmsr=studygolang.com&utm_medium=studygolang.com&utm_source=studygolang.com

原文链接：https://www.f2er.com/go/187935.html

猜你在找的Go相关文章

golang简单实现jwt验证(beego、xorm、jwt)
程序目录结构 简单实现，用户登录后返回一个jwt的token，下次请求带上token请求用户信息接...
【工程实践】利用go语言写一个简单的Pow样例
本篇博客的主要内容是用go写一个简单的Proof-of-Work共识机制，不涉及到网络通信环节，只是...
【工程实践】go语言实现MerkleTree
简介 默克尔树（MerkleTree）是一种典型的二叉树结构，其主要特点为： 最下面的叶节点包含...
第九章 goroutine
接下来学习并发编程, 并发编程是go语言最有特色的地方, go对并发编程是原生支持. goroutin...
第十一章 运用广度优先搜索走迷宫
先普及一下, 什么是广度优先搜索 广度优先搜索类似于树的层次遍历。从图中的某一顶点出发，...
第十三章 go实现分布式网络爬虫---单机版爬虫
爬虫的分类 网络爬虫分为两类 1. 通用爬虫: 类似于baidu, google. 他们会把大量的数据挖下...
第十章 channel select 总结
感觉channel在理解起来还有点费劲的, 尤其是select的使用, 既要可以读数据, 又要可以写数据...
第十五章 并发版爬虫第二版 -- 完结
并发版爬虫, 在上一篇单机版爬虫的基础上演变而来 这里只有并发引擎的代码, 基本的解析器代...
第八章--性能优化--pprof详细研究
接着上次的博客: https://www.cnblogs.com/ITPower/articles/12315637.html ppro...
第八章 测试与性能调优--生成文档和测试示例代码
java也可以生成文档, 就像一个手册一样, 可以用来查看方法, 接口, 下面我们给go项目生成文...
PHPJavaJava SEPythonC#C&C++RubyVBasp.NetGoPerlnettyDjangoDelphiJsp.NET CoreSpringFlaskSpringbootSpringMVCLuaLaravelMybatisAspGroovyThinkPHPYiiswoole
文件时间pythonm相等性PHP Warning时间问题问题解决pcntl_signal采样点wav模块动态文本调用频率限制对外暴露多个访问请求更新数据表模型结构type()方法比较速度手写体sobel算子保存模型Image类nn.Conv2dpytorch1.0kaggleDCGAN交并比range()用法打印模型反卷积卷积