server.py 文件源码

def ka(self):
        # print "%d: Keepalive: %s" % (time.time(), str(self))
        try:
            self.write_message(self.KA)
            tornado.ioloop.IOLoop.instance().add_timeout(datetime.timedelta(seconds=2), self.ka)
        except websocket.WebSocketClosedError:
            pass