Golang multipart.Reader无法检测边界：海康威视事件流读取异常

问题分析 #

你在解析海康威视/ISAPI/Event/notification/alertStream的multipart/mixed推送流时遇到两个核心问题：

• 调用io.ReadAll()或io.Copy()会卡住，因为这是持续推送的长连接流，不会返回EOF，这类依赖EOF终止的方法会一直阻塞等待。
• 用bufio.Scanner逐行读取时，虽然能输出内容，但readPartData()永远无法返回——因为Scanner会持续等待下一行输入，而推送流会不断发送新的part，不会给当前part发送终止信号，导致循环无法退出。

从你提供的流示例看，海康的multipart格式是符合规范的：每个part有明确的Content-Length，边界标识--boundary也正确，问题出在你的读取逻辑上。

解决思路与修正代码 #

核心修复点是根据每个part的Content-Length读取固定字节数，而不是依赖EOF或逐行读取。具体步骤：

1. 从multipart.Part的Header中获取Content-Length，转换为整数。
2. 读取对应长度的字节内容，避免阻塞。

主循环代码（保持原结构） #

parser := multipart.NewReader(resp.Body, bod)

for {
    log.Println("New Part")
    part, err := parser.NextPart()
    if err != nil {
        log.Println("NextRawPart:", err)
        continue
    }

    da, err := readPartData(part)
    if err != nil {
        log.Println(err)
        continue
    }

    log.Println(da)

    part.Close()
}

修正后的readPartData函数 #

import "strconv"
import "fmt"
import "io"

func readPartData(part *multipart.Part) (string, error) {
    // 获取Content-Length头
    contentLenStr := part.Header.Get("Content-Length")
    if contentLenStr == "" {
        return "", fmt.Errorf("missing Content-Length header")
    }

    contentLen, err := strconv.Atoi(contentLenStr)
    if err != nil {
        return "", fmt.Errorf("invalid Content-Length: %v", err)
    }

    // 读取指定长度的内容
    buffer := make([]byte, contentLen)
    _, err = io.ReadFull(part, buffer)
    if err != nil {
        return "", fmt.Errorf("failed to read part data: %v", err)
    }

    return string(buffer), nil
}

额外注意事项 #

• 海康的推送流是永久连接，除非主动断开或设备离线，所以你的循环会一直运行，需要做好异常处理（比如连接中断、超时等）。
• 若XML内容中包含换行，io.ReadFull会完整读取所有字节，不会丢失格式，后续可以正常解析XML。
• 不要使用io.ReadAll()读取part或整个响应体，因为长连接不会返回EOF，必然导致阻塞。

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