Node.JS: ¿Cómo crear un servidor HTTP Chat?

Question

Con el Net Stream Object con TCP funciona muy bien (como presetend en el node.js introduction video), pero ¿cómo debo hacer esto en HTTP?

¿Hay alguna manera de acceder a sockets/clients dentro de un http.createServer()? ¿O cuál es el método para hacerlo? Traté de encontrar la solución del node chat demossouce code oficial, pero realmente no lo entiendo.

Entiendo el lado del cliente js, pero ¿qué ocurre después de que (como cliente) envíe un mensaje a través de AJAX, al lado del servidor js? ¿Cómo puedo enviar a los otros clientes que están en el servidor también?

Tenga en cuenta que no quiero aprender la lógica del proceso, por lo que no quiero usar socket.io o cualquier otro marco, bibliotecas, módulos.

Muchas gracias por cualquier ayuda!

Answer 1

Una forma de hacerlo implica que los clientes se "suscriban" a un canal que actúa como distribuidor de mensajes. Una vez suscrito, un cliente recibe una copia de cada mensaje enviado al canal.

Muchos servicios de chat de nodos se basan en la función pubsub de redis para manejar esta distribución de mensajes de uno a cualquier número de clientes. Si quisieras "hacer tuyo", entender cómo Redis resuelve este problema sería un gran comienzo.

Answer 2

Lo ideal es que solo use WebSockets, pero la alternativa es ajax de largo sondeo.

Puede utilizar una técnica conocida como larga encuesta para hacer el chat. Esto significa que realiza una solicitud (ajax) al servidor y el servidor retiene esta solicitud hasta que le quedan algunos datos para enviar.

Por lo que los clientes terminan sondeando periódicamente el servidor, si el servidor no tiene nuevos mensajes, solo mantiene su solicitud. Si tiene un mensaje, lo envía de vuelta al cliente y el cliente volverá a sondear el servidor.

[[Código Pseudo]]

// Client.js

var Socket = function(ip, port, name) { 
    this.ip = ip; 
    this.port = port; 
    this.name = name; 
    this._cbs = []; 
    this._poll(); 
}; 

// Call the server periodically for data. 
Socket.prototype._poll = function() { 
    var that = this; 
    // if the server does not return then call it again 
    var timer = setTimeout(function() { 
     this._poll(); 
    }, 5000); 
    $.ajax({ 
     type: "GET", 
     timeout: 5000, 
     data: { 
      name: this.name 
     }, 
     url: this.ip + ":" + this.port, 
     success: function(data) { 
      // server returned, kill the timer. 
      clearTimeout(timer); 
      // send the message to the callback. 
      for (var i = 0; i < that._cbs.length; i++) { 
       that._cbs[i](data); 
      } 
      // call the server again 
      that._poll(); 
     } 
    }); 
}; 

// Add a callback for a message event 
Socket.prototype.on = function(event, cb) { 
    if (event === "message") { 
     this._cbs.push(cb); 
    } 
}; 

// Send a message to the server 
Socket.prototype.send = function(message) { 
    $.ajax({ 
     data: { 
       message: message, 
       name: this.name 
     }, 
     type: "GET", 
     url: this.ip + ":" + this.port 
    }); 
}; 

var socket = new Socket('192.168.1.1', '8081', "Raynos"); 
socket.on("message", function(data) { 
    console.log(data); 
}); 
socket.send("Hello world!"); 

// server.js

var url = require("url"); 
var events = require("events"); 
// store messages for clients 
var clients = {}; 

var emitter = new events.EventEmitter(); 

http.createServer(function(req, res) { 
    // get query string data 
    var data = url.parse(req.url, true).query; 
    // if client is not initialized then initialize it. 
    if (data.name && !clients[data.name]) { 
     clients[data.name] = []; 
    } 
    // if you posted a message then add it to all arrays 
    if (data.message) { 
     for (var k in clients) { 
       clients[k].push(data.name + " : " + data.message); 
     } 
     // tell long pollers to flush new data. 
     emitter.emit("new-data"); 
    } else if (clients[data.name].length > 0) { 
     // else empty the clients array down the stream 
     for (var i = 0; i < clients[data.name].length; i++) { 
       res.write(clients[data.name].shift()); 
     }; 
     res.end(); 
    // long polling magic. 
    } else { 
     var cb = function() { 
       for (var i = 0; i < clients[data.name].length; i++) { 
        res.write(clients[data.name].shift()); 
       }; 
       res.end(); 
       // kill that timer for the response timing out. 
       clearTimeout(timer); 
     } 
     // when we get data flush it to client 
     emitter.once("new-data", cb); 
     var timer = setTimeout(function() { 
       // too long has passed so remove listener and end response. 
       emitter.removeListener(cb); 
       res.end(); 
     }, 4500); 
    } 
}).listen(8081); 

Una mejor tecnología push sería Server-side events. Vea un example of it here. Esto requiere soporte del navegador (creo que Chrome y la ópera).

Answer 3

Si desea conocer los principios básicos del sondeo largo, intente consultar this article. Resumí algunas partes de mi servidor de encuestas largas, cómo las implementé y el artículo también contiene enlaces a otros recursos. Debería darte al menos una idea más completa de cuánto tiempo funcionan las encuestas.

Si desea aprender la lógica para divertirse con la codificación con node.js, y no utilizar las soluciones existentes, entonces le recomendaría ir paso a paso desde la implementación más simple y básica hasta las más complejas. . No intente construir todo desde la primera toma porque es una de las formas más seguras de fallar.