使用Python和Go实现服务器发送事件(SSE)

更新时间：2024年11月25日 10:33:19 作者：关山月

在当今的交互式web应用程序中,实时数据更新在增强用户体验方面起着至关重要的作用,在实时通信的各种技术中,SSE在众多解决方案脱颖而出,本文给大家介绍了使用Python和Go实现服务器发送事件(SSE),需要的朋友可以参考下

为什么选择SSE？

服务器发送事件是HTML5规范的一部分，专门用于将事件从服务器推送到客户端。它的简单性、自动重新连接和事件跟踪功能使其非常适合数据流的场景。在单向数据流情况下，SSE表现尤其出色。

概述

SSE是一种服务器向浏览器实时推送消息的技术。它是HTML5规范的一部分，主要涉及：

通信协议：使用HTTP。
事件对象：在浏览器端可用。

WebSockets也是一种实时通信技术，但它们有不同之处：

SSE	WebSockets
基于HTTP	基于TCP
单向（服务器到客户端）	全双工（双向）
轻量级和简单	更复杂的
内置重新连接和消息跟踪	需要手动实现这些功能
文本或Base64和gzip压缩的二进制文件	支持各种数据类型
支持自定义事件类型	不支持自定义事件类型
HTTP/1.1或HTTP/2限制连接数量	无限连接

服务器实现

协议实现

本质上，浏览器发起一个HTTP请求，服务器用HTTP状态进行响应，包括以下标头：

Content-Type: text/event-stream
Cache-Control: no-cache
Connection: keep-alive

SSE指定事件流的MIME类型必须为 text/event-stream ，浏览器不应该缓存数据，并且连接应该是持久的（ keep-alive ）。

消息格式

事件流是使用UTF-8编码的文本或Base64编码的二进制消息，并使用gzip压缩。每条消息由一行或多行字段组成，格式为 field-name : field-value 。每个字段以 \n 结尾。以冒号开头的行是注释，会被浏览器忽略。每个推送可以由多个消息组成，以空行分隔（ \n\n ）。

关键字段包括：

event ：事件类型。
id ：事件ID，浏览器跟踪最后接收到的事件用来重新连接服务。
retry ：浏览器在连接失败后重新尝试连接所需的等待时间（ms）。
data ：消息数据。

示例：Python实现SSE

from flask import Flask, Response

app = Flask(__name__)


@app.route('/events')
def sse_handler():
    def generate():
        paragraph = [
            "Hello, this is an example of a continuous text output.",
            "It contains multiple sentences, each of which will be sent to the client as an event.",
            "This is to simulate the functionality of Server-Sent Events (SSE).",
            "We can use this method to push real-time updates.",
            "End of sample text, thank you!",
        ]

        for sentence in paragraph:
            yield f"data: {sentence}\n\n"

            import time
            time.sleep(1)

    return Response(generate(), mimetype='text/event-stream')


if __name__ == '__main__':
    app.run(host='0.0.0.0', port=8081, debug=True)

示例：Go实现SSE

package main

import (
    "fmt"
    "log"
    "net/http"
    "time"
)

func main() {
    http.HandleFunc("/events", sseHandler)

    fmt.Println("Starting server on :8080")
    if err := http.ListenAndServe(":8080", nil); err != nil {
        log.Fatalf("Server error: %v", err)
    }
}

func sseHandler(w http.ResponseWriter, r *http.Request) {
    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "Streaming unsupported!", http.StatusInternalServerError)
        return
    }

    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    // Change the output here to a specific text
    paragraph := []string{
        "Hello, this is an example of a continuous text output.",
        "It contains multiple sentences, each of which will be sent to the client as an event.",
        "This is to simulate the functionality of Server-Sent Events (SSE).",
        "We can use this method to push real-time updates.",
        "End of sample text, thank you!",
    }

    for _, sentence := range paragraph {
        _, err := fmt.Fprintf(w, "data: %s\n\n", sentence)
        if err != nil {
            return
        }
        flusher.Flush()
        time.Sleep(1 * time.Second) // Wait 1 second before sending the next piece of text
    }
}

浏览器API️

在客户端，JavaScript的 EventSource API允许您创建一个 EventSource 对象来侦听服务器发送的事件。一旦连接上，服务器就可以向浏览器发送事件消息。浏览器通过监听 onmessage 、 onopen 和 onerror 事件来处理这些消息。

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>SSE Example 🌟</title>
</head>
<body>
    <h1>Server-Sent Events Example 🚀</h1>
    <div id="messages"></div>
    <script>
        window.onload = function() {
            if (typeof(EventSource) !== "undefined") {
                const eventSource = new EventSource('/events');

                eventSource.onmessage = function(event) {
                    const newElement = document.createElement("p");
                    newElement.textContent = "Message: " + event.data;

                    document.getElementById("messages").appendChild(newElement);
                };

                eventSource.onerror = function(event) {
                    console.error("Error occurred: ", event);
                    const newElement = document.createElement("p");
                    newElement.textContent = "An error occurred while connecting to the event source.";
                    document.getElementById("messages").appendChild(newElement);
                    eventSource.close(); 
                };
            } else {
                document.getElementById("messages").textContent = "Sorry, your browser does not support server-sent events...";
            }
        };
    </script>
</body>
</html>

SSE调试

目前，许多流行的工具，如Postman、Insomnia、Bruno和ThunderClient缺乏对服务器发送事件SSE的足够支持。在开发过程中，这种限制会让人非常沮丧。幸运的是，我最近遇到了EchoAPI，这个工具提供了出色的SSE调试功能。这个发现极大地改善了我的工作流程，提高了效率和生产力。

如果您正在使用SSE或进行API调试，我强烈建议您尝试一下EchoAPI。它可以彻底改变您的调试体验并简化您的开发工作。

示例：SSE的EchoAPI客户端

在EchoAPI中，使用SSE接口非常简单。只需输入URL，填写相关参数，然后点击“发送”即可看到您的请求结果。

以上就是使用Python和Go实现服务器发送事件(SSE)的详细内容，更多关于Python Go服务器发送事件的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Python实现Markdown格式消除工具
这篇文章主要为大家详细介绍了如何使用 Python 和 PyQt5 库来创建一个简单易用的 Markdown 格式消除工具,并且支持实时预览和文件保存功能,需要的可以了解下
2025-02-02
python音频处理用到的操作的示例代码
本篇文章主要介绍了python音频处理用到的操作的示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-10-10
Python 虚拟机字典dict内存优化方法解析
这篇文章主要为大家介绍了Python 虚拟机字典dict内存优化方法解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-03
pytorch常见的Tensor类型详解
今天小编就为大家分享一篇pytorch常见的Tensor类型详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-01-01
Python编程根据字典列表相同键的值进行合并
这篇文章主要介绍了来学习Python字典列表根据相同键的值进行合并的操作方法，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步
2021-10-10
如何将你的应用迁移到Python3的三个步骤
这篇文章主要介绍了如何将你的应用迁移到Python3的三个步骤,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-12-12
Pywinauto基础教程之控件操作
这篇文章主要给大家介绍了关于Pywinauto基础教程之控件操作的相关资料,pywinauto库是一个用于在Windows上自动化操作的库,文中通过代码示例介绍的非常详细,需要的朋友可以参考下
2023-08-08
Python字符串的encode与decode研究心得乱码问题解决方法
为什么Python使用过程中会出现各式各样的乱码问题，明明是中文字符却显示成“\xe4\xb8\xad\xe6\x96\x87”的形式？
2009-03-03
亲手教你实现pynq-z2条形码识别功能
这篇文章主要介绍了pynq-z2条形码识别功能,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-07-07
对python中的高效迭代器函数详解
今天小编就为大家分享一篇对python中的高效迭代器函数详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-10-10