SEVER:
import socketserver
class MyServer(socketserver.BaseRequestHandler):
def handle(self):
while 1: # self.request相当于一个conn
msg = self.request.recv(1024).decode('utf-8')
if msg == 'q':
self.request.send(b'q')
break
print(msg)
info = input('>>>')
self.request.send(info.encode('utf-8'))
if __name__ == '__main__':
sever = socketserver.ThreadingTCPServer(('127.0.0.1',8090),MyServer)
sever.serve_forever()
CLIENT1:
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',8090))
while 1:
msg = input('>>>')
if msg == 'q':
sk.send(b'q')
break
sk.send(('美团:'+msg).encode('utf-8'))
ret = sk.recv(1024).decode('utf-8')
if ret == 'q':
break
print(ret)
sk.close()
CLIENT2:
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',8090))
while 1:
msg = input('>>>')
if msg == 'q':
sk.send(b'q')
break
sk.send(('饿了么:'+msg).encode('utf-8'))
ret = sk.recv(1024).decode('utf-8')
if ret == 'q':
break
print(ret)
sk.close()