多个客户端连接到 Tornado 服务器答案

【问题标题】：Multiple clients connected to Tornado Server多个客户端连接到 Tornado 服务器
【发布时间】：2015-11-22 01:14:15
【问题描述】：

我正在使用此代码从源获取连续的无限数据流，对其进行处理，然后将处理后的无限流发送到连接到我的服务器的客户端。问题是龙卷风只支持一个 websocket 连接，但我想将数据转发到连接到我的服务器的所有客户端。如何支持多个客户端？

import tornado.httpserver
import tornado.websocket
import tornado.ioloop
import tornado.web

class WSHandler(tornado.websocket.WebSocketHandler):
def open(self):
    print 'new connection'
    self.write_message("Hello World")

def readData(self):
    while True:
       --continue generating data--
       self.write_message(generated data)

def on_message(self, message):
    print 'message received %s' % message

def on_close(self):
  print 'connection closed'


application = tornado.web.Application([
(r'/ws', WSHandler),
])


if __name__ == "__main__":
http_server = tornado.httpserver.HTTPServer(application)
http_server.listen(8888)
tornado.ioloop.IOLoop.instance().start()

【问题讨论】：

您在“生成数据”部分到底在做什么以及如何做？它可能正在那里进行非 asyc 调用。
我正在连接到以 xml 格式输出无限数据流的 TLS 服务器。我正在将我需要的数据处理成 JSON。那是生成数据的部分。我想要做的是将该数据发送到连接到我的 websocket 的所有客户端，但我不想为连接到我的 websocket 的每个客户端单独连接到我的 TLS 服务器。一个到 TLS 服务器的连接和生成的数据被发送到连接到 websocket 的所有客户端。让我知道是否需要任何其他细节。 :)

标签： python websocket tornado

【解决方案1】：

Here 是一个我认为与您正在尝试做的事情相匹配的示例。

【讨论】：

另外，如果上一行包含特定关键字，我想多读一行怎么办？
如果我想忽略不包含特定关键字或一组关键字的行？
就像现在的代码一样，它只是逐行读取和处理。您必须修改 process 方法以跟踪某些事件，以便它们影响后续行的处理。要删除某些输入，您需要修改它调用 write_message 的流读取器基类。
运行代码时出现了一个问题。经过一定时间后，代码继续运行，但不会从源服务器读取任何数据。我使用调试器进行检查，似乎它卡在了 ioloop.py 我该如何克服这个问题？以这种方式陷入困境会破坏我的目的。
现在 Tornado 是 v4 并推荐使用新的 asyncio 模块，我移至 Python 3.4，它破坏了这段优秀的代码。您现在必须对 _random_stuff 例程 \self.stream.write(output.encode("utf-8")) \..... 中来自和去往 "utf-8" 的所有字符串进行编码