Я пытаюсь добавить SSE (события, отправленные сервером) в NodeJs, но когда я отправляю ответ, используя res.write()
, данные не отправляются, а только после записи res.end()
все данные отправляются на в то же время.
Я уже нашел много сообщений на Github, StackOverflow, касающихся этой проблемы и везде, где упоминается использование res.flush()
после каждого res.write()
, но это тоже не работает для меня, также я не использую любой модуль сжатия явно.
Код на стороне сервера
Может кто-нибудь, пожалуйста, скажите мне, есть ли способ, которым я могу сделать эту работу.
const express = require('express')
const app = express()
app.use(express.static('public'))
app.get('/countdown', function(req, res) {
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
})
countdown(res, 10)
})
function countdown(res, count) {
res.write("data: " + count + "\n\n")
if (count)
setTimeout(() => countdown(res, count-1), 1000)
else
res.end()
}
app.listen(3000, () => console.log('SSE app listening on port 3000!'))
Код на стороне клиента
<html>
<head>
<script>
if (!!window.EventSource) {
var source = new EventSource('/countdown')
source.addEventListener('message', function(e) {
document.getElementById('data').innerHTML = e.data
}, false)
source.addEventListener('open', function(e) {
document.getElementById('state').innerHTML = "Connected"
}, false)
source.addEventListener('error', function(e) {
const id_state = document.getElementById('state')
if (e.eventPhase == EventSource.CLOSED)
source.close()
if (e.target.readyState == EventSource.CLOSED) {
id_state.innerHTML = "Disconnected"
}
else if (e.target.readyState == EventSource.CONNECTING) {
id_state.innerHTML = "Connecting..."
}
}, false)
} else {
console.log("Your browser doesn't support SSE")
}
</script>
</head>
<body>
<h1>SSE: <span id="state"></span></h1>
<h3>Data: <span id="data"></span></h3>
</body>
</html>
Решение - я использовал nginx для обратного прокси-сервера, поэтому это происходило, поэтому я попробовал это решение, и оно работало :)
EventSource / Отправленные сервером события через Nginx