Json gateway.py

import SocketServer,threading,json
conn={}
conn_lock=threading.Lock()

class ThreadingServer(SocketServer.ThreadingMixIn,SocketServer.TCPServer):
    allow_reuse_address=True

class Handler(SocketServer.StreamRequestHandler):
    def handle(self):
        print "A new client connected",self.client_address
        msg=json.read_stream(self.rfile)
        if "!name" in msg:
            name =msg["!name"]
            wlock=threading.Lock()
            conn_lock.acquire()
            conn[name]=(wlock,self.wfile)
            conn_lock.release()
            print "Client registered (%s)"%name
            reply={"ok": u"registered"}
            self.wfile.write(json.write(reply))
            self.wfile.flush()
        else:
            reply={"err" : u"Invalid name"}
            self.wfile.write(json.write(reply))
            return
        handle_connection(self,name)

    def handle_connection(self,name):
        while True:
            try:
                msg=json.read_stream(self.rfile)
            except:
                msg={"!close": True}
            if "!close" in msg:
                print "Client  exits (%s)"%name, self.cient_address
                conn_lock.acquire()
                if name in conn:
                    del conn[name]
                conn_lock.release()
                break
            elif "!dst" in msg:
                wfile=None
                conn_lock.acquire()
                if msg["!dst"] in conn:
                    wlock,wfile=conn[msg["!dst"]]
                conn_lock.acquire()
                if wfile:
                    wlock.acquire()
                    try:
                        wfile.write(json.write(msg))
                    finally:
                        wlock.release()
server=ThreadingServer((" ",8080),Handler)
print "JSON gateway is running!"
print "Waiting for new clients..."
server.serve_forever()