龙卷风Websocket与单独的线程/应用程序的交互

Question

我正在尝试通过单独的服务器线程在龙卷风上进行交互或发送消息。任何帮助将不胜感激。

这是一些代码

waiters = set()

class MainHandler(tornado.web.RequestHandler):
  def get(self):
     print ("[HTTP](MainHandler) User Connected.")
     self.render("index.html")


class WSHandler(tornado.websocket.WebSocketHandler):
    cache = []
    cache_size = 200
    
    def open(self):
        global waiters
        print(list(waiters))
        print ('[WS] Connection was opened.')
        waiters.add(self)
        print(list(waiters))

    def on_message(self, message):
        print ('[WS] Incoming message:'), message
        if message == "toggle":
            global waiters
            for client in self.waiters:
                print("fired")
    def on_close(self):
        global waiters
        print(list(waiters))
        print ('[WS] Connection was closed.')
        waiters.remove(self)
        print(list(waiters))

     @classmethod
     def client_message_from_program(cls, JSONmsg):
         print("JSONmsg") #This does not print using add_callback
         print(JSONmsg)
         for client in cls.waiters:
             print('sent to client')
             client.write_message(json.dumps(JSONmsg))

单独的线程代码，希望与Wshandler进行交互/接口 loopdeclaration引用了正确的龙卷风.ioloop.ioloop.instance（）

    msg_json={"type":"StatusUpdate","message":"Connected","message1":"123412","Message2":"Calculating RSSI","Message3":""}
    LoopDeclaration.add_callback(WSHandler.client_message_from_program, msg_json)

这不会引起例外，但不会引起wshandler的任何进一步行动。没有消息传递。

创建客户的全局列表并以这种方式发送消息将不起作用，或者在测试中不适合我。 （全球列表不会在Wshandler之外进行更新，在龙卷风5.0及以后的wshandler之外发送消息）

将不胜感激。一些旧线程提到在龙卷风WS上以“特殊客户端”为“特殊客户端”的遗产线程将是最好的方法，但我不知道如何实现这一目标，并且无法找到前进的路径。谢谢。

Answer 1

其他Stackoverflow建议创建一个“特殊客户”，但有关此技术成就的信息最少。我在这里添加我的解决方案，以帮助他人遇到同样的问题。

相关的服务器代码：

class ApplicationHandler(tornado.web.RequestHandler):
    def get(self):
        server = tornado.ioloop.IOLoop.current()
        data = {"type":"StatusUpdate","message":"Connected - Backend Application Ready","message1":"Current Action: Starting Up ","message2":" ","message3":" "}
        server.add_callback(WSHandler.send_message, data)
        self.set_status(200)
        self.finish()

    def post(self):
        datatype = self.get_argument('type', '')
        if datatype:
            server = tornado.ioloop.IOLoop.current()
            server.add_callback(WSHandler.send_message, self.request.body)

[Under WSHandler]
    @classmethod
    def send_message(self, message):
        if isinstance(message, bytes):
            x = urllib.parse.parse_qs(bytes.decode(message))
            message = x
        else:
            pass
        for client in waiters:
            client.write_message(message)
        #for session_id, session in self.session.server._sessions._items.iteritems():
        return True


application = tornado.web.Application([
  (r'/', MainHandler),
  (r"/application/", ApplicationHandler),
  (r'/ws', WSHandler),
  ], **settings)

应用程序/特殊客户端，

    http_client = tornado.httpclient.HTTPClient()
        response = http_client.fetch("http://localhost:8001/application/")
        print(response.body)
    except tornado.httpclient.HTTPError as e:
        print("Error: " + str(e))
    except Exception as e:
        print("Error: " + str(e))
    post_data = {"type":"StatusUpdate","message":"Connected","message1":"Secondary Update from client","message2":"Calculating","message3":" "}
    post_data_encoded = urllib.parse.urlencode(post_data) #Make it into a post request
    http_client.fetch("http://localhost:8001/application/", method='POST', headers=None, body=post_data_encoded) #Send it off!

我敢肯定有更好的方法可以做到这一点，如果有人提供未来的建议，请添加它们。我对酒吧/子模型感兴趣，但没有时间足够学习...