Websockets mit Tornado: Holen Sie sich den Zugriff von "außen" zum senden von Nachrichten an clients

Ich fange an, in WebSockets als Weg zur übertragung von Daten von einem server an die verbundenen clients. Da ich python Programmieren jede Art von Logik, ich sah der Tornado so weit. Der Codeausschnitt unten zeigt die einfachen Beispiel kann man überall auf der Web:

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 on_message(self, message):
        print 'message received %s' % message
        self.write_message('ECHO: ' + 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()

Als es ist, das funktioniert wie vorgesehen. Aber ich kann nicht meinem Kopf herum wie kann dieses "integriert" in dem rest meiner Bewerbung. Im obigen Beispiel wird die WebSocket-nur sendet etwas an die clients als Antwort auf eine client-Nachricht. Wie kann ich auf die WebSocket-von "außen"? Zum Beispiel zur Anzeige aller momentan verbundenen clients, die eine Art-Ereignis aufgetreten ist, -- und dieser Fall ist NICHT jede Art von Nachricht von einem client. Im Idealfall würde ich mag zu schreiben, die irgendwo in meinem code so etwas wie:

websocket_server.send_to_all_clients("Good news everyone...")

Wie kann ich dies tun? Oder muss ich eine komplette misundersanding, wie WebSockets (oder Tornado) arbeiten sollten. Danke!

InformationsquelleAutor Christian | 2014-05-09
  1. 10

    Dies ist aufbauend auf Hans Dann dem Beispiel. Ich hoffe, es hilft Ihnen zu verstehen, wie Sie Ihre server initiieren Sie die Kommunikation mit Ihren Kunden, ohne die Kunden auslösen der Interaktion.

    Hier ist der server:

    #!/usr/bin/python

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



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

    def on_message(self, message):
        print 'message received %s' % message
        self.write_message('ECHO: ' + message)

    def on_close(self):
        print 'connection closed'
        WSHandler.clients.remove(self)

    @classmethod
    def write_to_clients(cls):
        print "Writing to clients"
        for client in cls.clients:
            client.write_message("Hi there!")


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


if __name__ == "__main__":
    http_server = tornado.httpserver.HTTPServer(application)
    http_server.listen(8888)
    tornado.ioloop.IOLoop.instance().add_timeout(datetime.timedelta(seconds=15), WSHandler.write_to_clients)
    tornado.ioloop.IOLoop.instance().start()

    Ich aus der client-Liste einer Klasse, variable, anstatt global. Ich eigentlich nicht dagegen, mit einer globalen variable für diesen, aber da waren Sie besorgt, hier ist ein alternativer Ansatz.

    Und hier ist ein Beispiel-client:

    #!/usr/bin/python

import tornado.websocket
from tornado import gen 

@gen.coroutine
def test_ws():
    client = yield tornado.websocket.websocket_connect("ws://localhost:8888/ws")
    client.write_message("Testing from client")
    msg = yield client.read_message()
    print("msg is %s" % msg)
    msg = yield client.read_message()
    print("msg is %s" % msg)
    msg = yield client.read_message()
    print("msg is %s" % msg)
    client.close()

if __name__ == "__main__":
    tornado.ioloop.IOLoop.instance().run_sync(test_ws)

    Können Sie dann auf dem server ausgeführt werden, und zwei Instanzen der test-client eine Verbindung herstellen. Wenn Sie das tun, der server gibt diese:

    bennu@daveadmin:~$ ./torn.py 
new connection
message received Testing from client
new connection
message received Testing from client
<15 second delay>
Writing to clients
connection closed
connection closed

    Den ersten client druckt diese:

    bennu@daveadmin:~$ ./web_client.py 
msg is Hello World
msg is ECHO: Testing from client
< 15 second delay>
msg is Hi there! 0

    Und der zweite druckt diese:

    bennu@daveadmin:~$ ./web_client.py 
msg is Hello World
msg is ECHO: Testing from client
< 15 second delay>
msg is Hi there! 1

    Für die Zwecke dieses Beispiels, hatte ich gerade den server sendet die Nachricht an die clients, die auf eine 15 Sekunden Verzögerung, aber es könnte ausgelöst werden durch das, was Sie wollen.

    • Dano, vielen Dank! Das bringt mich näher an mein Ziel. Aber ein timer passt nicht ein event-basiertes system. Ich kann auch nicht sehen, wie könnte ich das senden der Nachricht als parameter, statt immer nur "Hallo, es gibt". Ihr "aber es könnte sein, ausgelöst durch das, was Sie wollen", ist der wirklich faszinierende Teil für mich :). Ist es jetzt wirklich so, um ein handle auf das WebSocket-wie ws = WebSocket() umfasst der server gestartet wird und dann ein ws.write_to_clients(msg) wenn ein Ereignis aufgetreten ist? Ist das nicht der Grundgedanke hier? Aber ich konnte nicht finden ein Beispiel noch.
    • Was ist das "Ereignis" haben Sie im Sinn? Mein Beispiel könnte umgestaltet werden leicht, so dass write_to_clients ist nur eine Funktion der obersten Ebene des Moduls, sondern als Methode einer Klasse. Es könnte auch ein parameter, anstatt nur immer mit "Hallo, es gibt". Dann ist Ihr event-handling-code kann nur aufrufen dieser Methode. Macht das Sinn?
    • Ich nehme an, Ihr verpasst würde, wie Hans modifizierten Beispiel mit einem send_to_all_clients Methode auf der obersten Ebene des Moduls. Aber in seinem Beispiel ist er immer noch ruft diese Methode innerhalb der WSHandler Klasse. Aber wie kann ich das aufrufen dieser Methode von "überall"? -- Um ein Beispiel zu geben: Sagen Sie, was meine Anwendung macht komplexe Berechnungen, und jedes mal, wenn eine neue Folge verfügbar ist, möchte ich bekannt geben, dass er an alle verbundenen clients.
    • Ich meine nicht, um die Funktion ein Teil der WSHandler Klasse. Nur machen es zu einem standalone-Funktion auf der obersten Ebene des Moduls, und verwenden Sie WSHandler.clients im inneren statt cls.clients. Dann rufen Sie einfach write_to_clients von der Funktion tun, die Berechnungen.
    • Bitte Lesen Sie meine latestet Kommentar auf die erste Antwort. Habe ich endlich entdeckt, mein Missverständnis. Vielen Dank für Sie Hilfe gibt es immer!
    • Dies war ein treffend erklärte Antwort, die code-Beispiele sind ausreichend, um die Idee zu verstehen und auch versuchen, mehr Dinge. Ich danke Ihnen sehr!
    • Hey könntest du Jungs check this out stackoverflow.com/questions/51635511/..., es wäre super-hilfreich, um einige Erkenntnisse von Menschen, die wissen, tornado gut!

    InformationsquelleAutor dano
  2. 10

    Müssen Sie verfolgen alle clients, die eine Verbindung herstellen. Also:

    clients = []

def send_to_all_clients(message):
    for client in clients:
        client.write_message(message)

class WSHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        send_to_all_clients("new client")
        clients.append(self)

    def on_close(self):
        clients.remove(self)
        send_to_all_clients("removing client")

    def on_message(self, message):
        for client in clients:
            if client != self:
                client.write_message('ECHO: ' + message)
    • Hans, vielen Dank! Ja, fand ich diese Lösung irgendwo. Aber Erstens, so wurde argumentiert, dass die Verwendung einer globalen variable für das nicht eine schöne Art und Weise. Und zweitens auch mit, dass ich nicht weiß, wie es weitergehen soll. Ich nehme an, irgendwo habe ich eine Schleife über alle clients und für jeden client rufen Sie die write_message Methode. Aber wohin mit der Schleife. Wenn ich das Skript starte, scheint alles blockiert zu sein. Könnte Sie verlängern meine anfängliche Beispiel, um ein komplettes Beispiel mit Ihrem Ansatz, einschließlich einer Schleife über die client-array. Das wäre genial!
    • Ich habe eine Methode zum senden einer Nachricht an alle clients und ein paar Beispiele, wie Anruf, Nachricht.
    • Sehe ich, aber immer noch send_to_all_clients Aufruf innerhalb der WSHandler Klasse. Wie kann ich jetzt rufen Sie diese Methode von praktisch überall zu integrieren in eine größere Anwendung? Vielleicht habe ich einfach ein völliges Missverständnis über WebSockets.
    • Sie können rufen Sie die send_to_all_clients aus, wohin Sie wollen.
    • Das könnte auszusetzen meine Schwächen in Python :). Aber was nicht funktioniert, ist, z.B., ein 2. Skript mit from ... import send_to_all_clients und dann send_to_all_clients('External message'). Es ist einfach nicht die gleiche Tragweite, die clients array ist immer leer, wenn genannt wie diese. Können Sie ein konkretes Beispiel von "Sie können es nennen, von überall Sie wollen"?
    • Auch Ihre python-sollte Sie einfach die Arbeit. Aber vielleicht ist Schwäche nicht so viel Python wie Javascript. Kann man den code für die clients, die eine Verbindung zu Ihrem websocket-server?
    • In der Tat, es war mein Missverständnis mit WebSocket-Servern oder zumindest Tornado. Die einfache Möglichkeit zum auslösen des senden eines meesage von einer Anwendung ist, lassen Sie die Anwendung die Verbindung zu Tornado-Einsatz einer dedizierten Handler, d.h., was die Anwendung im Grunde so etwas wie eine "special client". Aber vielen Dank für Euch Mühe, es sicherlich dazu beigetragen, mich zu erkennen, mein problem!
    • Da ich meinen Kunden ständig anhören der server in einer Schleife, wie es hier erwähnt wird tornadoweb.org/en/stable/websocket.html#client-side-support. Ich bin nicht in der Lage, mehrere Instanzen des clients die Verbindung zum server mit den oben genannten Prozess der Verwendung eine Liste.. Der zweite client immer wartet, bis der erste client-Prozess zu Ende, bevor ich den Lesen von Nachrichten aus dem server.. gibt es eine Möglichkeit, um dieses?

    InformationsquelleAutor Hans Then
  3. 0

    meine Lösung dazu: zuerst fügen Sie "if __name__ == '__main__':" - der main.py. dann importieren main.py in die websocket-Modul. z.B. (import main as MainApp) . es ist nun möglich, eine Funktion aufzurufen, die in 'main.py" in der ws.py/WebSocketHandler-Funktion. - in den Handler übergeben Sie die Nachricht etwa so:
    MainApp.function(message)

    ich weiß nicht, ob das ist das Gegenteil von elegant, aber es funktioniert für mich.

    ..plus erstellen und importieren Sie eine benutzerdefinierte 'config.py' (das sieht aus wie: someVar = int(0) ) in der 'mainApp.py' .. etwa so: import config as cfg --> jetzt können Sie verändern Variablen mit cfg.someVar = newValue aus dem inneren der Funktion in 'main.py' das einmal genannt wurde, die von der Prozedur 'ws.py'.

    InformationsquelleAutor ronnies
Schreibe einen Kommentar