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

用Go实现 SSE 实时推送消息(消息通知)——思悟项目技术4

news 2026/5/14 5:49:40

目录

简介

工作原理

例子

使用场景

简介

SSE（Server - Sent Events）是一种允许服务器向客户端实时推送更新的 Web 技术。是一种基于 HTTP 协议的单向通信机制，服务器可以在客户端建立连接后，持续不断地向客户端发送事件流。客户端只需发起一次请求，服务器就能随时向客户端推送新的数据，无需客户端反复请求。

工作原理

  1. 客户端发起请求：客户端通过创建一个 EventSource 对象（在浏览器环境中）向服务器发起一个 HTTP 请求，请求的响应头中 Content - Type 为 text/event - stream。
  2. 服务器建立连接：服务器接收到请求后，与客户端建立长连接，保持连接处于打开状态。
  3. 服务器推送数据：服务器可以在有新数据时，将数据以特定的格式（事件流格式）发送给客户端。事件流由多个事件组成，每个事件包含事件类型、数据等信息。
  4. 客户端接收数据：客户端的 EventSource 对象会持续监听服务器发送的事件流，当接收到新事件时，会触发相应的事件处理函数。

    例子

    后端（Go + Gin）:

    POST /send 端点是用于接收前端发送的消息并广播到所有 SSE 客户端，它的作用是触发消息的推送。

    而 for msg := range client 这部分代码是具体执行消息推送的逻辑，它确保 SSE 连接的客户端能够实时收到消息。

    package mainimport ("fmt""net/http""sync""time""github.com/gin-gonic/gin"
)type Client chan stringvar (clients   = make(map[Client]bool) // 记录所有 SSE 连接clientsMu sync.Mutex              // 保护 clients 并发访问
)func main() {r := gin.Default()// SSE 端点：用于客户端接收推送r.GET("/stream", func(c *gin.Context) {client := make(Client, 10) // 创建一个带缓冲的通道clientsMu.Lock()clients[client] = true // 添加新客户端clientsMu.Unlock()// 设置 SSE 头部c.Header("Content-Type", "text/event-stream")c.Header("Cache-Control", "no-cache")c.Header("Connection", "keep-alive")// 监听消息通道// 监听 SSE（Server-Sent Events） 连接的消息通道，并将新消息推送到客户端。它实现了 服务器端的推送机制。for msg := range client {fmt.Fprintf(c.Writer, "data: %s\n\n", msg)c.Writer.Flush()}})// 发送消息端点：接收前端消息，并推送给所有客户端r.POST("/send", func(c *gin.Context) {var json struct {Message string `json:"message"`}if err := c.ShouldBindJSON(&json); err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})return}// 发送消息到所有 SSE 客户端broadcast(json.Message)c.JSON(http.StatusOK, gin.H{"status": "sent"})})r.GET("/", func(c *gin.Context) {c.Header("Content-Type", "text/html")c.String(http.StatusOK, htmlContent)})r.Run(":8080")
}// 发送消息给所有已连接的 SSE 客户端
func broadcast(message string) {clientsMu.Lock()defer clientsMu.Unlock()for client := range clients {select {case client <- fmt.Sprintf("%s - %s", message, time.Now().Format("15:04:05")):default:close(client)           // 关闭不可用的客户端delete(clients, client) // 从列表中移除}}
}const htmlContent = `<!DOCTYPE html>
<html lang="zh">
<head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>SSE 实时消息</title>
</head>
<body><h2>Server-Sent Events (SSE) 消息推送</h2><input type="text" id="messageInput" placeholder="输入消息"><button onclick="sendMessage()">发送消息</button><h3>收到的消息：</h3><div id="messages"></div><script>// 监听 SSE 事件const eventSource = new EventSource("/stream");eventSource.onmessage = function(event) {const div = document.createElement("div");div.textContent = "收到：" + event.data;document.getElementById("messages").appendChild(div);};// 发送消息到后端function sendMessage() {const message = document.getElementById("messageInput").value;if (!message) return;fetch("/send", {method: "POST",headers: { "Content-Type": "application/json" },body: JSON.stringify({ message: message })}).then(response => response.json()).then(data => console.log("消息已发送:", data));}</script>
</body>
</html>`

    结果：

    使用场景

    • 实时新闻更新：新闻网站可以使用 SSE 实时向用户推送最新的新闻消息。
    • 股票行情推送：金融类应用可以利用 SSE 实时更新股票价格、交易信息等。
    • 在线聊天系统的消息通知：当有新消息时，服务器可以及时将消息推送给客户端。

    相关文章：

    用Go实现 SSE 实时推送消息(消息通知)——思悟项目技术4

    目录 简介 工作原理 例子 使用场景 简介 SSE&#xff08;Server - Sent Events&#xff09;是一种允许服务器向客户端实时推送更新的 Web 技术。是一种基于 HTTP 协议的单向通信机制&#xff0c;服务器可以在客户端建立连接后&#xff0c;持续不断地向客户端发送事件流。客…...

    编程日记 2025/2/13 1:48:14

    0基础租个硬件玩deepseek,蓝耘元生代智算云|本地部署DeepSeek R1模型

    前言&#xff1a;哈喽&#xff0c;大家好&#xff0c;今天给大家分享一篇文章&#xff01;并提供具体代码帮助大家深入理解&#xff0c;彻底掌握&#xff01;创作不易&#xff0c;如果能帮助到大家或者给大家一些灵感和启发&#xff0c;欢迎收藏关注哦 &#x1f495; 目录 0基础…...

    编程日记 2025/2/13 1:47:12

    vue3：动态渲染后端返回的图片

    问&#xff1a; div classleft-png 这里我用css设置了他的背景图片&#xff0c;但是现在我希望改为后端返回的图片&#xff0c;怎么写&#xff1f; 后端返回数据&#xff1a; const centerdata {img:;xxxx,title,xxxx,num:xxxx}&#xff1f; 回答&#xff1a; 好的&#xff…...

    编程日记 2025/2/13 1:45:10

    DeepSeek小白初识指南

    1.什么是DeepSeek&#xff1f; DeepSeek是一个基于大语言模型&#xff08;LLM&#xff09;的智能助手&#xff0c;能够处理自然语言理解、生成、对话等任务。它广泛应用于聊天机器人、内容生成、数据分析等领域。 2.DeepSeek和OpenAI等大模型差异&#xff1f; 虽然DeepSeek和Op…...

    编程日记 2025/2/13 1:43:07

    图像锐化（QT）

    如果不使用OpenCV&#xff0c;我们可以直接使用Qt的QImage类对图像进行像素级操作来实现锐化。锐化算法的核心是通过卷积核&#xff08;如拉普拉斯核&#xff09;对图像进行处理&#xff0c;增强图像的边缘和细节。 以下是一个完整的Qt应用程序示例&#xff0c;展示如何使用Qt…...

    编程日记 2025/2/13 1:40:02

    38.社区信息管理系统(基于springboothtml)

    目录 1.系统的受众说明 2.需求分析及相关技术 2.1设计目的 2.2社区信息管理系统的特点 2.3可行性分析 2.3.1技术可行性 2.3.2运行可行性 2.4系统设计 2.4.1系统功能分析 2.4.2管理员权限功能设计 2.4.3业主权限功能设计 2.5系统的技术介绍 2.5.1 Html 2.5.2 Aja…...

    编程日记 2025/2/13 1:36:58

    游戏引擎学习第98天

    仓库:https://gitee.com/mrxiao_com/2d_game_2 开始进行一点回顾 今天的目标是继续实现正常贴图的操作&#xff0c;尽管目前我们还没有足够的光照信息来使其完全有用。昨日完成了正常贴图相关的基础工作&#xff0c;接下来将集中精力实现正常贴图的基本操作&#xff0c;并准备…...

    编程日记 2025/2/13 1:35:57

    音频知识基础

    音频知识基础 声音属性声音度量人耳特性通道数音频数字化传输接口 声音属性 响度 响度是人耳对声音强弱的主观感受&#xff1b; 主要和声波的振幅相关&#xff0c;同时也和频率有一定关系&#xff1b; 音调 音调是人耳对声音高低的主观感受&#xff1b; 主要与频率相关&#…...

    编程日记 2025/2/13 1:33:52

    【AI赋能】蓝耘智算平台实战指南：3步构建企业级DeepSeek智能助手

    蓝耘智算平台实战指南&#xff1a;3步构建企业级DeepSeek智能助手 引言&#xff1a;AI大模型时代的算力革命 在2025年全球AI技术峰会上&#xff0c;DeepSeek-R1凭借其开源架构与实时推理能力&#xff0c;成为首个通过图灵测试的中文大模型。该模型在语言理解、跨模态交互等维…...

    编程日记 2025/2/13 1:32:47

    LabVIEW无人机飞行状态监测系统

    近年来&#xff0c;无人机在农业植保、电力巡检、应急救灾等多个领域得到了广泛应用。然而&#xff0c;传统的目视操控方式仍然存在以下三大问题&#xff1a; 飞行姿态的感知主要依赖操作者的经验&#xff1b; 飞行中突发的姿态异常难以及时发现&#xff1b; 飞行数据缺乏系统…...

    编程日记 2025/2/13 1:31:46

    DeepSeek模型架构及优化内容

    DeepSeek v1版本 模型结构 DeepSeek LLM基本上遵循LLaMA的设计&#xff1a; 采⽤Pre-Norm结构&#xff0c;并使⽤RMSNorm函数. 利⽤SwiGLU作为Feed-Forward Network&#xff08;FFN&#xff09;的激活函数&#xff0c;中间层维度为8/3. 去除绝对位置编码&#xff0c;采⽤了…...

    编程日记 2025/2/13 1:30:45

    html语义化

    常见语义化标签有&#xff1a; &#xff08;1&#xff09;页面结构标签&#xff1a;<header>、<nav>、<main>、<article>、<section>、<aside>、<footer> &#xff08;2&#xff09;文本语义标签&#xff1a;<h1>-<h6>…...

    编程日记 2025/2/13 1:28:43

    python学习第十四天之机器学习名词介绍

    名词介绍 1. 常用术语解释2.常见机器学习任务3. 机器学习常见算法1. 监督学习&#xff08;Supervised Learning&#xff09;2. 非监督学习&#xff08;Unsupervised Learning&#xff09;3.深度学习4.**对比总结** 1. 常用术语解释 拟合&#xff08;Fit&#xff09;&#xff1…...

    编程日记 2025/2/13 1:26:40

    天津三石峰科技——汽车生产厂的设备振动检测项目案例

    汽车产线有很多传动设备需要长期在线运行&#xff0c;会出现老化、疲劳、磨损等 问题&#xff0c;为了避免意外停机造成损失&#xff0c;需要加装一些健康监测设备&#xff0c;监测设备运 行状态。天津三石峰科技采用 12 通道振动信号采集卡&#xff08;下图 1&#xff09;对…...

    编程日记 2025/2/13 1:23:37

    汽车与AI深度融合：CES Asia 2025前瞻

    在科技飞速发展的当下&#xff0c;汽车与AI的融合正成为行业变革的关键驱动力。近日&#xff0c;吉利、极氪、岚图、智己等多家车企纷纷官宣与DeepSeek模型深度融合&#xff0c;其中岚图知音更是将成为首个搭载该模型的量产车型&#xff0c;这无疑是汽车智能化进程中的重要里程…...

    编程日记 2025/2/13 1:20:33

    前端实现 GIF 图片循环播放

    前言 使用 img 加载 GIF 图片&#xff0c;内容只会播放一次&#xff0c;之后就会自动暂停&#xff1b; 通过定时器在一段时间后重新加载图片的方式&#xff0c;会导致浏览器内存不断增大&#xff0c;并且可能会有闪烁、卡顿的问题&#xff1b; ImageDecoder WebCodecs API 的…...

    编程日记 2025/2/13 1:19:31

    React - 事件绑定this

    在 React 中&#xff0c;this 的绑定是一个常见问题&#xff0c;尤其在类组件中使用事件处理函数时。JavaScript 中的 bind 函数用于设置函数调用时 this 的值。 bind 函数的作用 bind() 方法创建一个新的函数&#xff0c;当被调用时&#xff0c;其 this 关键字被设置为提供的…...

    编程日记 2025/2/13 1:15:24

    STM32系统架构介绍

    STM32系统架构 1. CM3/4系统架构2. CM3/4系统架构-----存储器组织结构2.1 寄存器地址映射&#xff08;特殊的存储器&#xff09;2.2 寄存器地址计算2.3 寄存器的封装 3. CM3/4系统架构-----时钟系统 STM32 和 ARM 以及 ARM7是什么关系? ARM 是一个做芯片标准的公司&#xff0c…...

    编程日记 2025/2/13 1:05:09

    Macbook Pro快速搭建Easysearch学习环境

    在学习过程中&#xff0c;我们有时身边没有可用的服务器&#xff0c;这时就需要借助自己的 Mac 来安装和学习 Easysearch。然而&#xff0c;Easysearch 官网并未提供 Mac 版本的安装教程&#xff0c;下面我将详细整理我在 Mac 上安装和使用 Easysearch 的折腾经历。 Easysearc…...

    编程日记 2025/2/13 0:57:00

    老游戏回顾：SWRacer

    竞速类游戏里&#xff0c;我很怀念它。 虽然已经25年过去了。 相比之下&#xff0c;别的游戏真的没法形容。 ---- 是LucasArts制作的一款赛车竞速游戏&#xff1b; 玩家要扮演一名银河旅行者参加各种赛车比赛&#xff0c;赢得奖金&#xff0c;在经历了八个不同星球上的24场…...

    编程日记 2025/2/13 0:52:55

    Timoni高级功能揭秘：类型验证、签名和OCI分发

    Timoni高级功能揭秘&#xff1a;类型验证、签名和OCI分发 【免费下载链接】timoni Timoni is a package manager for Kubernetes, powered by CUE and inspired by Helm. 项目地址: https://gitcode.com/gh_mirrors/ti/timoni Timoni是一个基于CUE的Kubernetes包管理器&…...

    编程新知 2026/5/14 4:23:59

    从Xilinx 7系列FPGA看架构演进与工程选型实战

    1. 项目概述&#xff1a;从一则旧闻看FPGA的演进与选型看到这个标题&#xff0c;很多朋友可能会觉得这是一则十多年前的“旧闻”了。确实&#xff0c;2011年Xilinx宣布其28nm 7系列FPGA在六个月内获得超过200个设计订单&#xff0c;这在当时是半导体行业的一个里程碑。但今天回…...

    编程新知 2026/5/14 3:58:46

    AI智能体开发实战：从框架选型到部署优化的全流程指南

    1. 项目概述与核心价值最近在探索AI智能体&#xff08;AI Agent&#xff09;和自动化工作流领域时&#xff0c;我反复被一个名字刷屏&#xff1a;AwesomeClaw。这个由CrayBotAGI团队开源的项目&#xff0c;在GitHub上迅速获得了大量关注。乍一看&#xff0c;它像是一个又一个“…...

    编程新知 2026/5/14 3:25:22

    大型语言模型开发的环境成本与优化策略

    1. 语言模型开发的环境成本全景图当我们惊叹于ChatGPT流畅的对话能力或Midjourney惊人的图像生成质量时&#xff0c;很少有人会思考这些AI能力背后的环境代价。事实上&#xff0c;大型语言模型的开发正悄然成为数字时代的"高碳产业"——训练一个130亿参数的模型所产生…...

    编程新知 2026/5/14 3:23:22

    DuckyClaw工具链解析：智能家居硬件安全与固件提取实战

    1. 项目概述&#xff1a;从“DuckyClaw”看智能家居的硬件安全研究最近在翻看一些开源硬件项目时&#xff0c;一个名为“DuckyClaw”的仓库引起了我的注意。这个项目托管在涂鸦智能&#xff08;Tuya&#xff09;的官方GitHub组织下&#xff0c;名字本身就很有意思——“鸭子爪”…...

    编程新知 2026/5/14 2:23:55

    观察在虚拟机内使用Taotoken调用API的延迟与稳定性表现

    &#x1f680; 告别海外账号与网络限制&#xff01;稳定直连全球优质大模型&#xff0c;限时半价接入中。 &#x1f449; 点击领取海量免费额度 观察在虚拟机内使用Taotoken调用API的延迟与稳定性表现 在开发与测试环境中&#xff0c;虚拟机&#xff08;VM&#xff09;是常见的…...

    编程新知 2026/5/14 2:15:39

    兔子需要通风吗？关键不是风，而是空气路径

    养兔子的朋友&#xff0c;大概率都有一个共识&#xff1a;要给兔子控温&#xff0c;夏天防中暑、冬天防受冻。但很多人都忽略了一个和温度同等重要的点——空气流动。 从环境工程的角度来说&#xff0c;兔子的舒适生活环境&#xff0c;离不开三个核心因素&#xff1a;温度、湿度…...

    编程新知 2026/5/14 1:59:31

    别再搞混了！设备上那个RJ45口是Console调试口，不是网口（附UART转RS-232电路详解）

    网络设备调试入门&#xff1a;解密Console口的真实身份与电路原理 刚拿到一台崭新的交换机或路由器时&#xff0c;许多新手会对着设备后面板上那个看似普通的RJ45接口发愣——它长得和网口几乎一模一样&#xff0c;但旁边却标注着"Console"。这个看似简单的接口背后&…...

    编程新知 2026/5/14 1:47:33

    交互式CLI工具开发指南：从原理到实战构建Node.js命令行应用

    1. 项目概述&#xff1a;一个能“对话”的命令行工具如果你经常和命令行打交道&#xff0c;尤其是需要处理一些重复性、多步骤的配置或部署任务&#xff0c;你肯定有过这样的体验&#xff1a;打开一个脚本&#xff0c;面对一堆需要手动输入的参数&#xff0c;或者在不同的命令之…...

    编程新知 2026/5/14 1:21:15

    手把手教你写一个能自动上网写研报的 Research Agent

    手把手教你写一个能自动上网写研报的 Research Agent 引言 痛点引入 如果你是券商研究员、行业分析师、高校商科学生，或者企业战略岗的从业者，一定对「写研报」这件事的痛苦深有体会： 查资料耗时：一篇中等深度的行业研报，至少需要翻阅30+权威来源的信息，包括工信部政策…...

    编程新知 2026/5/14 1:10:55