服务端
from SocketServer import TCPServer, StreamRequestHandler class Handler(StreamRequestHandler): def handle(self): addr = self.request.getpeername() print ‘Got connection from‘, addr self.wfile.write(‘Thank you for connecting‘) server = TCPServer((‘‘, 1234), Handler) server.serve_forever()
基于进程的服务端
from SocketServer import TCPServer, ForkingMixIn, StreamRequestHandler class Server(ForkingMixIn, TCPServer): pass class Handler(StreamRequestHandler): def handle(self): addr = self.request.getpeername() print ‘Got connection from‘, addr self.wfile.write(‘Thank you for connecting‘) server = Server((‘‘, 1234), Handler) server.serve_forever()
线程服务端
from SocketServer import TCPServer, ThreadingMixIn, StreamRequestHandler class Server(ThreadingMixIn, TCPServer): pass class Handler(StreamRequestHandler): def handle(self): addr = self.request.getpeername() print ‘Got connection from‘, addr self.wfile.write(‘Thank you for connecting‘) server = Server((‘‘, 1234), Handler) server.serve_forever()
客户端
from SocketServer import TCPServer, ForkingMixIn, StreamRequestHandler class Server(ForkingMixIn, TCPServer): pass class Handler(StreamRequestHandler): def handle(self): addr = self.request.getpeername() print ‘Got connection from‘, addr self.wfile.write(‘Thank you for connecting‘) server = Server((‘‘, 1234), Handler) server.serve_forever()
官方文档3.5
import socketserver class MyTCPHandler(socketserver.BaseRequestHandler): """ The RequestHandler class for our server. It is instantiated once per connection to the server, and must override the handle() method to implement communication to the client. """ def handle(self): # self.request is the TCP socket connected to the client self.data = self.request.recv(1024).strip() print("{} wrote:".format(self.client_address[0])) print(self.data) # just send back the same data, but upper-cased self.request.sendall(self.data.upper()) if __name__ == "__main__": HOST, PORT = "localhost", 9999 # Create the server, binding to localhost on port 9999 server = socketserver.TCPServer((HOST, PORT), MyTCPHandler) # Activate the server; this will keep running until you # interrupt the program with Ctrl-C server.serve_forever()
原文:http://www.cnblogs.com/zhuweiblog/p/5186597.html