如何从express.js发送“文本/事件流”数据?

Rob*_*and 1 javascript node.js express server-sent-events

尝试在服务器端使用express.js 获取基本的服务器发送事件:

index.js:

const app        = require('express')();
const index_html = require('path').join(__dirname, 'index.html');

app.get('/', (req, res) =>
{
    res.sendFile(index_html);
});

app.get('/data', (req, res) =>
{
    res.header('Cache-Control', 'no-cache');
    res.header('Content-Type', 'text/event-stream');

    setInterval(() =>
    {
        res.write(new Date().toISOString() + '\n\n');
    }, 1000);
});

app.listen('7000');
Run Code Online (Sandbox Code Playgroud)

index.html:

<!doctype html>
<head>
    <title>Hello World</title>
</head>
<body>
    <h1 id='result'>No Data Yet</h1>
    <script>
    var source = new EventSource('data');
    source.onmessage = function(event)
    {
        console.log('invoked');
        document.getElementById('result').innerHTML = event.data + '<br>';
    };
    </script>
</body>
Run Code Online (Sandbox Code Playgroud)

永远source.onmessage不会触发。

Jar*_*a X 6

服务器端事件需要以特定(文本)格式发送数据,具体来说,发送数据,需要一行格式的文本

data: text to send goes here
Run Code Online (Sandbox Code Playgroud)

单个事件中的其他类型的数据可以是type, id, 和retry

任何不以以下内容开头的行

data:
type:
id:
retry:
Run Code Online (Sandbox Code Playgroud)

忽略,因此您没有收到任何事件

简单的改变

setInterval(() =>
{
    res.write('data: ' + new Date().toISOString() + '\n\n');
}, 1000);
Run Code Online (Sandbox Code Playgroud)

不过,我会这样写

    setInterval(() => res.write(`data: ${new Date().toISOString()}\n\n`), 1000);
Run Code Online (Sandbox Code Playgroud)

进一步阅读MDN 文档