从一个客户端向另一个 socket.io 发送响应消息时出现问题

Question

我的问题如下： 我有 2 个通过套接字服务器进行通信的应用程序。 App1 通过 message 事件向 app 2 发送消息。这可以正常工作，因为应用程序 2 获得了正确的消息，我正在尝试做的是从应用程序 2 向 1 发送另一条回复消息，以警告消息已顺利到达。为此，我有一个名为 estado_mensaje 的事件，该事件在消息事件中发出，并且在服务器上在侦听此事件时发出 mensaje_ok 事件，这在服务器控制台中显示良好，但我无法在应用程序 1 中收到该消息. 这是我的代码：

服务器节点

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var port = process.env.PORT || 4444;

app.get('/', function(req, res){
res.sendFile(__dirname + '/index.html');
});

UserOnId=new Array();
IdsOnUser=new Array();
io.on('connection', function(socket){

socket.on('datos_usuario', function(datos){
 id_socket=socket.id;
 usuario=datos.username;
 UserOnId[id_socket]=usuario;

 if(IdsOnUser[usuario]==null){
  IdsOnUser[usuario]=new Array();
 }
 IdsOnUser[usuario].push(id_socket);

console.log('------usuarios por id_socket------');
console.log(UserOnId);
console.log('------IDs socket por usuarios------');
console.log(IdsOnUser);
console.log('Cantidad de usuarios en lineas');
console.log(Object.keys(IdsOnUser).length);
 io.emit('nuevo_usuario', datos);

});


socket.on('message', function(datos){

  if(datos.user_to!=''){
      destinatario=datos.user_to;
      if(IdsOnUser[destinatario]){
          id_onlines=IdsOnUser[destinatario];
          for (var i=0;i<id_onlines.length;i++){
              io.to(id_onlines[i]).emit('message', datos);
          }
          io.to(socket.id).emit('message', datos);
      }

  }else {
      io.emit('message', datos);
  }
    console.log(datos.contenido);


});


socket.on('estado_mensaje ', function(datos){

    console.log(datos);
    io.emit('ok_mensaje', datos);

});

App1

var socket = io();
$(function () {


    $('form').submit(function(){
        var id_usuario_logueado=$('#id_username').val();
        var usuario_logueado=$('#username').val();
        var id_user_to=$('#id_receptor').val();
        var user_to=$('#receptor').val();
        datos={id_user_from:id_usuario_logueado,user_from:usuario_logueado,id_user_to:id_user_to,user_to:user_to,contenido:$('#m').val()};
        /*Envia un mensaje a traves del canal message*/
        socket.emit('message', datos);
        $('#m').val('');
        return false;
    });

    socket.on('message', function(datos){
        $('#messages').append($('<li>').text(datos.user_from+':'+datos.contenido));
        console.log(datos);
        window.scrollTo(0, document.body.scrollHeight);

    });

    socket.on('nuevo_usuario', function(datos){

        console.log('Usuario logueado: '+datos.username);
        var usuario_logueado=$('#usuario_logueado').val(datos.username);

    });

    socket.on('ok_mensaje ', function(datos){

        alert('llega la respuesta');
        console.log(datos);


    });

});
function loguear(){
    var username=$('#username').val();
    socket.emit('datos_usuario', {username:username});
}

App2

socket.on('message', function(datos){
    $.ajax({
    url: "index.php?route=administracion/chat/send_message&token=" + token,
    type: 'POST',
    dataType: 'json',
    async:true,
    data:{ id_user_from : id_user_from,id_user_to: id_user_to },
    success: function (json) {
      /*Here is how I emit the response to the other app*/
       socket.emit('estado_mensaje ', {status:'sucess'});
       console.log('guarda bien');
    },
    error: function(json){
        console.log('guarda mal');
        socket.emit('estado_mensaje ', {status:'error'});

    }
});
});

Answer 1

您的邮件名称略有不同。

在您的序列后期，您的服务器会这样做：

io.emit('ok_mensaje', datos);

但是 app1 正在这样做：

socket.on('ok_mensaje ', function(datos){ ...});

看看一个消息名称的末尾有空格，而另一个则没有。它们不匹配。 在您命名的消息末尾放置空格的整个概念（对我而言）似乎是一种可怕的约定。如果您想区分消息，请使用前导下划线或前缀，如 ok_ 或非常明显的前缀，而不是尾随空格那么微妙的前缀。

仅供参考，这是发生的事情的顺序，有时您必须如何调试这些事情，以将实际顺序解包成一组顺序代码，您可以更轻松地遵循这些代码。这就是我发现上述问题的方式：

// client (app1)
socket.emit('message', datos);

// server
socket.on('message', function(datos){

    // ...
    for (var i=0;i<id_onlines.length;i++){
        io.to(id_onlines[i]).emit('message', datos);
    }   
    io.to(socket.id).emit('message', datos);

});

// client (app2)
socket.on('message', function(datos){
    socket.emit('estado_mensaje ', {status:'sucess'});
});

// server
socket.on('estado_mensaje ', function(datos){
    console.log(datos);
    io.emit('ok_mensaje', datos);
});

// *** Everything works up to here ***
// *** the next part does not work ***

// client (app1)

socket.on('ok_mensaje ', function(datos){
    alert('llega la respuesta');
    console.log(datos);
});