个人中心
gpt4 book ai didi

python - 在运行 Sophos 的机器上，为什么我的所有浏览器都无法从我的 Python 应用程序实时接收服务器发送的事件 (sse)？

转载 作者：行者123 更新时间：2023-12-02 16:38:39 25 4
gpt4 key购买 nike

我的 ASGI 应用程序将事件发送到 curl 并发送到我的手机。然而，即使服务器正在发送事件，并且 header 看起来正确，但在连接关闭之前，我的 Windows 计算机上的 Firefox 和 Chrome 都不会收到事件。

无论我将服务器托管在 WSL、Powershell 终端还是单独的 Linux 机器上，都会发生这种情况。

但是，如果我托管 server on repl.it，这些相同的浏览器工作正常(请 fork 并尝试一下)。

我曾尝试修改 Windows 防火墙设置，但无济于事。

这是应用程序代码:

import asyncio
import datetime


async def app(scope, receive, send):
    headers = [(b"content-type", b"text/html")]
    if scope["path"] == "/":
        body = (
            "<html>"
            "<body>"
            "</body>"
            "<script>"
            "  let eventSource = new EventSource('/sse');"
            "  eventSource.addEventListener('message', (e) => {"
            "    document.body.innerHTML += e.data + '<br>';"
            "  });"
            "</script>"
            "</html>"
        ).encode()

        await send({"type": "http.response.start", "status": 200, "headers": headers})
        await send({"type": "http.response.body", "body": body})
    elif scope["path"] == "/sse":
        headers = [
            (b"content-type", b"text/event-stream"),
            (b"cache-control", b"no-cache"),
            (b"connection", b"keep-alive"),
        ]

        async def body():
            ongoing = True
            while ongoing:
                try:
                    payload = datetime.datetime.now()
                    yield f"data: {payload}\n\n".encode()
                    await asyncio.sleep(10)
                except asyncio.CancelledError:
                    ongoing = False

        await send({"type": "http.response.start", "status": 200, "headers": headers})
        async for chunk in body():
            await send({"type": "http.response.body", "body": chunk, "more_body": True})
        await send({"type": "http.response.body", "body": b""})
    else:
        await send({"type": "http.response.start", "status": 404, "headers": headers})
        await send({"type": "http.response.body", "body": b""})

这可以通过将上面的文件命名为 asgi_sse.py，然后 pip install uvicorn，然后使用类似的东西来运行

uvicorn asgi_sse:app

(用 daphne 或 hypercorn 代替上面的 uvicorn 以查看这些服务器如何处理应用程序。)

标题:

$ curl -I http://localhost:8000/sse
HTTP/1.1 200 OK
date: Mon, 01 Jun 2020 09:51:41 GMT
server: uvicorn
content-type: text/event-stream
cache-control: no-cache
connection: keep-alive

响应:

$ curl http://localhost:8000/sse
data: 2020-06-01 05:52:40.735403

data: 2020-06-01 05:52:50.736378

data: 2020-06-01 05:53:00.736812

非常欢迎任何见解!

最佳答案

我最近遇到了同样的问题，但使用的是 NodeJS + Express 应用程序。如果连接不安全，我最终会发送一个 2 兆字节的数据 block 。

if (!req.secure) {
  res.write(new Array(1024 * 1024).fill(0).toString());
}

这是为了让服务器发送的事件在没有安全连接的开发环境中工作。

完整的实现:

app.use('/stream', (req, res) => {
  res.set({
    'Content-Type': 'text/event-stream;charset=utf-8',
    'Cache-Control': 'no-cache, no-transform',
    'Content-Encoding': 'none',
    'Connection': 'keep-alive'
  });
  res.flushHeaders();

  if (!req.secure) {
    res.write(new Array(1024 * 1024).fill(0).toString());
  }

  const sendEvent = (event, data) => {
    res.write(`event: ${String(event)}\n`);
    res.write(`data: ${data}`);
    res.write('\n\n');
    res.flushHeaders();
  };

  const intervalId = setInterval(() => {
    sendEvent('ping', new Date().toLocaleTimeString());
  }, 5000);

  req.on('close', () => {
    clearInterval(intervalId);
  });
});

关于python - 在运行 Sophos 的机器上，为什么我的所有浏览器都无法从我的 Python 应用程序实时接收服务器发送的事件 (sse)？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/62129788/

25 4 0
文章推荐： yolo - OpenVINO - 带有 YoloV4 的工具包
文章推荐： python - python中的.dat文件
文章推荐： opencv - 给定点的世界坐标(在二维图像平面位置和深度值中)，我该如何导出？
文章推荐： javascript - 如何以 Angular 覆盖按钮点击测试？ (附 Stackblitz)
行者123
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com