1

我的 ASGI 应用程序可以很好地向 curl 和我的手机发送事件。但是，即使服务器正在发送事件，并且标头看起来正确，但我的 Windows 机器上的 Firefox 和 Chrome 都不会收到事件，直到连接关闭。

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

但是，如果我在 repl.it 上托管服务器，这些相同的浏览器可以正常工作（请分叉并试用）。

我曾尝试摆弄 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

任何见解都非常受欢迎！

4

2 回答 2

3

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

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);
  });
});
于 2020-07-15T09:42:50.233 回答
1

说明

我的公司已打开 Sophos Endpoint Security 的 Web 保护。根据Sophos 社区中的此条目，Web 保护缓冲并扫描文本/事件流内容以查找恶意软件。因此意外的缓冲。

解决方案

我发现了两种解决方法：

  1. 在第一个事件之前发送一个 2 兆字节（多就可以；少就不行）的数据块。您不需要在每个事件中都发送它；只是第一个。
  2. 或使用 https (SSL/TLS)。对于本地开发，请考虑使用mkcert以方便地进行设置。

蟒蛇之谜

上述问题不仅仅是我的代码的问题，也不是 Uvicorn、Hypercorn 或 ASGI 的问题。事实上，我什至尝试了一个 aiohttp 实现，结果同样令人遗憾。但是，当我尝试SSE的 Go 示例实现和Node.js 中的另一个实现时，它运行良好，不需要变通方法。我能看到的唯一区别是 Go 实现在每个事件之后都使用了 flush 方法。我不确定为什么 ASGI 和 aiohttp 不公开某种刷新方法，或者，如果他们公开了，为什么我找不到它。如果他们这样做了，是否会使这些变通办法变得不必要？我不确定。

这是使它与 Sophos 一起工作的更新代码，并检查是否通过 https 提供服务：

async def app(scope, receive, send):
    headers = [(b"content-type", b"text/html")]
    if scope["path"] == "/":
        body = (
            "<!DOCTYPE html>"
            "<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})
        if scope["scheme"] != "https": # Sophos will buffer, so send 2MB first
            two_meg_chunk = "." * 2048 ** 2
            await send(
                {
                    "type": "http.response.body",
                    "body": f": {two_meg_chunk}\n\n".encode(),
                    "more_body": True,
                }
            )
        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""})
于 2020-06-10T10:15:52.937 回答