SSE基于HTTP实现服务端向浏览器的单向实时推送,使用EventSource API建立连接,服务端以text/event-stream格式持续发送数据,支持自动重连与自定义事件,适合通知类低频实时场景。

Server-Sent Events(SSE)是一种让服务器主动向浏览器推送数据的技术,基于HTTP协议,使用简单,适合实时性要求不高的场景,比如通知、状态更新或实时日志展示。它比WebSocket轻量,且天然支持文本数据的有序传输。
基本原理
SSE 建立在标准 HTTP 之上,客户端通过 EventSource API 发起连接,服务端保持连接不关闭,并以特定格式持续发送数据。每次推送的消息都会触发客户端的 message 事件。
关键特点:
单向通信:仅服务端推送到客户端 自动重连:断开后客户端会尝试重新连接 支持自定义事件类型 数据格式为 text/event-stream
前端实现
使用原生 EventSource 即可监听服务端推送:
const eventSource = new EventSource(‘/api/sse’);
eventSource.onmessage = function(event) {
console.log(‘收到消息:’, event.data);
};
eventSource.onerror = function(err) {
console.error(‘SSE 连接出错’, err);
};
// 可监听自定义事件
eventSource.addEventListener(‘customEvent’, function(event) {
console.log(‘自定义事件:’, event.data);
});
后端实现(Node.js 示例)
服务端需设置正确的响应头,并持续输出符合 SSE 格式的数据:
app.get(‘/api/sse’, (req, res) => {
// 设置响应头
res.writeHead(200, {
‘Content-Type’: ‘text/event-stream’,
‘Cache-Control’: ‘no-cache’,
‘Connection’: ‘keep-alive’
});
// 发送普通消息
setInterval(() => {
res.write(`data: ${Date.now()}nn`);
}, 1000);
// 发送自定义事件
setInterval(() => {
res.write(`event: customEventndata: {“msg”: “hello”}nn`);
}, 5000);
// 客户端断开时清理
req.on(‘close’, () => {
res.end();
});
});
SSE 数据格式说明
每条消息由一个或多个字段组成,常见字段包括:
data: 消息内容,可多行,以 nn 结尾 event: 自定义事件名称,对应前端 addEventListener 的类型 id: 消息ID,用于断线重连时定位位置 retry: 重连间隔毫秒数
示例:
event: userUpdate
data: {“id”: 123, “status”: “online”}
id: 456
retry: 3000
nn
基本上就这些。只要前后端遵守 SSE 协议格式,就能轻松实现实时推送。相比轮询更高效,比 WebSocket 更简单,适合大多数通知类场景。注意连接长时间保持可能受代理或Nginx配置影响,需调整超时设置。
以上就是怎样利用Server-Sent Events实现服务端推送功能?的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1523212.html
微信扫一扫
支付宝扫一扫