Я реализовал функцию чата с помощью sockjs-tornado и мог хранить сообщения в RethinkDB.

Не могли бы вы помочь мне, как мне установить частный канал для обмена сообщениями в sockjs-tornado? (Я имею ввиду приватный разговор / один на один)

Ниже приведена функция on_message в моем коде на стороне сервера -

def on_message(self, message):
    str=message
    mg=str.split('#:#')
    sender=1 # This is the sender user id
    receiver=2 #This is the receiver user id - I need to implement session variables to have these id's so that I can use it here this way
    ts=r.expr(datetime.now(r.make_timezone('00:00')))
    connection = r.connect(host="192.x.x.x")
    r.db("djrechat").table('events').insert({"usrs":mg[0],"msg":mg[1],"tstamp":ts,"snder":sender,"rcver":receiver}).run(connection)
    log.info(message)
    self.broadcast(self.participants, '{} - {}'.format(self.stamp(),message))

В настоящее время это вещание для всех подключенных клиентов. Может быть, я должен иметь идентификатор канала и отправлять сообщения только двум клиентам, которые будут иметь одинаковый идентификатор канала, но как мне его реализовать или есть ли лучшее решение для этого?

На стороне клиента, у меня есть ниже javascript -

      function connect() {
        disconnect();
        conn = new SockJS('http://localhost:8080/chat', ['websocket','xhr-streaming','iframe-eventsource','iframe-htmlfile','xhr-polling','iframe-xhr-polling','jsonp-polling']);
        //log('Connecting.....');
        conn.onopen = function() {
        //  log('Connected. (' + conn.protocol + ')');
        log('Connected.');
        };

        conn.onmessage = function(e) {
          log(e.data);
        };

        conn.onclose = function() {
          log('Disconnected.');
          conn = null;
        };
      }

Я использую Python 3.4 - Django 1.8.4 и Rethinkdb