Можно ли отправить сообщение всем активным соединениям WebSocket? Использование либо node.js, либо python tornado websockets - PullRequest
Новая
       21

Можно ли отправить сообщение всем активным соединениям WebSocket? Использование либо node.js, либо python tornado websockets

8 голосов
/ 08 июля 2011

Я экспериментирую с созданием приложения на основе веб-сокета.

Мне интересно, можно ли отправить сообщение всем активным соединениям, поскольку они постоянны.

Скажите, что я работаюсайт живого аукциона, и у меня есть несколько пользователей, просматривающих страницу аукциона, каждый из которых подключен через сокеты к моему серверу.Допустим, один пользователь повышает ставку.Я хочу отправить сообщение всем подключенным клиентам.Самый простой способ состоит в том, чтобы клиенты опрашивали сервер через сокет каждую секунду, но я думаю, что идея веб-сокетов состоит в том, чтобы иметь истинную двунаправленную связь.

Как это можно сделать?

спасибозаранее

Rotem

Ответы [ 3 ]

6 голосов
/ 08 июля 2011

socket.io решение: 

// 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 (имеется много ), выполните то же вручную: 

  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);
4 голосов
/ 08 марта 2012

Для решения, основанного на tornado / tornadio, ваш класс SocketConnection должен поддерживать список соединений на уровне класса. Ваш обработчик on_connect добавит соединение в этот список, а on_close удалит его. Образец псевдокода см. в этом посте . Автор: Сергей С. Коваль. Код приведен ниже:

Объявите свой класс подключения TornadIO: 

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)

В теме опроса вашего устройства выполните что-то вроде: 

while True: 
    datum = file.readline() 
    if len(datum) > 2: 
        t = json.loads(datum) 
        ...
        def callback():
            MyConnection.controller_msg(t)

        io_loop.add_callback(callback)

Кроме того, gevent-socketio поддерживает широковещательную рассылку сообщений, но основан на gevent, а не на торнадо.

UPDATE:

tornadio2 уже ведет список активных сессий, поэтому все, что вам нужно сделать, это: 

class MyConnection(SocketConnection):
    def broadcast(self, event, message):
        for session_id, session in self.session.server._sessions._items.iteritems():
            session.conn.emit(event, message)

Это работает, потому что каждый экземпляр соединения имеет ссылку на свой сеанс, который имеет ссылку на глобальный маршрутизатор, используемый для создания приложения (хранится как server), который поддерживает список сеансов в объекте SessionContainer в _sessions. Теперь, когда вы хотите передать сообщение в вашем классе соединения, просто сделайте: 

self.broadcast('my_custom_event', 'my_event_args')
2 голосов
/ 28 июля 2011

Этот redis + websockets (на торнадо) пример должен вам помочь. В основном у вас есть список слушателей, которых следует уведомить, и как только сообщение будет получено, выполните итерацию по этому списку и сообщите им.

...