我正在使用 MEAN 并尝试从服务器端接收事件。为此，我使用了 EventSource，但它不起作用。
我看到连接是如何打开的，但我没有从服务器收到任何消息。我可以在 Node 控制台中看到消息是如何发送的，但在客户端(浏览器控制台)什么也看不到。
我有点迷茫，因为我正在学习我找到的所有教程，但使用完全相同的代码却行不通。
在客户端，这是我的 AngularJS 代码:
var source = new EventSource('/api/payments/listen');
source.addEventListener('open', function(e) {
console.log('CONNECTION ESTABLISHED');
}, false);
source.addEventListener('message', function (e) {
$scope.$apply(function () {
console.log('NOTIFICATION');
console.log(e.data);
});
}, false);
source.onmessage = function (e) {
console.log('NOTIFICATION!');
console.log(e);
};
source.addEventListener('error', function(e) {
if (e.readyState === EventSource.CLOSED) {
console.log('CONNECTION CLOSED');
}
}, false);
服务器端代码:
exports.listen = function (req, res) {
if (req.headers.accept && req.headers.accept === 'text/event-stream') {
if ( req.url === '/api/payments/listen' ) {
sendSSE(req, res);
}
else {
res.writeHead(404);
res.end();
}
}
else
res.end();
};
function sendSSE(req, res) {
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
var id = (new Date()).toLocaleTimeString();
// Sends a SSE every 5 seconds on a single connection.
setInterval(function() {
constructSSE(res, id, data);
}, 5000);
constructSSE(res, id, data);
}
function constructSSE(res, id, data) {
res.write('id: ' + id + '\n');
res.write('data: ' + JSON.stringify(data) + '\n\n');
}
有什么建议吗？有什么建议吗？
编辑
我不知道是什么导致了这个问题，但我已经使用 Simple-SSE 让它工作了，这是一个用于服务器端事件的有用的小型库。
现在，它按预期工作。
这是给想试一试的人的链接: https://github.com/Lesterpig/simple-sse
谢谢 =)
最佳答案
希望这对遇到与我相同问题的任何人有所帮助。在无法从服务器接收消息之后，我想到了这个问题，尽管我的代码中的所有内容似乎都完全符合预期。在看到这个库对我有所帮助后，我深入研究了源代码并找到了我的答案。如果您正在使用任何压缩库，例如我在我的 express 应用程序中，您需要在写入后刷新响应。否则压缩不会像协议(protocol)预期的那样发送消息。例如 res.write("数据:hi\n\n") res.flush()
关于javascript - 服务器端事件 (SSE) 未到达客户端，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40304985/