当前位置：首页 > news >正文

使用Server-Sent Events (SSE)，并获取message里面的内容

news 2026/2/9 10:34:05

什么是Server-Sent Events (SSE)?

Server-Sent Events (SSE)是一种服务器推送技术，允许服务器向客户端（浏览器）发送实时消息。与WebSocket不同，SSE是单向通信，只能从服务器到客户端。SSE在HTML5中作为标准实现，并且被大多数现代浏览器支持。

SSE的优势

简单易用：SSE API简单，易于理解和实现。
自动重连：浏览器会在连接断开时自动尝试重新连接。
HTTP协议：SSE基于HTTP协议，易于与现有的Web架构和安全模型集成。

如何在前端使用SSE

1. 创建SSE连接

在JavaScript中，我们使用EventSource接口创建到服务器的SSE连接。

const eventSource = new EventSource('your-sse-endpoint');

2. 监听消息

一旦创建了EventSource实例，我们就可以监听从服务器发送的消息。

eventSource.onmessage = function(event) {const data = event.data;// 处理接收到的数据
};

3. 处理不同类型的事件

服务器可以发送不同类型的事件，客户端可以选择监听特定类型的事件。

eventSource.addEventListener('message-type', function(event) {const data = event.data;// 处理特定类型的事件
});

4. 关闭连接

当不再需要接收事件时，可以关闭连接。

eventSource.close();

在Vue.js中使用SSE

在Vue.js应用程序中使用SSE，我们可以在组件的生命周期钩子中创建和管理SSE连接。

示例代码

以下是一个Vue组件的示例，展示了如何使用SSE连接并处理接收到的消息。

<template><div><h1>实时消息</h1><ul><li v-for="message in messages" :key="message.id">{{ message.content }}</li></ul></div>
</template><script>
export default {data() {return {messages: [],eventSource: null};},created() {this.connectToSSE();},beforeDestroy() {if (this.eventSource) {this.eventSource.close();}},methods: {connectToSSE() {this.eventSource = new EventSource('/sse-endpoint');this.eventSource.onmessage = (event) => {const message = JSON.parse(event.data);this.messages.push(message);};this.eventSource.onerror = (error) => {console.error('SSE error:', error);this.eventSource.close();};}}
};
</script>

在这个例子中，我们在created钩子中创建了SSE连接，并在beforeDestroy钩子中关闭了它。我们监听onmessage事件来接收消息，并将其添加到messages数组中，这样它们就可以在模板中显示。

处理JSON消息

通常，服务器会发送JSON格式的消息。我们可以使用JSON.parse来解析这些消息。

this.eventSource.onmessage = (event) => {const message = JSON.parse(event.data);// 处理JSON消息
};

错误处理

在实际应用中，我们需要处理可能发生的错误，例如网络问题或服务器错误。

this.eventSource.onerror = (error) => {console.error('SSE error:', error);// 可以在这里尝试重新连接或通知用户
};

结论

SSE是一种强大的技术，可以在不需要复杂协议的情况下实现实时通信。在前端应用程序中使用SSE可以为用户提供即时的更新和通知。