socketserver實現並發
阿新 • • 發佈:2018-09-03
elf 服務器 send continue __main__ port conn exce self.
服務器端sockforever版
import socketserver class MyServer(socketserver.BaseRequestHandler):
def handle(self): # print(‘conn is: ‘,self.request) print(‘address is:‘,self.client_address) while True: try: msg = self.request.recv(1024)if not msg:break print(‘收到客戶端的消息: ‘,msg.decode(‘utf-8‘),self.client_address) self.request.send(msg) except Exception as e: print(e) break if __name__ == ‘__main__‘: server = socketserver.ThreadingTCPServer((‘127.0.0.1‘,8080),MyServer) server.serve_forever()
client端
import socket buffer_size=1024 sk = socket.socket() sk.connect((‘127.0.0.1‘,8080)) while True: msg = input(‘>>:‘) if not msg:continue if msg == ‘quit‘:break sk.send(msg.encode(‘utf-8‘)) data =sk.recv(buffer_size) print(‘來自客戶端的消息: ‘,data.decode(‘utf-8‘)) sk.close()
socketserver實現並發