Node.jsでServer Sentイベントを実装する簡単な方法は？

Question

Node.jsでSSEを実装するすべての方法がより複雑なコードで行われているように見えますが、SSEを送受信する簡単な方法があるようです。これを簡単にするAPIまたはモジュールはありますか？

Answer 1

あなたはSocket.ioを使用してこのようなことを行うことができるはずです。まず、npm install socket.ioでインストールする必要があります。クライアント上の

var express = require('express'); 
var app = express(); 
var server = require('http').createServer(app); 
var io = require('../..')(server); 
var port = process.env.PORT || 3000; 

server.listen(port, function() { 
    console.log('Server listening at port ' + port); 
}); 

app.use(express.static(__dirname + '/public')); 

io.on('connection', function (socket) { 
    socket.emit('EVENT_NAME', {data}); 
}); 

そして、このような何か：

そこから、あなたのコードでは、あなたはあなたがサーバー上でこのようなものを使用することができ more in-depth examples given by Socket.IO

見ることができますvar io = require(socket.io);

を持っていることになるでしょう

<script src="socket_src_file_path_here"></script> 
<script> 
    var socket = io('http://localhost'); 
    socket.on('EVENT_NAME', function (data) { 
    console.log(data); 
    //Do whatever you want with the data on the client 
    }); 
</script> 

Answer 2

サーバーから送信されるイベントはかなりシンプルです。ちょうどそれについての私の2つの部分のブログ記事を見てください。

1. http://bayn.es/real-time-web-applications-with-server-sent-events-pt-1/
2. http://bayn.es/real-time-web-apps-with-server-sent-events-pt-2/

Answer 3

node.jsでSSEの実装が見つかりました。

Githubのリンク：https://github.com/einaros/sse.js

NPMモジュール：https://www.npmjs.com/package/sse

ウィル上記のリンクはあなたを助けますか？

Answer 4

**client.js** 

var eventSource = new EventSource("/route/events"); 
eventSource.addEventListner("ping", function(e){log(e.data)}); 

//if no events specified 
eventSource.addEventListner("message", function(e){log(e.data)}); 

**server.js** 

http.createServer((req, res)=>{ 

    if(req.url.indexOf("/route/events")>=){ 

     res.setHeader('Connection', 'keep-alive'); 

     res.setHeader("Cache-Control", "no-cache"); 

     res.setHeader("Content-Type", "text/event-stream"); 

     let event = "event: ping"; 

     let id = `id: ${Date.now()}`; 

     let data = { 
     message:`hello @${new Date().toString()}` 
     } 

     data = "data: "+JSON.stringify(data); 

     res.end(`${event}\n${id}\n${data}\n\n`); 
    } 
}).listen(PORT)