message_queues[s]
for s in writable:
try:
next_msg = message_queues[s].get_nowait()
except queue.Empty:
# 没有数据了，该连接对象队列为空，停止检测
print('output queue for [%s] is empty' % s.getpeername()[0])
outputs.remove(s)
else:
print('send %s to %s' % (next_msg, s.getpeername()[0]))
s.send(next_msg)
for s in exceptional:
print('handling exceptional condition for', s.getpeername()[0])
# 从inputs中删除
inputs.remove(s)
if s in outputs:
outputs.remove(s)
s.close()
# 删除队列
del message_queues[s]
client
# -*- coding: UTF-8 -*-
import socket
HOST = 'localhost' # The remote host
PORT = 9999 # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
while True:
msg = bytes(input(">>:"), encoding="utf8")
s.sendall(msg)
data = s.recv(1024)
# print(data)
print('Received', repr(data))