アプリのデータストリームをブラウザにリアルタイムでリダイレクトするにはどうすればいいですか？

Question

私のnode appは、kafkaプロデューサーとconsole.logからストリームをリアルタイムで読むことができます。しかし私は同じ方法（リアルタイム）で私のWebアプリでそれを更新したいと思います。どのように実装できますか？

「node index.js」コマンド（またはnpm start）を使用してアプリケーションを起動します。

index.js：

'use strict'; 
var express = require('express'), 
    app = express(), 
    server, 
    data = []; 
... 

consumer.on('message', function (message) { 
    console.log(message); 
    data.push(message); 
    //global.location.reload(); 
}); 

... 

app.get('/', function(req, res){ 
    res.send(data); 
}); 

server = app.listen(3002, function(){ 
    console.log('Listening on port 3002'); 
}); 

私はres.send(data)を変更したり、on('message')イベントにコードを追加することを必要とする、と思います。

Answer 1

クライアントとサーバーの間の接続を維持する必要があります。 このsocket.ioパッケージを試すと、リアルタイムでメッセージが更新されます。