Private Messaging mit sockjs-tornado
Ich habe die Chat-Funktion mit sockjs-tornado implementiert und konnte die Nachrichten in RethinkDB speichern.
Könnten Sie mir bitte helfen, wie ich einen privaten Kanal für Nachrichten in sockjs-tornado einrichte? (Ich meine Privatgespräch / eins zu eins)
Below ist die Funktion on_message in meinem serverseitigen Code -
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))
Zurzeit wird an alle verbundenen Clients gesendet. Möglicherweise sollte ich eine Kanal-ID haben und eine Nachricht nur an die beiden Clients senden, die dieselbe Kanal-ID haben, aber wie implementiere ich sie oder gibt es eine bessere Lösung dafür?
uf der Client-Seite habe ich unten 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;
};
}
Ich benutze Python 3.4 - Django 1.8.4 und Rethinkdb