简单的小协程

单线程下实现服务器的并发

import socket
import gevent
from gevent import monkey

monkey.patch_all()

def server():
    s = socket.socket()
    s.bind(('0.0.0.0',8080))
    s.listen()
    while True:
        cli, addr = s.accept()
        print('recv from ', addr)
        gevent.spawn(requests, cli)


def requests(conn):
    try:
        while True:
            data = conn.recv(1024)
            print(data.decode())
            conn.send(data.upper())
    except ConnectionResetError as e:
        print(e)

server()

客户端代码

import socket

client = socket.socket()
client.connect(('localhost', 8080))
while True:
    data = input('>>>')
    if not data:continue
    client.send(data.encode())
    print('>>>', client.recv(1024).decode())