Tornado nicht blockierende Websocket Server-Implementierung

Question

class Client(tornado.websocket.WebSocketHandler): 
    def open(self): 
     print "Connection is opened" 

    def on_message(self, message): 
     self.Process(message) 

    def on_close(self): 
     print "socket closed" 

Nehmen Sie den obigen Code in Python/Tornado. Eine Instanz von Client wird erstellt, wenn ein neuer Websocket-Client eine Verbindung zum Server herstellt. Das Problem ist, self.process(message) dauert Minuten und der gesamte Handler ist blockiert (keine Verbindung mehr akzeptieren oder Nachricht zu empfangen), solange self.process(message) auf Prozess ist. Gibt es eine Lösung, um dieses Hindernis zu überwinden?

Answer 1

Hier ist ein Basic-Code zum Einstieg mit ThreadPoolExecutor:

import concurrent.futures 

# create a `ThreadPoolExecutor` instance 
executor = concurrent.futures.ThreadPoolExecutor(max_workers=8) 


class Client(tornado.websocket.WebSocketHandler): 

    def on_message(self, message): 
     # ask `executor` to run `self.process` in a thread 
     executor.submit(self.process, message) 

    def process(self, message): 
     # do something blocking ... 
     return processed_message 

---

Wenn Sie die Nachricht in on_message nach der Verarbeitung darauf zugreifen möchten, haben Sie es mit gen.coroutine zu dekorieren und dann yield Die executor.submit(...):

from tornado import gen 

class Client(tornado.websocket.WebSocketHandler): 

    # decorate on_message with gen.coroutine 
    @gen.coroutine 
    def on_message(self, message): 
     # now use the yield keyword 
     processed_message = yield executor.submit(self.process, message) 
     # do something with processed_message 

    def process(self, message): 
     # do something blocking ... 
     return processed_message