import SocketServer
import netstring
import sys
import string

class MyRequestHandler(SocketServer.BaseRequestHandler):
    def handle(self):
        print "Connected:", self.client_address
        while 1:
            rq = netstring.readns(self.request)
            print "From:", self.client_address, rq
            sys.stdout.flush()
            if rq == "":
                break
            netstring.writens(self.request, string.upper(rq))

myServer = SocketServer.ThreadingTCPServer(('', 8081),
                MyRequestHandler)
myServer.serve_forever()

#//python/8082