Python SocketServer threading

Python SocketServer, threading

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 = {“er

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        2040  2010-04-19 23:05  080-jsongateway.py