Tornado SockJS连接无法彻底关闭及close与on_close方法疑问

先帮你理清这两个方法的核心差异，再解决你遇到的PING/PONG持续的问题：

一、close()和on_close()的本质区别 #

• on_close()是回调钩子：它是SockJS框架在连接即将关闭或已经关闭时自动触发的方法，属于"通知型"接口。你应该在这里做清理工作——比如把当前连接实例从已连接客户端列表中移除、释放相关资源，而不是用来主动关闭连接。
• close()是主动关闭API：这是你用来主动触发连接关闭的方法，调用它会启动SockJS的连接关闭流程（包括通知客户端、终止底层通信通道）。当close()执行完成后，框架会自动调用on_close()来让你做后续清理。

这也是为什么你在on_close()里调用self.close()会陷入递归：close()触发on_close()，后者又调用close()，形成无限循环。

二、为什么你的连接没真正关闭，PING/PONG还在？ #

你在on_close()里移除了用户，但PING/PONG仍持续，大概率是因为：

1. 你触发on_close()的时机并非连接真正关闭的时刻（比如可能是某个中间状态触发了回调，但底层通道没断开）；
2. 你的removeUserAfterSocketConnectionClose只是移除了列表引用，但服务器端还有其他逻辑（比如定时PING任务）持有该连接实例的引用，导致仍在发送PING；
3. 你混淆了"清理用户列表"和"关闭连接"的顺序：on_close()是清理环节，不是关闭环节，你需要主动调用close()来真正终止连接。

三、有效关闭连接、停止PING/PONG的解决方案 #

1. 正确区分主动关闭和回调清理的场景 #

• 当你需要主动关闭连接（比如客户端发送断开请求、服务器踢人），在外部逻辑中调用self.close()，而不是在on_close()里。比如给你的代码加一个断开任务：

def on_message(self, message):
    message = simplejson.loads(message)
    TASK = message['TASK']
    if TASK == "PING":
        self.send('PONG')
    elif TASK == 'ADD_CLIENT':
        addUserAfterSocketConnection(self, message, "SOCKJS")
    elif TASK == 'DISCONNECT':  # 新增：处理客户端断开请求
        self.close(reason="Client initiated disconnect")  # 主动触发关闭

• on_close()只专注做清理工作：

def on_close(self):
    removeUserAfterSocketConnectionClose(self)
    # 这里绝对不要调用self.close()！

2. 确保彻底释放连接引用 #

检查addUserAfterSocketConnection和removeUserAfterSocketConnectionClose的逻辑：

• 确保removeUserAfterSocketConnectionClose真正把当前实例从所有持有它的集合/全局变量中移除，避免内存泄漏或无效的PING触发；
• 如果服务器端有主动发起PING的定时任务，要在用户移除后停止对该实例的PING操作。

3. 利用close()的参数明确关闭原因 #

调用self.close()时可以传递reason参数，帮助客户端更好地处理关闭事件，同时也能让SockJS框架更规范地终止连接：

self.close(reason="Server timeout")

当你按上述方式调用self.close()后，SockJS会自动终止底层的通信通道，停止PING/PONG交互，然后触发on_close()让你完成用户清理，这样就不会出现递归，也能彻底关闭连接了。

内容的提问来源于stack exchange，提问作者garg10may