处理流式 HTTP 响应- 技术经验 -卓越飞翔博客

处理流式 http 响应

php小编子墨为您介绍处理流式 HTTP 响应的方法。在开发Web应用程序时，我们经常需要处理大文件的下载或者实时流媒体的传输。而传统的一次性加载整个响应内容的方式会导致内存占用过高，影响性能。为了解决这个问题，我们可以使用流式HTTP响应。流式HTTP响应可以将响应内容分块传输，减少内存占用，提高用户体验。在PHP中，我们可以使用一些库或者自定义方法来实现流式HTTP响应，从而优化我们的Web应用程序。

问题内容

我有以下示例，它连接到 HTTP 服务，该服务将响应以块流的形式传回以创建 JSON 结构。对于每个块，我的代码附加一个字节 rb 数组和各个行。但是，我的问题是尝试在 rb 完成时解决，以便我可以对其进行解码。

我在这里遗漏了一些明显的东西吗？

package main

import (
    "bufio"
    "bytes"
    "fmt"
    "io"
    "net/http"
)

func main() {

    body := []byte("test")

    resp, err := http.Post("http://localhost:8281/tap", "application/json", bytes.NewReader(body))
    if err != nil {
        fmt.Printf("%vn", err)
        return
    }
    defer resp.Body.Close()
    fmt.Printf("Status: [%s]n", resp.Status)
    fmt.Println()
    //var rb []byte
    reader := bufio.NewReader(resp.Body)
    var rb []byte

    for {

        line, err := reader.ReadBytes('n')
        if err != nil {
            if err == io.EOF {
                break
            }
            fmt.Printf("Error reading streamed bytes %v", err)
        }
        rb = append(rb, line...)

        fmt.Println(rb)

    }
}

解决方法

忽略程序中的bug，rb在循环中断后完成。

该程序确实有错误：

程序仅在 EOF 时跳出循环。如果出现任何其他类型的错误，程序将永远旋转。
程序不处理 ReadBytes 返回数据和错误的情况。可能发生这种情况的一个示例是响应不以分隔符结尾。

看起来您的目标是吸收对 rb 的整个响应。使用 io.ReadAll 执行此操作：

resp, err := http.Post("http://localhost:8281/tap", "application/json", bytes.NewReader(body))
if err != nil {
    fmt.Printf("%vn", err)
    return
}
defer resp.Body.Close()
rb, err := io.ReadAll(resp.Body)
if err != nil {
    // handle error
}
var data SomeType
err = json.Unmarshal(rb, &data)
if err != nil {
     // handle error
}

如果你想将响应体解码为 JSON，那么更好的方法是让 JSON 解码器读取响应正文：

resp, err := http.Post("http://localhost:8281/tap", "application/json", bytes.NewReader(body))
if err != nil {
    fmt.Printf("%vn", err)
    return
}
defer resp.Body.Close()
var data SomeType
err := json.NewDecoder(resp.Body).Decode(&data)

问题内容

解决方法

相关推荐