高速公路,留下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块中返回并继续执行我的HTTP请求.

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

Answer 1

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