web前端三大主流框架之Python异步框架如何工作？

import socketHOST = 'localhost'    # The remote hostPORT = 8888 # Arbitrary non-privileged portwith socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)    s.bind((HOST, PORT))    s.listen(50)    while True:        conn, addr = s.accept()        print('Connected by', addr)        with conn:            while 1:                data = conn.recv(1024)                if not data:                    break                conn.sendall(data)

package mainimport (    "fmt"    "net"    "os"    "sync")func sendMessage(msg string) error {    conn, err := net.Dial("tcp", "localhost:8888")    if err != nil {        return fmt.Errorf("error: %v", err)    }    defer conn.Close()    _, err = conn.Write([]byte("hello"))    if err != nil {        return fmt.Errorf("error: %v", err)    }    reply := make([]byte, 1024)    _, err = conn.Read(reply)    if err != nil {        println("Write to server failed:", err.Error())        os.Exit(1)    }    println("reply from server=", string(reply))    return nil}func main() {    var wg sync.WaitGroup    nbGoroutines := 20    wg.Add(nbGoroutines)    for k := 0; k <p>使用 go 运行它可以看到输出。</p><p>接下来我们使用 python3 提供的 selectros 来改造它，这个模块封装了操作系统底层提供的 I/O 复用机制，比如 linux 上使用了 epoll。通过 I/O 复用机制我们可以监听多个文件描述符的可读写事件并且注册回调函数，拥有更好的并发性能。 先看 python3 的 selectors 文档给的例子</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">Python免费学习笔记（深入）</a>”；</p><pre class="brush:js;toolbar:false">import selectorsimport socketsel = selectors.DefaultSelector()def accept(sock, mask):    conn, addr = sock.accept()  # Should be ready    print('accepted', conn, 'from', addr)    conn.setblocking(False)    sel.register(conn, selectors.EVENT_READ, read)def read(conn, mask):    data = conn.recv(1000)  # Should be ready    if data:        print('echoing', repr(data), 'to', conn)        conn.send(data)  # Hope it won't block    else:        print('closing', conn)        sel.unregister(conn)        conn.close()sock = socket.socket()sock.bind(('localhost', 1234))sock.listen(100)sock.setblocking(False)sel.register(sock, selectors.EVENT_READ, accept)while True:  # 这其实就是通常在异步框架中所说的 event loop 啦    events = sel.select()    for key, mask in events:        callback = key.data        callback(key.fileobj, mask)