【小白学编程Python方向】项目练习第9期（截止7.27）

Sever： from socket import *from time import ctime host = ''port = 31500bufsize = 1024HandP = (host, port) tcpSeverSocket = socket(AF_INET, SOCK_STREAM)tcpSeverSocket.bind(HandP)tcpSeverSocket.listen(5) while True: print("waiting for connection...") tcpClientSocket, HandP = tcpSeverSocket.accept() print("...connected from", HandP) while True: data = tcpClientSocket.recv(bufsize) if not data: break data = data.decode('utf-8') respMsg = "[%s]:%s" % (ctime(), data) tcpClientSocket.send(bytes(respMsg, 'utf-8')) print(data) tcpClientSocket.close() tcpSeverSocket.close() * '''Client:''''from socket import * host='127.0.0.1'port=31500bufsize=1024HandP=(host,port) tcpClientSocket=socket(AF_INET,SOCK_STREAM)tcpClientSocket.connect(HandP) while True: data = input(">>> ") if not data: break tcpClientSocket.send(bytes(data,'utf-8')) data=tcpClientSocket.recv(bufsize) if not data: break print(data.decode('utf-8')) tcpClientSocket.close()

服务端代码 ''' name: Server End author: xyxc0673 created_at: 2018-7-26 ''' import socket import logging import threading class TcpServer: def __init__(self, host, port): # TCP socket config self.host = host self.port = port self.addr = (self.host, self.port) # logging config logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s') self.logger = logging.getLogger(__name__) def log(self, message): self.logger.info(message) def listen(self, backlog=5): self.log(f'Server is starting to listen on {self.host}:{self.port}.') self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # socket.AF_INET: ipv4, socket.SOCK_STREAM: tcp self.socket.bind(self.addr) self.socket.listen(backlog) self.log(f'Server is listening with the backlog of {backlog}.') def handler(self, socket, addr): ''' handle message from connection ''' host, port = addr self.log(f'Function handler() for {host}:{port} is on.') socket.send(b'Weclome to The WORLD.') while True: data = socket.recv(1024) # bufsize 1024 means to the max recevied data length data_decoded = data.decode('utf-8') # recved data is bytes-like. self.log(f'Received {data_decoded} from {host}:{port}') # connection closes if message is 'exit' if data_decoded == "exit": socket.send(b'exited') break socket.sendall(f'Message receved: {data_decoded}'.encode('utf-8')) socket.close() self.log(f'Connection from {host}:{port} closed.') def run(self): while True: socket, addr = self.socket.accept() self.log(f'Client {addr[0]}:{addr[1]} is accepted.') th = threading.Thread(target=self.handler, args=(socket, addr)) # start a new thread to handle new connection th.start() if __name__ == "__main__": host = '127.0.0.1' port = 31500 server = TcpServer(host, port) server.listen() server.run() 客户端代码 ''' name: Client End author: xyxc0673 created_at: 2018-7-26 ''' import socket import logging import threading class TcpClient: def __init__(self, host, port): # TCP socket config self.host = host self.port = port self.addr = (self.host, self.port) # logging config logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s') self.logger = logging.getLogger(__name__) def log(self, message): self.logger.info(message) def connect(self): self.log(f'Client is starting to connect to {self.host}:{self.port}.') # connect to server self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.socket.connect(self.addr) self.log(f'Client has connected to the server {self.host}:{self.port}.') # Receive message from server message = self.socket.recv(1024).decode('utf-8') self.log(f'Received message {message} from server.') def run(self): while True: user_input = input("Please input: ") self.socket.sendall(user_input.encode('utf-8')) data = self.socket.recv(1024) data_decoded = data.decode('utf-8') self.log(f'Messge from server: {data_decoded}.') if data_decoded == "exited": self.log('Connection has closed.') break if __name__ == "__main__": host = '127.0.0.1' port = 31500 client = TcpClient(host, port) client.connect() client.run()