1

我仍然是使用 SSE 的新手，我对 Django 版本 3.2.5 中的 SSE 有疑问，我正在使用 StreamingHttpResponse 向 EventSource 客户端发送 SSE 响应，它工作正常，我的问题是

为什么打开后端和 EventSource 之间的连接需要很长时间？

为什么它只发送 167 个响应/32 秒？

我试图打开 StreamingHttpResponse 的代码，但我没有找到与响应数量相关的任何内容

在代码中

def sse_movies(request):
  def event_stream():
      while True:
          sleep(.2)
          yield f"data: {datetime.time(datetime.now())}\n\n"
  return StreamingHttpResponse(event_stream(), content_type='text/event-stream')

我使用 sleep() 每次迭代只等待 200/毫秒。但是每当发送 EventSource 时，它​​都会等待近 32/秒来启动与后端的连接，在它发送 167 个请求之后等待 2 秒，然后再次发送另一个 167 个请求，在发送第二个 167 之后它又等待 32 秒

这是EventSource客户端的代码

    let url = '/test/' +'sse/movies/'
    let sse_client = new EventSource(url)
    let movies = document.querySelector('#data-movies')
    let movies_list = document.querySelector('#messages')

    sse_client.onopen  = function(message_event) {
        console.log('opened')
    }
    console.log(sse_client)

    sse_client.onmessage =  (message_event) => {
        console.log(message_event.data)
        console.log(sse_client.readyState)
}

注意：当我删除白色时：True EventSource 不会等待并尽可能多地发送请求

也许我在这里误解了一些东西，但我希望有人能帮助我

4

1 回答 1

0

我可以弄清楚这个问题。

它不在代码本身中，但它与网络服务器的缓冲区大小有关

所以当我编辑我的代码如下它工作正常：

def sse_movies(request):
  def event_stream():
      body =  ''.join([letter * 6000 for letter in 'A'])
      body_len = len(body)
      print(body_len)

      while True:
          sleep(2)
          yield f"data: {body}\n\n"
  return StreamingHttpResponse(event_stream(), content_type='text/event-stream')

正如您在上面看到的，缓冲区的最小大小是 6000/字符，我不知道这可能是多少字节），但是它确实有效，Alhumdulliah）

我真的不太了解缓冲区/缓冲区大小/.. 但我认为这可能是问题所在

于 2021-08-01T16:23:54.200 回答