gRPC ServerStream分块传输CSV时每块出现多余换行如何解决

多余换行是grpc-gateway默认的服务端流转码逻辑导致的。
默认配置下，grpc-gateway会将gRPC服务端流按JSON流协议处理，每个独立的流消息序列化写入响应后，会自动追加一个\n作为消息分隔符。你的实现中每个分块都作为独立的HttpBody消息发送，且每个消息都携带了ContentType字段，gateway没有识别到这是连续的单文件字节流，就会在每个分块末尾插入分隔换行，最终表现为每隔chunkSize个字符出现一个多余换行。

按以下优先级修改即可解决问题：

1. 修正HttpBody的发送逻辑 #

• 提前在gRPC响应头中声明完整的响应元信息，包括Content-Type，不要依赖分块里的ContentType字段
• 仅在第一个流分块中设置ContentType，后续分块只传字节数据，告知gateway这是同一个连续资源的分块，而非独立消息
  修改后的代码如下：

// 提前在响应头设置所有下载相关元信息
if err := stream.SetHeader(metadata.Pairs(
    "content-disposition", "attachment",
    "content-type", "text/csv",
)); err != nil {
    return err
}

chunkSize := uint64(100)
isFirstChunk := true
for offset := uint64(0); offset < objLen; offset += chunkSize {
    contents, err := getContent(offset, chunkSize)
    if err != nil {
        return err
    }

    chunk := &httpbody.HttpBody{
        Data: contents,
    }
    // 仅第一个分块携带ContentType
    if isFirstChunk {
        chunk.ContentType = "text/csv"
        isFirstChunk = false
    }

    if err := stream.Send(chunk); err != nil {
        return err
    }
}

2. 为grpc-gateway注册专用的HttpBody序列化器 #

如果第一步修改后仍存在换行问题，是因为gateway默认没有为text/csv类型绑定原生字节流的序列化器，初始化ServeMux时添加如下配置即可：

import (
    "google.golang.org/genproto/googleapis/api/httpbody"
    "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
)

// 初始化gateway mux时注册HttpBody处理器
mux := runtime.NewServeMux(
    // 为所有类型绑定HttpBodyMarshaler，直接透传字节不做JSON包装
    runtime.WithMarshalerOption(runtime.MIMEWildcard, &runtime.HTTPBodyMarshaler{
        Marshaler: &runtime.JSONPb{},
    }),
)

HTTPBodyMarshaler是grpc-gateway官方提供的专门处理google.api.HttpBody类型的序列化器，会直接将Data字段的原始字节写入响应，不会追加任何额外的分隔符或包装内容，同时支持CSV、二进制文件等任意字节流传输场景。

3. 校验数据源逻辑 #

排除框架问题后，检查getContent函数的返回值，确认分块读取逻辑没有在每个分块末尾额外插入换行符。

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