高速公路，离开 onMessage 块

Question

我有一个高速公路 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 块中 return 并继续执行我的 HTTP 请求。

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

Answer 1

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

高速公路，离开 onMessage 块

Autobahn, leave onMessage block

python

websocket

autobahn