12

我在节点 js 和 xmpp 中迈出了第一步

我需要在节点 js 上的 xmpp 服务器上运行以进行消息传递

过程如下：我使用 node-xmpp 服务器https://github.com/astro/node-xmpp 运行服务器示例 (/examples/c2s.js) 与两个客户端连接到服务器（客户端在其他服务器上测试 jabber - 它有效并且消息正在发送）

客户在我的服务器上有授权。但是当我从一个客户端向另一个客户端发送消息时，消息会到达服务器（我在日志中看到），那就是消息没有到达接收者

我不知道在哪里寻找问题服务器配置？路由？短信可能需要自己添加？

请帮帮我

我的服务器代码（通过示例）

var xmpp = require('../lib/node-xmpp');

var c2s = new xmpp.C2SServer({
    port: 5222,
    domain: 'localhost'

});

// On Connect event. When a client connects.
c2s.on("connect", function(client) {
    c2s.on("register", function(opts, cb) {
        console.log("REGISTER");
    cb(true);
    });

    client.on("authenticate", function(opts, cb) {
        console.log("AUTH" + opts.jid + " -> " +opts.password); 
    cb(null); 
    });

    client.on("online", function() {
        console.log("ONLINE");
        client.send(new xmpp.Message({ type: 'chat' }).c('body').t("Hello there, little client."));
    });

    client.on("stanza", function(stanza) {
        console.log("STANZA" + stanza);

    });

    client.on("disconnect", function(client) {
        console.log("DISCONNECT");
    });

});

我运行服务器并通过此代码连接到它

var xmpp = require('../lib/node-xmpp');
var argv = process.argv;

if (argv.length < 6) {
    console.error('Usage: node send_message.js <my-jid> <my-password> <my-text> <jid1> [jid2] ... [jidN]');
    process.exit(1);
}

var cl = new xmpp.Client({ jid: argv[2], password: argv[3] });

cl.addListener('online',
   function() {argv.slice(5).forEach(
       function(to) {cl.send(new xmpp.Element('message', { to: to,type: 'chat'}).c('body').t(argv[4]));
       });

       // nodejs has nothing left to do and will exit
       // cl.end();
   });

cl.addListener('stanza',
    function(stanza) {
        if (stanza.is('message') &&
            // Important: never reply to errors!
            stanza.attrs.type !== 'error') {
            console.log("New message");
            // Swap addresses...
            stanza.attrs.to = stanza.attrs.from;
            delete stanza.attrs.from;
            // and send back.
            cl.send(stanza);
        }
    });

cl.addListener('error',
    function(e) {
       console.error(e);
       process.exit(1);
   });
4

5 回答 5

5

简短的回答：更改cb(null)为cb(null, opts).

长答案：

  1. client.on("authenticate", function(opts, cb) {...})注册当客户端尝试对自己进行身份验证时服务器将执行的操作。在 node-xmpp 内部，它会首先寻找认证机制，然后该机制将调用回调并通过cb.

  2. 默认情况下，使用Plain身份验证。你可以在这里查看它是如何工作的：https ://github.com/node-xmpp/node-xmpp-server/blob/master/lib/authentication/plain.js 。使用 Plainopts存储 jid 和密码。

  3. 然后通知 node-xmpp 身份验证失败/成功，我们需要查看https://github.com/node-xmpp/node-xmpp-server/blob/master/lib/authentication/mechanism.jsmechanism，继承自清楚的。 在这里，需要两个参数。为空和非空时，表示认证成功。否则，失败。 this.authenticate(this.extractSasl(auth), function (err, user) { if (!err && user) { self.success(user) } else { self.failure(err) } }) cberruser

于 2014-04-04T19:44:57.563 回答
2

我既不是 node.js 也不是 xmpp 专家。但是阅读您的代码。我假设“节”是客户端发送消息的事件。您要求它记录消息，但您没有说明如何将其路由到收件人。您应该将服务器上收到的消息分解为消息正文和收件人，并要求您的服务器将其发送给收件人。

于 2013-10-25T08:17:45.103 回答
1

您可以从服务器获取短信和接收者 JID。只需按以下方式打破节并将其放在错误侦听器之前：-

cl.on('stanza', function(stanza) {
   if (stanza.is('message') && (stanza.attrs.type !== 'error')) {
       var body = stanza.getChild('body');
       if (!body) {
         return;
       }
       console.log(stanza.attrs.from+" Says: "+body.children[0]);
   }
});
于 2015-03-12T06:35:18.700 回答
1

Alex 您使用了 C2SServer，它连接了服务器和客户端之间的流。当您从一个客户端向另一个客户端发送消息时，它们会到达服务器。现在，服务器负责将它们转发回实际接收器。

一种可能的解决方案是在客户端通过身份验证时保持客户端对象是与其 jid 对应的全局对象，当您收到该客户端的消息时，您可以从全局变量中获取该消息并将消息路由到保存在全局变量中的实际客户端。

于 2014-04-03T14:23:29.867 回答
0

在“身份验证”中，参数可能不足以进行回调吗？

NG:
cb(null);

OK:
cb(null, opts);
于 2014-03-18T12:33:41.537 回答