Websocket在收到龙卷风响应后不断收听
问题描述:
我正在处理收听龙卷风服务器的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)
客户端正在运行,直到它收到来自服务器的第一条消息。但我想无限期地运行。
我错过了什么吗?
答
使用一个循环:
@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)