高速公路，离开 onMessage 块

Posted 2023-04-18

【中文标题】高速公路，离开 onMessage 块

【英文标题】：Autobahn, leave onMessage block

【发布时间】：2018-02-17 07:51:36

【问题描述】：

我有一个高速公路 Websocket 服务器，其协议中有典型的onX 功能。我的问题是我找不到退出onX 的方法，同时继续做我想要在特定消息到达时做的各种事情。更具体地说，在我的 onMessage 函数中，我有时会对非常慢的 API 执行 HTTP 请求。结果，发送 websocket 消息的客户端被服务器的onMessage 终结阻止。即使我从服务器端执行self.sendMessage 或reactor.callFromThread(<http request here>) 或self.transport.loseConnection()，在onMessage 块中，onMessage 仍在执行 HTTP 请求，而我的客户端正在等待。

这是我客户的代码：

@asyncio.coroutine
def send(command,userPath,token):
    websocket = yield from websockets.connect('wss://127.0.0.1:7000',ssl=ssl.SSLContext(protocol=ssl.PROTOCOL_TLSv1_2))
    data = json.dumps("api_command":"session","body":command,"headers": 'X-User-Path': userPath, 'X-User-Token': token)
    response = 
    try:
        yield from websocket.send(data)
    finally:
        yield from websocket.close()
    if 'command' in response:
        if response['command'] == 'ACK_SESSION_COMMAND' or response['command'] == 'ACK_INITIALIZATION':
            return ('OK',200)
        else:
            return('',400)

我什至尝试从客户端发送websocket.send(data)，但由于某种原因它没有发送数据（我没有看到它们到达服务器）。我不明白如何从 onMessage 块返回并继续执行我的 HTTP 请求。

为了解释我的情况，我只想向我的服务器发送 1 条 ssl websocket 消息并立即关闭连接。任何能做到这一点的东西都适合我。

【参考方案1】：

使用reactor.callInThread 代替reactor.callFromThread 会导致应用程序流释放，并且HTTP 请求在线程中独立执行。如扭曲文档中所述：http://twistedmatrix.com/documents/13.2.0/core/howto/threading.html