Weblabor

Szeretném veletek megosztani a Node.js-sel és websockettel szerzett tapasztalataimat. Olyan rendszert szerettem volna készíteni, ahol a felület interaktívan frissül, mint a Facebooké üzenet érkezésekor.

Elkészítettem hát a saját megoldásomat, ami kezdetben egy setInterval()-lal meghívott AJAX hívással valósult meg. Sajnos hamar be kellett lássam, hogy ha a webszervert és az adatbázist nem szeretném feleslegesen halálra terhelni, akkor ki kell találjak valami más megoldást. Az első és egyben legegyszerűbb a setInterval() kellően nagy értékre való állítása lett volna, de így a felhasználói élmény romlott volna.

Az elmúlt hetekben ismerkedtem meg a Node.js-sel. Webfejlesztőként viszonylag kis energia befektetés volt szükséges a használatának elsajátításához, hiszen a JavaScript szintakszisa és logikája már ismert számomra. (Gondolom sokunk van még így ezzel.) Alacsony memóriaigénye van, gyors, pont megfelel a célra. Először arra gondoltam, az AJAX kéréseket Node-dal szolgálom ki, így spórolok egy kis erőforrást, de végül arra jutottam, jobb ha a kapcsolódási idő és a setInerval() miatti késleltetést is elkerülöm.

A long polling és a websocket közül én az utóbbi megoldást választottam, ez volt a szimpatikusabb, egyszerűbb, azonban egy probléma felmerült, mégpedig a támogatottság kérdése, ugyanis nem mindegyik böngésző implementálta még a websocketet. Hosszas mérlegelés után arra jutottam, hogy ha egy böngésző nem támogatja, akkor nem lesz azonnali a frissítés, csak következő oldal betöltéskor változnak az adatok. Mivel egy asztali programot vált ki az alkalmazás, ezért úgy gondoltam, tehetek kivételt.

A kliens oldali kód:

var connection = null;

window.WebSocket = window.WebSocket || window.MozWebSocket;

if (!window.WebSocket) {
    return false;
}

connection = new WebSocket("ws://127.0.0.1:8000");

connection.onopen = function () {
    console.log("Connection established");
};

connection.onerror = function (error) {
    console.log("An error occured");
    console.log(error);
};

connection.onmessage = function (message) {
    try {
        console.log(message.data);
        var json = JSON.parse(message.data);
        
        …
        
    } catch (e) {
        console.log("This does not look like valid JSON: ", message.data);
        return;
    }
};

var errorIntervalCh = setInterval(function () {
    if (connection.readyState !== 1) {
        console.log("Unable to communicate to websocket.");
        clearInterval(errorIntervalCh);
    }
}, 3000);

A szerveroldali kód:

var http = require("http").createServer(function (request, response) {});
var ws   = new (require("websocket").server)({httpServer: http});

var port = 8000;
var clients = new Array();

http.listen(port, function () {});
console.log("Websocket server is running on " + port);

process.on("SIGHUP", function () {
    console.log("Sighup event triggered");
    
    …
    
    for (var i in clients) {
        clients[i].sendUTF(JSON.stringify({ … }));
    }
});

ws.on("request", function (request) {
    var connection = request.accept(null, request.origin);
    
    console.log("User connected");
    
    …
    
    clients.push(connection);
    
    connection.on("message", function(message) { … });
    
    connection.on("close", function (connection) {
        clients.splice(clients.indexOf(connection), 1);
        console.log("User disconnected");
    });
});

A következő probléma az adatbázis-terhelés volt: jó lenne csak akkor lekérdezni, ha történt az adatbázisba írás, ilyenkor kellene valami, ami arra készteti a Node-ot, hogy nézze meg, van-e mit küldeni. Ezekre MySQL-ben remek triggereket lehet írni, de a Node ettől még nem tudja, hogy ellenőrizni kellene.

Az egyik nagy terheléses cikkben olvastam, hogy szignállal fel lehet kelteni egy démont. Pont ez kell nekem, egy SIGHUP segítségével megkérjük a Node-ot, hogy ébredjen fel, és tegye a dolgát. Már csak valahogy meg kellene szólaltatni a szignált. A MySQL ad lehetőséget saját, C-ben írt függvény definiálására, de én nem szerettem volna ilyet írni, szerintem más sem. Egy egyszerű exec() kellett, amire találtam is egy kész megoldást. A plugin jól működik, azonban biztonsági kockázatot rejt magában: bárki számára elérhető lesz az operációs rendszer! Ha többen használják a MySQL szervert, érdemes saját plugint írni erre a célra.

delimiter $$
CREATE TRIGGER nodetrigger
AFTER INSERT ON message FOR EACH ROW
BEGIN
SET @S = (SELECT sys_exec('kill -HUP `pidof node`'));
END$$
delimiter ;

Már csak egy probléma maradt, a jogosultság. Ahhoz hogy mysql felhasználó SIGHUP-ot küldhessen a Node-nak, a Node szerverünket a mysql felhasználóval kell futtassuk:

sudo -u mysql node websocket.salvus.node.js

A dolog még teszt fázisban van, de szépen teszi a dolgát. Sokat gondolkoztam, hogy van-e egyszerűbb, jobb megoldás, esetleg van-e valamilyen rejtett biztonsági kockázat a dologban, de eddig nem sikerült találnom.