¿Cómo integrar nodeJS + Socket.IO y PHP?

Recientemente he estado buscando para encontrar una buena manera de comunicarme entre nodeJS y PHP. Aquí está la idea: nodeJS es todavía bastante nuevo y puede ser complicado desarrollar una aplicación completa solo con él. Además, es posible que solo lo necesite para un módulo de su proyecto, como notificaciones en tiempo real, chat, ... Y desea administrar todas las demás cosas con PHP, porque probablemente sea más fácil para usted (y puede aprovechar los marcos existentes, como CodeIgniter o Symfony).

Me gustaría tener una solución fácil; No quiero usar cURL o un tercer servidor para comunicarme entre los servidores Apache y Node. Lo que quiero es poder capturar eventos del nodo en Javascript simple, del lado del cliente.

No encontré ninguna respuesta que estuviera completa, la mayor parte del tiempo el lado del cliente se ejecutaba en el servidor de nodo y, por lo tanto, no es aplicable en mi caso. Así que rastreé todos los temas posibles y finalmente encontré mi respuesta; Intentaré compartir esto y tener un punto en el que todo esté claro.

¡Espero que esto pueda ayudar a algunas personas! ;)

Entonces, para empezar, puse mi proyecto en github, si quieres acceder al código completo: https://github.com/jdutheil/nodePHP

Es un proyecto de ejemplo muy simple: un chat web. Solo tiene un autor y un mensaje, y cuando presiona enviar, se guarda en una base de datos mysql. La idea es enviar actualizaciones en tiempo real y tener una conversación real. ;) Usaremos nodeJS para eso.

No hablaré de código PHP, es realmente simple y no es interesante aquí; lo que quiero mostrarte es cómo integrar tu código nodeJS.

Yo uso express y Socket.IO, así que asegúrese de instalar esos módulos con npm. Luego, creamos un servidor nodeJS simple:

var socket = require( 'socket.io' );
var express = require( 'express' );
var http = require( 'http' );

var app = express();
var server = http.createServer( app );

var io = socket.listen( server );

io.sockets.on( 'connection', function( client ) {
    console.log( "New client !" );

    client.on( 'message', function( data ) {
        console.log( 'Message received ' + data.name + ":" + data.message );

        io.sockets.emit( 'message', { name: data.name, message: data.message } );
    });
});

server.listen( 8080 );

Registramos nuestra devolución de llamada de eventos cuando se conecta un nuevo usuario; cada vez que recibimos un mensaje (representa un mensaje de chat), lo transmitimos a todos los usuarios conectados. Ahora, la parte complicada: ¡del lado del cliente! Esa es la parte que me tomó la mayor parte del tiempo, porque no sabía qué script incluir para poder ejecutar el código Socket.IO sin el nodeServer (porque la página del cliente será servida por Apache).

Pero todo ya está hecho; cuando instala el módulo Socket.IO con npm, hay un script disponible en /node_modules/socket.io/node_modules/socket.io-client/dist/socket.io.js; que el script lo incluiremos en nuestra página PHP, en mi caso:

    <script src="js/node_modules/socket.io/node_modules/socket.io-client/dist/socket.io.js"></script>
    <script src="js/nodeClient.js"></script>

Y para finalizar, mi nodeClient.js, donde simplemente nos conectamos al servidor de nodos y esperamos a que el evento actualice nuestra página. ;)

var socket = io.connect( 'http://localhost:8080' );

$( "#messageForm" ).submit( function() {
    var nameVal = $( "#nameInput" ).val();
    var msg = $( "#messageInput" ).val();

    socket.emit( 'message', { name: nameVal, message: msg } );

    // Ajax call for saving datas
    $.ajax({
        url: "./ajax/insertNewMessage.php",
        type: "POST",
        data: { name: nameVal, message: msg },
        success: function(data) {

        }
    });

    return false;
});

socket.on( 'message', function( data ) {
    var actualContent = $( "#messages" ).html();
    var newMsgContent = '<li> <strong>' + data.name + '</strong> : ' + data.message + '</li>';
    var content = newMsgContent + actualContent;

    $( "#messages" ).html( content );
});

Intentaré actualizar y mejorar mi código lo antes posible, ¡pero creo que ya está abierto a todas las cosas interesantes! Estoy realmente abierto a recibir consejos y reseñas sobre este tema, ¿es la buena manera de hacerlo?

¡Espero que esto pueda ayudar a algunas personas!

Tengo otra solución que me funciona bastante bien, pero me gustaría que alguien comentara qué tan efectiva es, ya que (todavía) no he tenido la oportunidad / tiempo de probarla en el servidor real.

Aquí va el código node-js. Puse este código en un archivo llamado nodeserver.js:

var http = require('http');

http.createServer(function (req, res) {
    res.writeHead(200, {'Content-Type': 'text/html'});

    var knall = new Object();
    knall.totten = "4 tomtar";
    knall.theArr = new Array();
    knall.theArr.push("hoppla")
    knall.theArr.push("hej")
    var strKnall = JSON.stringify(knall);

    res.end(strKnall);
}).listen(process.env.PORT);  

Y aquí está el fragmento de código simple en php, llamando al servidor node-js con la ayuda de file_get_contents ():

$json = file_get_contents('http://localhost:3002/knall.json');
$obj = json_decode($json);

Funciona muy bien, cuando cargo la página php, a su vez llama a la página nodeserver.js, que jsonifica el objeto knall.

Tengo dos instalaciones de host local ejecutándose en iis en Windows 10, un servidor php estándar y el servidor nodejs funciona con el iisnode ordenado paquete .

El servidor 'real' se ejecuta en ubuntu.

Creo que esta es una solución fácil y ordenada para la comunicación entre dos servidores, pero tal vez alguien tenga algún comentario al respecto.

Pruebe algo similar o puede consultar mi blog para obtener un código de muestra completo en nodejs

En el lado de su página:

• Toma de carga JS

https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.2.0/socket.io.js

• Hacer objeto del enchufe

var socket = io ();

• Utilice la emitfunción para enviar datos a nodeserver.

socket.emit ('nueva_notificación', {
mensaje: 'mensaje',
título: 'título',
icono: 'icono',
});

Así que ahora tu código se verá como

<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.2.0/socket.io.js"></script>

var socket = io(); 

$(document).ready(function($) {
  $('.rules-table').on('click', '.runRule', function(event) {
    event.preventDefault();
    /* Act on the event */
    var ruleID = $(this).parents('tr').attr('id');

    // send notification before going to post 
    socket.emit('new_notification', {
        message: 'Messge is ready to sent',
        title: title,
        icon: icon,
    });
    $.ajax({
      url: '/ajax/run-rule.php',
      type: 'POST',
      dataType: 'json',
      data: {
        ruleID: ruleID
      },
    })
    .done(function(data) {
      console.log(data);

      // send notification when post success 
      socket.emit('new_notification', {
        message: 'Messge was sent',
        title: title,
        icon: icon,
      });

    })
    .fail(function() {
      console.log("error");

      // send notification when post failed 
      socket.emit('new_notification', {
        message: 'Messge was failed',
        title: title,
        icon: icon,
      });
    })
    .always(function() {
      console.log("complete");
    });

  });
});

Ahora, en el lado del servidor de Nodo, haga un controlador para su solicitud para obtener su solicitud y envíe un mensaje a todos los dispositivos / navegadores conectados (server.js)

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);

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


io.on('connection', function (socket) {
  socket.on( 'new_notification', function( data ) {
    console.log(data.title,data.message);

    // Now Emit this message to all connected devices
    io.sockets.emit( 'show_notification', { 
      title: data.title, 
      message: data.message, 
      icon: data.icon, 
    });
  });
});

http.listen(3000, function() {
   console.log('listening on localhost:3000');
});

Ahora el lado del cliente / navegador / cliente crea un receptor para recibir el mensaje de socket del servidor del nodo

<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.2.0/socket.io.js"></script>   

var socket = io();

/**
 * Set Default Socket For Show Notification
 * @param {type} data
 * @returns {undefined}
 */
socket.on('show_notification', function (data) {
    showDesktopNotification(data.title, data.message, data.icon);
});
/**
 * Set Notification Request
 * @type type
 */
function setNotification() {
    showDesktopNotification('Lokesh', 'Desktop Notification..!', '/index.jpeg');
    sendNodeNotification('Lokesh', 'Browser Notification..!', '/index.jpeg');
}
/**
 * Check Browser Notification Permission
 * @type window.Notification|Window.Notification|window.webkitNotification|Window.webkitNotification|Window.mozNotification|window.mozNotification
 */
var Notification = window.Notification || window.mozNotification || window.webkitNotification;
Notification.requestPermission(function (permission) {
});
/**
 * Request Browser Notification Permission 
 * @type Arguments
 */
function requestNotificationPermissions() {
    if (Notification.permission !== 'denied') {
        Notification.requestPermission(function (permission) {
        });
    }
}
/**
 * Show Desktop Notification If Notification Allow
 * @param {type} title
 * @param {type} message
 * @param {type} icon
 * @returns {undefined}
 */
function showDesktopNotification(message, body, icon, sound, timeout) {
    if (!timeout) {
        timeout = 4000;
    }
    requestNotificationPermissions();
    var instance = new Notification(
            message, {
                body: body,
                icon: icon,
                sound: sound
            }
    );
    instance.onclick = function () {
        // Something to do
    };
    instance.onerror = function () {
        // Something to do
    };
    instance.onshow = function () {
        // Something to do
    };
    instance.onclose = function () {
        // Something to do
    };
    if (sound)
    {
        instance.sound;
    }
    setTimeout(instance.close.bind(instance), timeout);
    return false;
}