Gin（后端）和 Vue3（前端）中实现 Server-Sent Events（SSE）推送

在 Gin（后端）和 Vue3（前端）中实现 Server-Sent Events（SSE）推送，主要分为以下几个步骤：

后端（Gin）实现 SSE

Gin 框架可以使用 c.SSEvent 方法来推送 SSE 事件。

1. 安装 Gin

确保你的 Go 项目已安装 gin：

go get -u github.com/gin-gonic/gin

2. Gin SSE 服务器

创建一个 SSE 端点 /sse，用于持续向前端推送消息：

package mainimport ("fmt""net/http""time""github.com/gin-gonic/gin"
)func main() {r := gin.Default()// SSE 推送r.GET("/sse", func(c *gin.Context) {// 设置 SSE 相关 Headerc.Writer.Header().Set("Content-Type", "text/event-stream")c.Writer.Header().Set("Cache-Control", "no-cache")c.Writer.Header().Set("Connection", "keep-alive")// 监听客户端断开连接notify := c.Writer.CloseNotify()// 模拟持续推送for {select {case <-notify:fmt.Println("客户端断开连接")returndefault:// 发送数据c.SSEvent("message", gin.H{"time": time.Now().Format("15:04:05")})c.Writer.Flush() // 立即刷新time.Sleep(2 * time.Second)}}})r.Run(":8080")
}

前端（Vue3 + Composition API）监听 SSE

Vue3 通过 EventSource 监听 SSE 事件。

1. Vue3 组件实现

创建 SseComponent.vue：

<template><div><h2>SSE 推送数据</h2><p v-if="message">时间：{{ message }}</p><button @click="stopSSE">断开连接</button></div>
</template><script setup>
import { ref, onMounted, onUnmounted } from "vue";let eventSource = null;
const message = ref("");const startSSE = () => {eventSource = new EventSource("http://localhost:8080/sse");eventSource.onmessage = (event) => {const data = JSON.parse(event.data);message.value = data.time;};eventSource.onerror = () => {console.error("SSE 连接错误");eventSource.close();};
};const stopSSE = () => {if (eventSource) {eventSource.close();console.log("SSE 连接已关闭");}
};onMounted(startSSE);
onUnmounted(stopSSE);
</script>