调用SendAndClose后未返回io.EOF错误的原因排查

常见原因及解决方案 #

1. 客户端未监听流结束信号 #

gRPC客户端流中，服务端调用SendAndClose后，客户端必须通过Recv()方法才能接收到流关闭的io.EOF信号。如果客户端只循环发送请求，完全没处理接收逻辑，自然不会触发EOF。

错误示例（客户端）：

stream, err := client.ClientStreamMethod(ctx)
if err != nil {
    // 错误处理
}
for {
    err := stream.Send(&Request{})
    if err != nil {
        // 发送错误处理
    }
    time.Sleep(7 * time.Second)
}

正确做法是单独启动goroutine处理接收：

stream, err := client.ClientStreamMethod(ctx)
if err != nil {
    // 错误处理
}

// 启动接收协程监听流状态
go func() {
    resp, err := stream.Recv()
    if err == io.EOF {
        fmt.Println("服务端已关闭流")
    } else if err != nil {
        fmt.Printf("接收异常: %v\n", err)
    } else {
        fmt.Printf("收到服务端响应: %v\n", resp)
    }
}()

// 发送逻辑
for {
    err := stream.Send(&Request{})
    if err != nil {
        fmt.Printf("发送失败: %v\n", err)
        break
    }
    time.Sleep(7 * time.Second)
}

2. 服务端调用SendAndClose后未终止流操作 #

服务端调用SendAndClose后，如果还继续尝试读取客户端请求，会阻塞流的正常关闭，导致客户端无法收到EOF。

错误示例（服务端）：

func (s *Server) ClientStreamMethod(stream pb.Service_ClientStreamMethodServer) error {
    for {
        req, err := stream.Recv()
        if err == io.EOF {
            return nil
        }
        if err != nil {
            return err
        }
        // 处理请求后调用SendAndClose
        err = stream.SendAndClose(&Response{})
        if err != nil {
            return err
        }
        // 错误：还在尝试接收请求，阻塞流关闭
        req, err = stream.Recv()
    }
}

正确做法是调用SendAndClose后直接返回，不再操作流：

func (s *Server) ClientStreamMethod(stream pb.Service_ClientStreamMethodServer) error {
    req, err := stream.Recv()
    if err == io.EOF {
        return nil
    }
    if err != nil {
        return err
    }
    // 处理请求
    return stream.SendAndClose(&Response{})
}

3. 客户端上下文提前被取消 #

如果客户端传入的ctx被提前取消（比如超时、手动cancel），流的错误会被上下文取消错误覆盖，不会返回io.EOF。要确保上下文在流生命周期内有效，或者在错误处理时区分上下文取消和流正常关闭的情况。

4. gRPC版本兼容问题 #

旧版本gRPC可能存在流关闭逻辑的bug，建议升级到最新稳定版，同时确保客户端和服务端使用的gRPC版本一致。

排查步骤 #

• 先确认客户端是否有执行Recv()逻辑，这是获取EOF的前提
• 检查服务端调用SendAndClose后是否立即返回，没有后续的流读写操作
• 打印客户端所有发送/接收的错误信息，区分是上下文错误还是流关闭信号
• 简化代码（去掉业务逻辑）做最小化测试，排除干扰项

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