Gin框架流式返回图片异常：仅返回首张图片求助

我是Golang新手，尝试用Gin框架开发API，希望每隔500ms依次返回本地static文件夹中的图片。当前代码如下：

package main

import (
    "fmt"
    "io"
    "io/ioutil"
    "time"

    "github.com/gin-gonic/gin"
)
var imagePaths = []string{"static/1.png", "static/2.png", "static/3.png", "static/4.png"}

func main() {
    router := gin.Default()
    router.GET("/stream", func(c *gin.Context) {
        chanStream := make(chan []byte)
        go func() {
            defer close(chanStream)
            var i = 0
            for {
                file, _ := ioutil.ReadFile(imagePaths[i])
                chanStream <- file
                time.Sleep(time.Millisecond * 500)
                if i == 3 {
                    i = -1
                }
                i++
            }
        }()

        c.Stream(func(w io.Writer) bool {
            if msg, ok := <-chanStream; ok {
                w.Write(msg)
                return true
            }
            return false
        })
    })

    router.Run("localhost:8080")
}

预期效果是每隔500ms读取一张图片并返回，但目前仅能返回第一张图片。在c.Stream方法中打印msg的长度确认图片字节流已正确传入，但后续图片无法返回，求技术帮助。

问题出在HTTP响应没有明确的内容分隔标识：直接连续写入图片字节流时，客户端（浏览器或HTTP客户端）无法区分每张图片的边界，只会把所有字节当成一个完整的响应处理，所以只显示第一张。

要实现流式连续返回图片，需要使用multipart/x-mixed-replace类型的响应，这是专门用于动态替换内容的多部分MIME类型，通过边界符分隔每个图片内容块。

修改后的代码如下：

package main

import (
    "fmt"
    "io"
    "net/http"
    "os"
    "time"

    "github.com/gin-gonic/gin"
)

var imagePaths = []string{"static/1.png", "static/2.png", "static/3.png", "static/4.png"}
const boundary = "frame" // 自定义的内容块边界符

func main() {
    router := gin.Default()
    router.GET("/stream", func(c *gin.Context) {
        // 设置响应的Content-Type，指定多部分流式类型和边界符
        c.Header("Content-Type", fmt.Sprintf("multipart/x-mixed-replace; boundary=%s", boundary))
        
        chanStream := make(chan []byte)
        go func() {
            defer close(chanStream)
            i := 0
            totalImages := len(imagePaths)
            for {
                // 读取图片文件，不忽略错误
                fileBytes, err := os.ReadFile(imagePaths[i])
                if err != nil {
                    fmt.Printf("读取图片失败: %v\n", err)
                    time.Sleep(time.Millisecond * 500)
                    i = (i + 1) % totalImages
                    continue
                }
                chanStream <- fileBytes
                
                time.Sleep(time.Millisecond * 500)
                // 简化循环索引逻辑
                i = (i + 1) % totalImages
            }
        }()

        c.Stream(func(w io.Writer) bool {
            if imgBytes, ok := <-chanStream; ok {
                // 写入当前内容块的边界标识和类型头
                _, err := fmt.Fprintf(w, "--%s\r\nContent-Type: image/png\r\n\r\n", boundary)
                if err != nil {
                    fmt.Printf("写入边界标识失败: %v\n", err)
                    return false
                }
                // 写入图片字节流
                _, err = w.Write(imgBytes)
                if err != nil {
                    fmt.Printf("写入图片字节流失败: %v\n", err)
                    return false
                }
                // 写入内容块结束的换行符
                _, err = fmt.Fprintf(w, "\r\n")
                if err != nil {
                    fmt.Printf("写入换行符失败: %v\n", err)
                    return false
                }
                // 强制刷新缓冲区，确保内容立即发送给客户端
                if flusher, ok := w.(http.Flusher); ok {
                    flusher.Flush()
                }
                return true
            }
            // 响应结束时写入最终边界标识
            fmt.Fprintf(w, "--%s--\r\n", boundary)
            return false
        })
    })

    router.Run("localhost:8080")
}

关键修改点说明：

1. 设置正确的响应头：指定Content-Type为multipart/x-mixed-replace; boundary=frame，告诉客户端这是多部分流式响应，用自定义边界符分隔内容块。
2. 添加内容分隔标识：每次写入图片前，先写入边界符和图片类型头，明确当前内容块的开始和类型；图片写入后添加换行符分隔。
3. 强制刷新缓冲区：使用http.Flusher的Flush()方法，确保Gin立刻将内容发送到客户端，避免缓冲区堆积。
4. 完善错误处理：不再忽略文件读取和写入错误，便于排查问题。
5. 简化索引循环：用i = (i + 1) % totalImages替代原条件判断，逻辑更简洁且适配图片数量变化。

修改后，客户端能正确识别每张图片的边界，实现每隔500ms接收并显示新图片的效果。

内容的提问来源于stack exchange，提问作者Taki