Go에서 버퍼링되지 않은 HTTP 응답으로 실시간 데이터를 어떻게 보낼 수 있나요?

Go에서 버퍼링되지 않은 HTTP 응답으로 실시간 데이터 보내기

Go에서 HTTP 응답은 일반적으로 클라이언트에 전송되기 전에 버퍼링됩니다. 그러나 스트리밍 또는 실시간 애플리케이션의 경우 버퍼링 없이 데이터를 점진적으로 전송하는 것이 중요합니다.

버퍼되지 않은 응답을 얻으려면 일부 ResponseWriter에서 구현된 Flusher 인터페이스를 활용할 수 있습니다. 각 쓰기 작업 후 응답을 플러시하면 데이터가 사용 가능해지면 클라이언트에 직접 보낼 수 있습니다. 예는 다음과 같습니다.

func handle(res http.ResponseWriter, req *http.Request) {
  fmt.Fprintf(res, "sending first line of data")
  if f, ok := res.(http.Flusher); ok {
    f.Flush()
  }
  sleep(10) // Not real code
  fmt.Fprintf(res, "sending second line of data")
}

이 접근 방식은 수동 쓰기에는 작동하지만 파이핑 명령 출력이나 데이터가 비동기적으로 제공되는 기타 시나리오에는 충분하지 않을 수 있습니다. 이러한 경우 Go 루틴을 활용하여 데이터를 지속적으로 읽고 플러시할 수 있습니다.

pipeReader, pipeWriter := io.Pipe()
cmd.Stdout = pipeWriter
cmd.Stderr = pipeWriter
go writeCmdOutput(res, pipeReader)
err := cmd.Run()
pipeWriter.Close()

func writeCmdOutput(res http.ResponseWriter, pipeReader *io.PipeReader) {
  buffer := make([]byte, BUF_LEN)
  for {
    n, err := pipeReader.Read(buffer)
    if err != nil {
      pipeReader.Close()
      break
    }

    data := buffer[0:n]
    res.Write(data)
    if f, ok := res.(http.Flusher); ok {
      f.Flush()
    }
    // Reset buffer
    for i := 0; i < n; i++ {
      buffer[i] = 0
    }
  }
}

이 접근 방식을 사용하면 버퍼링 없이 명령 출력이 클라이언트에 직접 기록되고 플러시됩니다. 더욱 편리하게 하려면 실시간 스트리밍을 기본적으로 지원하는 [fasthttp](https://github.com/valyala/fasthttp)와 같은 라이브러리를 사용하는 것이 좋습니다.

위 내용은 Go에서 버퍼링되지 않은 HTTP 응답으로 실시간 데이터를 어떻게 보낼 수 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!