这是使用SSE（服务器发送的事件）的完整示例。这适用于Firefox，也可能适用于Chrome：
var cp = require("child_process"), express = require("express"), app = express();app.configure(function(){ app.use(express.static(__dirname));});app.get('/msg', function(req, res){ res.writeHead(200, { "Content-Type": "text/event-stream", "Cache-control": "no-cache" }); var spw = cp.spawn('ping', ['-c', '100', '127.0.0.1']), str = ""; spw.stdout.on('data', function (data) { str += data.toString(); // just so we can see the server is doing something console.log("data"); // Flush out line by line. var lines = str.split("n"); for(var i in lines) { if(i == lines.length - 1) { str = lines[i]; } else{ // Note: The double-newline is *required* res.write('data: ' + lines[i] + "nn"); } } }); spw.on('close', function (pre) { res.end(str); }); spw.stderr.on('data', function (data) { res.end('stderr: ' + data); });});app.listen(4000);和客户端HTML：
<!DOCTYPE Html><html> <body> <ul id="eventlist"> </ul> <script> var eventList = document.getElementById("eventlist"); var evtSource = new EventSource("http://localhost:4000/msg"); var newElement = document.createElement("li"); newElement.innerHTML = "Messages:"; eventList.appendChild(newElement); evtSource.onmessage = function(e) { console.log("received event"); console.log(e); var newElement = document.createElement("li"); newElement.innerHTML = "message: " + e.data; eventList.appendChild(newElement); }; evtSource.onerror = function(e) { console.log("EventSource failed."); }; console.log(evtSource); </script></body></html>运行
node index.js并将您的浏览器指向
http://localhost:4000/client.html。请注意，由于我正在运行OSX，因此必须使用“ -c”选项而不是“ -n”。
