Ist es möglich, eine Nachricht an alle aktiven WebSocket-verbindungen? Entweder node.js oder python-tornado websockets

Ich experimentiere mit dem Aufbau einer websocket-basiert Anwendung.

Frage ich mich, ob es möglich ist eine Nachricht zu senden, um alle aktiven verbindungen, wie Sie sind hartnäckig.

Sagen, ich bin mit einem live-Auktions-Website, und ich habe mehrere Benutzer beobachten die Auktions-Seite, jeder von Ihnen ist angeschlossen über sockets zu meinem server. Sagen wir nun, dass ein Benutzer hebt das Gebot. Ich möchte zum senden einer Nachricht an alle angeschlossenen clients. Einfachste Weg ist, um das Kunden-Umfrage über den server socket, jede Sekunde, aber ich finde die Idee von websockets ist eine echte bi-direktionale Kommunikation.

Wie kann das getan werden?

vielen Dank im Voraus,

Rotem

Ich habe auch exakt diese Frage. Kann mir jemand sagen, wie kann ich dies in servlet mit tomcat-server. Habe ich einen WebSocketServlet diesem Beispiel. - gist.github.com/chitan/3063774

InformationsquelleAutor Rotem Tamir | 2011-07-08

socket.io Lösung:

//note, io.listen() will create a http server for you
var io = require('socket.io').listen(80);

io.sockets.on('connection', function (socket) {
  io.sockets.emit('this', { will: 'be received by everyone' });

  socket.on('private message', function (msg) {
    console.log('I received a private message from ', socket.id, ' saying ', msg);
    //Echo private message only to the client who sent it
    socket.emit('private message', msg);
  });

  socket.on('disconnect', function () {
    //This will be received by all connected clients
    io.sockets.emit('user disconnected');
  });
});

all_active_connections = {};

webocket server (es gibt viele), tun dasselbe manuell:

  var ws = require("ws");

  global_counter = 0;
  all_active_connections = {};

  ws.createServer(function (websocket) 
  {
      websocket.on('connect', function() 
      {
          var id = global_counter++;
          all_active_connections[id] = websocket;
          websocket.id = id; 
      }).on('data', function (data) {
          if (data == 'broadcast me!')
          {
              for (conn in all_active_connections)
                 all_active_connections[conn].write(data);
          }       
      }
    }).on('close', function() {
        delete all_active_connections[websocket.id];
    });
  }).listen(8080);

Können Sie bitte erklären, wie das im servlet.
was tun Sie nennen servlet?
Servlet in J2EE.

InformationsquelleAutor Andrey Sidorov

4

Für eine Lösung basierend auf der tornado/tornadio, Sie SocketConnection Klasse muss weiterhin eine Liste der verbindungen in der Klasse. Ihre on_connect handler hinzufügen würde, die Verbindung zu dieser Liste, und on_close würde es zu entfernen. Zum Beispiel pseudo-code zu sehen dieser Beitrag von Serge S. Koval. Der code reproduzieren unter:

Erklären TornadIO connection-Klasse:
```
class MyConnection(SocketConnection):
    participants = set()

    @classmethod
    def broadcast(cls, msg):
        for p in cls.participants:
            p.send(msg)

    @classmethod
    def controller_msg(cls, msg):
        cls.broadcast(msg)
```
In Ihrem Gerät polling-thread, etwas zu tun:
```
while True: 
    datum = file.readline() 
    if len(datum) > 2: 
        t = json.loads(datum) 
        ...
        def callback():
            MyConnection.controller_msg(t)

        io_loop.add_callback(callback)
```
Darüber hinaus gevent-socketio hat die Unterstützung für broadcast-Nachricht, aber es basiert auf gevent, nicht tornado.

UPDATE:

tornadio2 unterhält bereits eine Liste der aktiven Sitzungen, so dass alle Sie tun müssen, ist:
```
class MyConnection(SocketConnection):
    def broadcast(self, event, message):
        for session_id, session in self.session.server._sessions._items.iteritems():
            session.conn.emit(event, message)
```
Dies funktioniert, da jede Verbindung eine Instanz hat eine Referenz auf die Sitzung, die eine Referenz auf die Globale router verwendet, um die Anwendung zu erstellen (gespeichert als server), die pflegt eine Liste der Sitzungen in einem SessionContainer Objekt in _sessions. Nun, wenn Sie wollen broadcast-eine Nachricht in Ihrem Zusammenhang-Klasse, nur:
```
self.broadcast('my_custom_event', 'my_event_args')
```
InformationsquelleAutor Tony Abou-Assaleh
2

Diese redis + websockets (tornado) Beispiel sollte dir helfen. Im Grunde haben Sie eine Liste von Listenern, die benachrichtigt werden sollen und sobald eine Nachricht empfangen wird, beim Durchlaufen dieser Liste und informieren.
- Link funktioniert nicht.
- Aktualisiert, um ein weiteres
InformationsquelleAutor calvinkrishy

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.

UPDATE: