0

我已经设置了一个运行 Mosca 的节点 js 服务器。客户端能够连接到 Mosca 服务器并发布消息。我需要以消息（订阅某个主题）的形式向客户端发送确认。

客户端发布消息后，以下代码会连续发送多条消息。我错过了什么吗？

 var settings = {
    port: 1882,
    backend: ascoltatore
 };

 var message = {
   topic: 'crofters',
   payload: 'OK', // or a Buffer
   qos: 2

 };

 var server = new mosca.Server(settings);

 server.on('clientConnected', function(client) {
       console.log('client connected', client.id);


   });

   // fired when a message is received
server.on('published', function(packet, client ) {


    var packet_payload = packet.payload;
    packet_payload = packet_payload.toString();
    console.log('Published', packet_payload);

    server.publish(message, function() {
        console.log('done!');
    });


});

server.on('ready', setup);

function setup() {
   console.log('Mosca server is up and running');
}
4

2 回答 2

2

事件监听server.on('published', function(packet, client){...}器监听每个发布事件，包括服务器的。

发生的事情是，当您server.publish(message, function(){...})在该侦听器内部使用时，它会触发另一个已发布的事件，该事件会立即被侦听器捕获。

它永远不会停止发布，因为它永远不会停止捕捉自己的事件。

于 2016-12-22T21:28:51.000 回答
0

我一直面临着类似的问题。如果您注意到，Mosca 只有 QoS 0 和 Qos 1

因此，我认为代理尝试“至少一次”多次发送相同的消息，直到它收到来自客户端的一些确认。看看这个文件

于 2016-11-20T20:04:07.897 回答