2017-10-22 170 views
0

我正在处理收听龙卷风服务器的websocket客户端。 一旦客户端收到来自服务器的消息,客户端就会默默退出。Websocket在收到龙卷风响应后不断收听

以下是我实施的代码。

#!/usr/bin/python 

import tornado.websocket 
from tornado import gen 
import requests 

@gen.coroutine 
def test_ws(): 
    client = yield tornado.websocket.websocket_connect("ws://localhost:8888/subscribe/ports") 

msg = yield client.read_message() 
print(msg) 

if __name__ == "__main__": 
    loop = tornado.ioloop.IOLoop() 
    loop.run_sync(test_ws) 

客户端正在运行,直到它收到来自服务器的第一条消息。但我想无限期地运行。

我错过了什么吗?

回答

1

使用一个循环:

@gen.coroutine 
def test_ws(): 
    client = yield tornado.websocket.websocket_connect("ws://localhost:8888/subscribe/ports") 

    while True: 
     msg = yield client.read_message() 
     print(msg)