IO多路复用多并发服务器模板

 import socket

 import selectors    # IO多路复用选择器

 epoll_selector = selectors.EpollSelector()  # 实例化选择器

 server = socket.socket()    # 实例化套接字

 server.bind(('', 6666)) # 地址和端口

 server.listen(100)  #侦听数

 def recv(conn): # 数据处理

     recv_data = conn.recv(1024)

     if recv_data:   # 判断是否存在

         res = recv_data.decode()    # 解码接收到的数据

         print(res)

         conn.send(recv_data)    # 发送数据

     else:

         epoll_selector.unregister(conn) # 解除监视，关闭监控

         conn.close()    # 关闭连接

 def accept(server): # 连接处理

     conn, addr = server.accept() # 生成一个对等连接套接字

     epoll_selector.register(conn, selectors.EVENT_READ, recv)   # 注册毁掉函数

 epoll_selector.register(server, selectors.EVENT_READ, accept) # 注册回调函数

 while True:

     events = epoll_selector.select()    # 查询事件

     for key, mask in events:    # 拆包

         callback = key.data

         sock = key.fileobj

         callback(sock)