|
@@ -0,0 +1,36 @@
|
|
|
+#! /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)
|