Psi と Spark の 2 つのクライアントのチャット サーバーとして node-xmpp サーバーを使用しています。クライアントごとにアカウントを登録します。Psi アカウントから Spark アカウントにメッセージを送信したいです。アカウント同じアカウントがメッセージを受信します。友達をリストに追加し（なぜ機能しないのかわかりません..おそらく実装されていません）、メッセージを正しく送信したい.ノードxmppサーバー/例/を使用していますserver-and-client.js.アドバイスありがとうございます。
質問する
892 次
2 に答える
2
この完全なコードは私にとって非常にうまく機能します:
var xmpp = require('node-xmpp-server');
function generateRoster(jid, name, id, to) {
// This is a roster request, we create the response node
var roster = new xmpp.Element('iq', {
id: id,
to: to,
type: 'set'
});
roster.c('query', {xmlns: 'jabber:iq:roster', ver: 'ver13'})// We add a children tag `query`, with the two attribute xmlns and ver
.c('item', { // We add a children 'Item'
jid: jid, // We send the jid and the name
name: name,
subscription: 'both'
}).c('group').t('Connected Clients'); // We add it to the 'Connected Clients' group
return roster;
}
var startServer = function (done) {
// Sets up the server.
server = new xmpp.C2S.TCPServer({
port: 5222,
domain: 'localhost'
});
var connectedUsers = [];
var clientsHandles = {};
// On connection event. When a client connects.
server.on('connection', function (client) {
var userJid = null;
// That's the way you add mods to a given server.
// Allows the developer to register the jid against anything they want
client.on('register', function (opts, cb) {
console.log('REGISTER');
console.log(cb);
cb(false)
});
// Allows the developer to authenticate users against anything they want.
client.on('authenticate', function (opts, cb) {
//console.log('server:', opts.username, opts.password, 'AUTHENTICATING')
if (opts.password === 'secret') {
//console.log('server:', opts.username, 'AUTH OK')
cb(null, opts)
}
else {
//console.log('server:', opts.username, 'AUTH FAIL')
cb(false)
}
});
client.on('online', function () {
userJid = client.jid.user + '@' + client.jid.domain + '/' + client.jid.resource;
console.log(userJid + 'ONLINE');
for (var i = 0; i < connectedUsers.length; i++) {
var myRoster = generateRoster(userJid, userJid, 'myRandomId', connectedUsers[i]);
if (clientsHandles[connectedUsers[i]]) {
clientsHandles[connectedUsers[i]].send(myRoster);
console.log("Sending my new infos to ", connectedUsers[i]);
}
}
connectedUsers.push(userJid);
client.jid.userJid = userJid;
clientsHandles[userJid] = client;
});
// Stanza handling
client.on('stanza', function (stanza) {
if (stanza.is('message') && (stanza.attrs.type !== 'error')) {
if (clientsHandles[stanza.attrs.to]) {
clientsHandles[stanza.attrs.to].send(stanza);
}
}
else if (stanza.is('presence')) {
// We loop through the user list
for (var j = 0; j < connectedUsers.length; j++) {
console.log(stanza.toString());
var jid = connectedUsers[j];
stanza.to = jid;
clientsHandles[jid].send(stanza);
}
}
else if (stanza.is('iq') && stanza.attrs.type == 'get') {
for (var i = 0; i < stanza.children.length; i++) {
if (stanza.children[i].name == 'query' && stanza.children[i].attrs.xmlns == 'jabber:iq:roster') {
// We loop through the user list
for (var j = 0; j < connectedUsers.length; j++) {
var roster = generateRoster(connectedUsers[j], connectedUsers[j], stanza.attrs.id, stanza.attrs.from);
client.send(roster); // We send it back to the client
}
}
}
client.send(stanza);
}
else {
client.send(stanza);
}
});
// On Disconnect event. When a client disconnects
client.on('disconnect', function () {
if (userJid) {
console.log(userJid, "DISCONNECTED");
connectedUsers.splice(connectedUsers.indexOf(userJid), 1);
delete clientsHandles[userJid];
}
});
});
server.on('listening', done)
};
startServer(function () {
console.log("Server running");
});
メッセージスタンザが到着すると、受信者が接続されているかどうかを確認し、接続されている場合はスタンザを送信します。
于 2015-08-25T10:50:24.043 に答える
1
正しいクライアント接続、つまり
1) を使用してメッセージを送信します。認証時にクライアントのすべての接続を配列に格納します。
2)。メッセージが来たら、メッセージ スタンザの「to」フィールドに関連付けられた正しいクライアントを見つけます。
var receiverCleint = getClient(msgStanza.attrs.to)
3)。正しいクライアントを返し、そのクライアントを介してメッセージを送信します。
receiverCleint.send(msgStanza)
私も同じデモに取り組んでいます。私の唯一の懸念は、より多くのユーザーが追加すると、すべてのクライアントを介して各メッセージを反復処理する必要があるため、問題になることです。
より良いアプローチがあれば幸いです。
コード：
var clients = new Array();
c2sRouter.on("connection", function(client){
client.on("register", function(opts, cb){
console.log("client server", "register");
})
client.on("authenticate", function(opts, cb){
console.log("client server", "authenticate");
if(opts.password === "tushar" || opts.password === "tushar1"){
clients.push(client);
cb(null, opts);
}else{
cb(false, opts);
}
})
client.on("online", function(){
console.log("client server", "online");
})
client.on("stanza", function(stanza){
console.log("client server", stanza.toString());
if(stanza.is("message")){
var receiverClient = getClient(stanza.attrs.to)
if(receiverClient === undefined){
client.send(stanza);
} else {
receiverClient.send(stanza);
}
}
})
client.on("disconnect", function(){
console.log("client server", "disconnect");
})
})
var getClient = function (to) {
var clientLength = clients.length;
var client
var clientId;
for(var i = 0; i < clientLength; i++){
client = clients[i];
clientId = client.jid.user + "@" + client.jid.domain
if(to.indexOf(clientId) == 0){
return client;
}
}
}
于 2015-08-23T14:22:08.027 に答える