Comment fonctionne le framework asynchrone Python des trois principaux frameworks web front-end ?

Dans cet article, nous examinerons l'exemple de programmation de socket pour voir comment fonctionne le framework asynchrone Python Nous devons comprendre la programmation simple des sockets et le mécanisme de réutilisation des E/S fourni par Linux. Le framework asynchrone Python est également implémenté sur la base du mécanisme de multiplexage d'E/S fourni par le système d'exploitation sous-jacent. Par exemple, select/poll/epoll peut être utilisé sous Linux. Examinons d'abord un exemple simple de serveur de socket Python. Le code Python utilise Python3 et garantit que le module sélecteurs peut être utilisé.

Un exemple

import socket
HOST = 'localhost'    # The remote host
PORT = 8888 # Arbitrary non-privileged port
with 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)

Testons-le avec un client TCP Golang :

package main
import (
    "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 < nbGoroutines; k++ {
        go func() {
            err := sendMessage("hello")
            if err != nil {
                fmt.Printf("fail: %v\n", err)
            }
            wg.Done()
        }()
    }
    wg.Wait()
}

Utilisez go pour exécuter Il peut voir la sortie.

Ensuite, nous utilisons les sélecteurs fournis par python3 pour le transformer. Ce module encapsule le mécanisme de multiplexage d'E/S fourni par le système d'exploitation sous-jacent, comme epoll sous Linux. Grâce au mécanisme de multiplexage d'E/S, nous pouvons surveiller les événements de lecture et d'écriture de plusieurs descripteurs de fichiers et enregistrer les fonctions de rappel pour obtenir de meilleures performances de concurrence. Regardons d'abord l'exemple donné dans le document des sélecteurs de python3

import selectors
import socket
sel = 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)

Exécutons ce serveur d'écho TCP qui utilise le mécanisme de multiplexage d'E/S seectors et regardons le résultat.

C'est tout. Continuons à exécuter le client TCP écrit en go pour le tester et voir les résultats.

Dans les didacticiels ultérieurs, nous utiliserons la coroutine de Python au lieu des fonctions de rappel pour transformer cet exemple, afin que nous puissions utiliser async/await pour l'exécuter

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!