123456789101112131415161718192021222324252627282930313233343536 |
- #! /usr/bin/python
- import threading
- import time
- import SocketServer
- class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
- def handle(self):
- print "Connection from %s" % self.client_address[0]
- # self.data = self.request.recv(1024).strip()
- while(1):
- self.data = self.request.recv(1024)
- print "%s: %s" % (self.client_address[0], self.data)
- self.request.send("OK\n")
- class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
- pass
- if __name__ == "__main__":
- HOST = '0.0.0.0'
- MINPORT = 3002
- MAXPORT = 3004
- MyServers = []
- MyThreads = []
- for port in range(MINPORT, MAXPORT+1):
- print "Listening on port %i" % port
- MyServers.append(ThreadedTCPServer((HOST, port), ThreadedTCPRequestHandler))
- MyThreads.append(threading.Thread(target=MyServers[-1].serve_forever))
- MyThreads[-1].setDaemon(True)
- MyThreads[-1].start()
- while 1:
- time.sleep(1)
|