1

我在 tornado 中编写了一个代码，该代码连接到正在推送无限数据流的服务器，处理数据流并将其发送到 websocket 服务器上。问题是我实现它的方式服务器在特定功能上被阻塞并且不再接受任何客户端，因为它永远不会退出向websocket提供数据的功能。我希望与服务器的连接和从中检索的数据只处理一次，但将处理后的数据发送到连接到我的龙卷风服务器的所有客户端。有人可以帮我吗，我想不出办法。这是我删除数据处理的代码：

import socket
import ssl
import tornado.httpserver
import tornado.websocket
import tornado.ioloop
import tornado.web

websockets = []

class WSHandler(tornado.websocket.WebSocketHandler):


  def readData(self):
    while True:
        line = self.ssl_sock.read()

        #PROCESS THE READ LINE AND CONVERT INTO RESULTING DATA


        if(toSend):
                self.write_message(result)

  def makeConnection(self):
      self.ssl_sock.connect(self.address)
      self.readData()



  def open(self):
    print 'New connection was opened'
    self.s=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    self.ssl_sock=ssl.wrap_socket(self.s, cert_reqs=ssl.CERT_NONE)
    self.address=('SERVER_ADDRESS',5000)
    self.nodes=[]
    self.edges=[]
    if self not in websockets:
        print ('added')
        websockets.append(self)

    if(len(websockets)==1):
        print('executing make conn')
        self.makeConnection()
    else:
        self.readData()
        print('executing read data')


  def on_message(self, message):
    print 'Incoming message:', message
    self.write_message("You said: " + message)

  def on_close(self):
    print 'Connection was 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()
4

1 回答 1

0

Tornado 是一个异步框架，也就是说，你所有的 IO 都必须在它的事件循环内运行，否则整个服务器就会卡住。

试试看Tornado Async Client。

于 2016-03-21T13:08:49.413 回答