2017-10-22 16 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) 
関連する問題