服务端代码
from gevent import monkey
monkey.patch_all()
from gevent import spawn
import socket
def communicate(conn):
while True:
try:
data = conn.recv(1024)
if len(data) == 0:break
print(data.decode("utf-8"))
conn.send(data.upper())
except ConnectionResetError:
break
conn.close()
def server():
server = socket.socket()
server.bind(("127.0.0.1",8080))
server.listen(5)
while True:
conn,addr = server.accept()
spawn(communicate())
if __name__ == '__main__':
s1 = spawn(server)
s1.join()from gevent import monkey
monkey.patch_