Les données en continu avec Node.js

Je veux savoir si il est possible de transférer des données à partir du serveur vers le client avec Node.js. Je veux mettre une seule requête AJAX Node.js puis laisser la connexion ouverte et continu de flux de données pour le client. Le client recevra de ce flux et de mise à jour de la page en permanence.

Mise à jour:

Une mise à jour de cette réponse - je ne peux pas obtenir que cela fonctionne. Le response.write n'est pas envoyé avant d'appeler close. J'ai mis en place un exemple de programme que j'utilise pour réaliser ceci:

Node.js:

var sys = require('sys'), 
http = require('http');
http.createServer(function (req, res) {
    res.writeHead(200, {'Content-Type': 'text/html'});
    var currentTime = new Date();
    setInterval(function(){
        res.write(
            currentTime.getHours()
            + ':' + 
            currentTime.getMinutes()
            + ':' +
            currentTime.getSeconds()
        );
    },1000);
}).listen(8000);

HTML: 

<html>
    <head>
        <title>Testnode</title>
    </head>

    <body>
        <!-- This fields needs to be updated -->
        Server time: <span id="time">&nbsp;</span>

        <!-- import jQuery from google -->
        <script type="text/javascript" src="http://ajax.googleapis.com/ajax/libs/jquery/1.4.2/jquery.min.js"></script>

        <!-- import jQuery -->
        <script type="text/javascript">
            $(document).ready(function(){
            //I call here node.localhost nginx ports this to port 8000
                $('#time').load('http://node.localhost');
            });
        </script>
    </body>
</html>

À l'aide de cette méthode, je n'obtenez pas quelque chose de nouveau, jusqu'à ce que j'appelle close(). Est-ce possible ou dois-je aller avec un long sondage approche à la place où j'appelle la fonction de charge de nouveau comme l'un vient vous?

  • Aussi je ne pense pas que ce soit le streaming, c'est juste de la segmentation des trucs en bits. Oui, noeud envoie des éléments de réponse, mais chaque serveur html ne ce. Le streaming de la bonté que vous obtenez de nœud se réfère à quelque chose d'autre.
  • Aussi, dans votre exemple, vous n'avez pas le mettre en pause, reprendre, rincer méthodes. Le (lire) flux est quelque chose qui est en vous donnant des données, aussi vite qu'il le peut (ou aussi vite que vous le pouvez). Et vous lui dites de faire une pause, puis il s'arrête. Et de vous dire de continuer etc.
InformationsquelleAutor Saif Bechan | 2010-04-01
  1. 24

    C'est possible. Utilisez simplement réponse.écrire() plusieurs fois.

    var body = ["hello world", "early morning", "richard stallman", "chunky bacon"];
//send headers
response.writeHead(200, {
  "Content-Type": "text/plain"
});

//send data in chunks
for (piece in body) {
    response.write(body[piece], "ascii");
}

//close connection
response.end();

    Vous pourriez avoir à fermer et rouvrir la connexion toutes les 30 secondes.

    MODIFIER: c'est le code que j'ai réellement testé:

    var sys = require('sys'),
http = require('http');
http.createServer(function (req, res) {
    res.writeHead(200, {'Content-Type': 'text/html'});
    var currentTime = new Date();
    sys.puts('Starting sending time');
    setInterval(function(){
        res.write(
            currentTime.getHours()
            + ':' +
            currentTime.getMinutes()
            + ':' +
            currentTime.getSeconds() + "\n"
        );

        setTimeout(function() {
            res.end();
        }, 10000);

    },1000);
}).listen(8090, '192.168.175.128');

    Je suis connecté en Telnet et son effet donne des fragments de réponse. Mais pour l'utiliser en AJAX navigateur doit prendre en charge XHR.readyState = 3 (réponse partielle). Pas tous les navigateurs prennent en charge ce, pour autant que je sais. Afin de mieux utiliser le temps d'interrogation (ou les Websockets pour Chrome/Firefox).

    EDIT2: Aussi, si vous utilisez nginx comme serveur proxy inverse pour le Nœud, il veut parfois de rassembler tous les morceaux et de les envoyer à l'utilisateur à la fois. Vous avez besoin de ruser.

    • Je suis en train de tester cette approche, mais je vais avoir du mal à accéder à la node.js script creux Ajax sur ma page. Je pense que cela a quelque chose à voir avec une croix domaine de chose. Je vais travailler sur cela plus tard et voir si cela fonctionne comme prévu.
    • J'ai mis à jour la question j'espère que vous pourrez m'aider avec cela.
    • jquery.load attend tous corps d'arriver avant la mise à feu de rappel. Vous avez besoin d'utiliser quelque chose de différent. Voir api.jquery.com/load
    • Avez-vous une idée sur ce genre de choses?
    • Certains bas-niveau stuff, je pense. XMLHTTPRequest peut-être. Tout ce qui peut traiter avec des fragments de réponses.
    • Êtes-vous sûr que cela devrait fonctionner. Ou êtes-vous juste de penser théoriquement, il devrait fonctionner. Parce que j'essaie de le faire en bloc, mais sa viens pas de l'affichage. Le Codage de Transfert est segmenté mais Node.js envoie uniquement lorsque vous appelez à proximité. Autre chose que je devrais utiliser un long sondage de la solution.
    • Je vais vérifier sur mon nœud de la machine (0.1.31)
    • Oui, peut-être longpoll sera mieux.
    • est-il possible de transférer des données binaires?
    • oui, bien sûr.
    • Pour faire de cet échantillon de travail: déplacer "var currentTime = new Date();" dans la fonction setinterval.
    • Est response.close une fonction? Je crois que tu veux dire response.end: nodejs.org/api/http.html#http_response_end_data_encoding
    • C'était en 2012 🙂
    • Ah contexte. 🙂

    InformationsquelleAutor Kuroki Kaze
  2. 16

    Regarder les Sockets.io. Il fournit HTTP/HTTPS en streaming et utilise différents transports pour le faire:

    • WebSocket
    • WebSocket sur Flash (+ XML de sécurité la politique de soutien)
    • XHR Interrogation
    • XHR Multipart Streaming
    • Jamais Iframe
    • JSONP d'Interrogation (pour cross domain)

    Et! Il fonctionne de manière transparente avec Node.JS. C'est aussi un mécanisme national de prévention de package.

    https://github.com/LearnBoost/Socket.IO

    https://github.com/LearnBoost/Socket.IO-node

    • cool, je vais regarder dans ce
    • Socket.IO est inefficace pour cela, car il est à la recherche d'un flux à partir du serveur vers le client. Quelque chose de l'ESS sont parfaits pour.
    • Cette solution m'aide beaucoup. Je voudrais envoyer un flux vidéo de la webcam + microphone audio à partir du serveur vers le client. Comment pourrais-je le faire? stackoverflow.com/questions/27712381/...
    InformationsquelleAutor BMiner
  3. 4

    Vous pouvez également annuler la boucle infinie:

    app.get('/sse/events', function(req, res) {
    res.header('Content-Type', 'text/event-stream');

    var interval_id = setInterval(function() {
        res.write("some data");
    }, 50);

    req.socket.on('close', function() {
        clearInterval(interval_id);
    }); 
});

    Ceci est un exemple de expressjs. Je crois que sans expressjs sera quelque chose comme.

    InformationsquelleAutor Andrey Antukh