网络框架netpoll～Listener的fd支持poll

本文主要是介绍网络框架netpoll～Listener的fd支持poll，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

网络框架的Listener接口

扩展原生的net.listener

// Listener extends net.Listener, but supports getting the listener's fd.
type Listener interface {net.Listener// Fd return listener's fd, used by poll.Fd() (fd int)
}

原生的net.Listener

可以从表象知道，一个Listener要有什么能力

// A Listener is a generic network listener for stream-oriented protocols.
//
// Multiple goroutines may invoke methods on a Listener simultaneously.
type Listener interface {// Accept waits for and returns the next connection to the listener.Accept() (Conn, error)// Close closes the listener.// Any blocked Accept operations will be unblocked and return errors.Close() error// Addr returns the listener's network address.Addr() Addr
}

实现了框架中的Listener接口的listener

// 空赋值声明，用于检查类型实现。
// 这是对类型断言和接口实现的一种验证方式，但并不关注具体变量的值
// var _ net.Listener = ...：这里声明了一个未使用的匿名变量（下划线_），并尝试将其赋值为右侧的表达式结果
// 这行代码的目的不是为了创建或使用这个变量，而是利用Go编译器的类型检查特性，确保&listener{}类型的实例能够被赋值给net.Listener接口
// 如果listener类型没有实现net.Listener接口所需的所有方法，编译器会报错。
// 
// 静态检查listener类型是否实现了net.Listener接口的所有要求，而不实际创建或使用这个接口实例
// 这是一种常用的技巧，用于确保类型满足特定接口规范，有助于编写更健壮和明确的代码。
var _ net.Listener = &listener{}type listener struct {fd    intaddr  net.Addr       // listener's local addrln    net.Listener   // tcp|unix listenerpconn net.PacketConn // udp listenerfile  *os.File
}// 实现框架Listenr的Fd方法
func (ln *listener) Fd() (fd int) {return ln.fd
}

具体转换

func ConvertListener(l net.Listener) (nl Listener, err error) {// 接口之间也能断言？if tmp, ok := l.(Listener); ok {return tmp, nil}ln := &listener{}ln.ln = lln.addr = l.Addr()// 填充 ln.fd、ln.fileerr = ln.parseFD()if err != nil {return nil, err}return ln, syscall.SetNonblock(ln.fd, true)
}func (ln *listener) parseFD() (err error) {// interface.(type)语法允许检查接口变量的实际类型，并赋值给netln// type switch是Go语言中检查接口类型的一种更简洁、更高效的方法，而不是使用reflect包。这使得代码更易于阅读和维护。//// File returns a copy of the underlying os.File.// File：返回底层 os.File 的拷贝// It is the caller's responsibility to close f when finished.// Closing l does not affect f, and closing f does not affect l.// 关闭 ln 不会影响到 ln.file// 关闭 ln.file 不会影响到 ln//// The returned os.File's file descriptor is different from the// connection's. Attempting to change properties of the original// using this duplicate may or may not have the desired effect.// 返回的os.File的文件描述副不同于connection的// 利用该拷贝改变文件描述符的原始属性，可能会/可能不会有作用switch netln := ln.ln.(type) {case *net.TCPListener:ln.file, err = netln.File()case *net.UnixListener:ln.file, err = netln.File()default:return errors.New("listener type can't support")}if err != nil {return err}ln.fd = int(ln.file.Fd())return nil
}