★net | net包提供了可移植的网络I/O接口,包括TCP/IP、UDP、域名解析和Unix域socket.

net

net包有如下接口:

  1. net.Addr:

    • Network() string: 连接类型,比如”tcp”, “udp”
    • String() string:地址,比如”192.0.2.1:25″, “[2001:db8::1]:80”
  2. net.Error():前俩函数用来判别错误类型。net.OpError结构体实现了这个接口。

    • Timeout() bool
    • Temporary() bool
    • error
  3. net.Listener():通用的面向流协议(TCP与其上层协议)网络侦听器,并发安全

    • Accept() (Conn, error)
    • Close() error
    • Addr() Addr
  4. net.Conn:通用的面向流协议(TCP与其上层协议)网络连接,并发安全。实现了io.ReadWriterCloser

    • Read(b []byte) (n int, err error)
    • Write(b []byte) (n int, err error)
    • Close() error
    • LocalAddr() Addr
    • SetDeadline(t time.Time) error
    • SetReadDeadline(t time.Time) error
    • SetWriteDeadline(t time.Time) error
  5. net.PacketConn():通用的面向数据包(报 Datagram)协议(UDP与其上层协议)网络连接,并发安全

    • ReadFrom(p []byte) (n int, addr Addr, err error):并未实现 io.ReaderFrom.ReadFrom(r Reader) (n int64, err error)
    • WriteTo(p []byte, addr Addr) (n int, err error):并未实现 io.WriterTo.WriteTo(w Writer) (n int64, err error)
    • Close() error
    • LocalAddr() Addr
    • SetDeadline(t time.Time) error
    • SetReadDeadline(t time.Time) error
    • SetWriteDeadline(t time.Time) error

PS: 为啥没写UDP的网络侦听器呢? 因为UDP协议是无连接的传输协议,性质决定了它不需要等待建立一条连接链路

核心函数如下:

  1. 服务端 Listen(network, address string) (Listener, error),支持的协议有:IP,TCP,UDP,MulticastUDP以及Unix,Unixgram。
  2. 客户端 Dial(network, address string) (Conn, error),也支持IP,TCP,UDP和Unix域。客户端还支持带自定义超时的拨号函数DialTimeout(network, address string, timeout time.Duration) (Conn, error)
  3. 直接操作socket文件(unix系):
    • FileListener(f *os.File) (ln Listener, err error):gin中用到[1]
  4. 功能函数
    • string型地址转为对应Addr结构(IP,CIDR,MAC),以Parse开头的一系列函数
    • string型地址进行dns解析并转为对应Addr结构,相当于ParseXXX的增强版,以Resolve开头的一系列函数
    • 以Lookup开头的查询函数(by resolver),可以查NS,MX,SRV,TXT也可以通过ip反查,用到再看
    • 生成v4,v6的CIDR掩码的小工具CIDRMask(ones, bits int) IPMask
    • 分割ip,port字符串的工具SplitHostPort(hostport string) (host, port string, err error)(真的有必要吗
    • func Pipe() (Conn, Conn):Pipe创建一个同步的内存中全双工网络连接;两端实现Conn接口。一端的读取与另一端的写入匹配,直接在两者之间复制数据;不存在内部缓冲。相当于双向的io.pipe
    • 查看网卡状态的函数,以Interface开头比如:Interfaces() ([]Interface, error)

[1]gin中部分源码如下:

// fd是通过系统调用获得的描述符
f := os.NewFile(uintptr(fd), fmt.Sprintf("fd@%d", fd))
listener, err := net.FileListener(f)

文章来源于互联网:第七天:golang学习笔记之net

发表评论