1 import selectors # 常用于非阻塞的socket的编程中
2 import threading
3 import socket
4 import logging
5
6 FORMAT = '%(asctime)s %(threadName)s %(thread)d %(message)s' # 日志格式
7 logging.basicConfig(format=FORMAT,level=logging.INFO)
8
9 def accept(sock:socket.socket,mask): # 接受
10 conn,raddr = sock.accept()
11 conn.setblocking(False)
12 key = selector.register(conn,selectors.EVENT_READ,read)
13 logging.info(key)
14
15 def read(conn:socket.socket,mask): # 读数据
16 data = conn.recv(1024)
17 msg = 'msg is {}'.format(data.decode())
18 conn.send(msg.encode())
19
20 selector = selectors.DefaultSelector() # 选择器 选择最佳实现，是当前平台上可用的最高效实现的别名
21 sock = socket.socket()
22 sock.bind(('127.0.0.1',8080))
23 sock.listen()
24 logging.info(sock)
25 sock.setblocking(False) # 设置非阻塞
26 key = selector.register(sock,selectors.EVENT_READ,accept) # 注册到选择器
27 logging.info(key)
28
29 e = threading.Event() # 类实现事件对象。
30
31 def select(e):
32 while not e.is_set():
33
34 events = selector.select()
35
36 print('========')
37
38 for key,mask in events:
39
40 logging.info(key)
41
42 logging.info(mask)
43
44 callback = key.data
45
46 callback(key.fileobj,mask)
47 threading.Thread(target=select,args=(e,),name='select').start()
48
49 def main():
50 while not e.is_set():
51 cmd = input('>>>')
52 print("1111111")
53 if cmd.strip() == 'quit':
54 e.set()
55 fobjs = []
56
57 logging.info('{}'.format(list(selector.get_map().items())))
58 for fd ,key in selector.get_map().items():
59 print(fd)
60 print(key)
61 fobjs.append(key.fileobj)
62 for fobj in fobjs:
63
64 selector.unregister(fobj)
65
66 fobj.close()
67 selector.close()
68 else:
69 print("22")
70
71 logging.info('{}'.format(list(selector.get_map().items())))
72
73 if __name__ == '__main__':
74 main()
import selectors # 常用于非阻塞的socket的编程中
import threading
import socket
import logging
FORMAT = '%(asctime)s %(threadName)s %(thread)d %(message)s' # 日志格式
logging.basicConfig(format=FORMAT,level=logging.INFO)
def accept(sock:socket.socket,mask): # 接受
conn,raddr = sock.accept()
conn.setblocking(False)
key = selector.register(conn,selectors.EVENT_READ,read)
logging.info(key)
def read(conn:socket.socket,mask): # 读数据
data = conn.recv(1024)
msg = 'msg is {}'.format(data.decode())
conn.send(msg.encode())
selector = selectors.DefaultSelector() # 选择器 选择最佳实现，是当前平台上可用的最高效实现的别名
sock = socket.socket()
sock.bind(('127.0.0.1',8080))
sock.listen()
logging.info(sock)
sock.setblocking(False) # 设置非阻塞
key = selector.register(sock,selectors.EVENT_READ,accept) # 注册到选择器
logging.info(key)
e = threading.Event() # 类实现事件对象。
def select(e):
while not e.is_set():
events = selector.select()
print('========')
for key,mask in events:
logging.info(key)
logging.info(mask)
callback = key.data
callback(key.fileobj,mask)
threading.Thread(target=select,args=(e,),name='select').start()
def main():
while not e.is_set():
cmd = input('>>>')
print("1111111")
if cmd.strip() == 'quit':
e.set()
fobjs = []
logging.info('{}'.format(list(selector.get_map().items())))
for fd ,key in selector.get_map().items():
print(fd)
print(key)
fobjs.append(key.fileobj)
for fobj in fobjs:
selector.unregister(fobj)
fobj.close()
selector.close()
else:
print("22")
logging.info('{}'.format(list(selector.get_map().items())))
if __name__ == '__main__':
main()