“”"
gevent server 基于协程 的 TCP 并发
思路:
1. 将每个客户端的处理 设置为 协程函数
2. 让socket 模块下的 阻塞 可以出发协程跳转
“”"
import gevent
from gevent import monkey
monkey.patch_all() # 在导入需要阻塞 的模块 之前执行, 执行脚本,修改socket 阻塞
from socket import *
创建 TCP 套接字
s = socket()
s.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) # 可重复使用端口号
s.bind((“0.0.0.0”, 8000))
s.listen(5)
循环接受 客户端发送的消息
def handle©:
while True:
data = c.recv(1024).decode()
if not data:
break
else:
print(data)
c.send(“OK”.encode())
循环接收客户端连接, 协程最多可 支持 上万的 同时连接
def receive(s):
while True:
c, addr = s.accept()
print("Connect from ", addr)
# handle© # 处理具体的客户端请求
gevent.spawn(handle,c) # 协程方案
# gevent.joinall()
receive(s)