#!/usr/bin/env python
# -*- coding:utf-8 -*-
# author: Changhua Gong
import selectors
import socket
sel = selectors.DefaultSelector()
'''selectors根据系统自动select或epoll'''
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) # 新连接注册read回调函数
def read(conn, mask):
data = conn.recv(1024) # 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', 10000))
sock.listen(100)
sock.setblocking(False)
sel.register(sock, selectors.EVENT_READ, accept) # 注册sock,有连接进来则调用accept
while True:
events = sel.select() # 默认阻塞,有活动连接就返回活动的连接列表
for key, mask in events:
callback = key.data # accept的内存地址或read的内存地址,即等于read或accept函数
callback(key.fileobj, mask) # 调用对应的回调函数,key.fileobj为文件句柄
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341