go runtime_error ai_generated true

rpc 错误:代码 = Internal 描述 = grpc: 在流上发送消息失败:流已关闭

rpc error: code = Internal desc = grpc: failed to send message on stream: stream closed

ID: go/grpc-stream-send-on-closed

其他格式: JSON · Markdown 中文 · English
80%修复率
84%置信度
0证据数
2024-09-03首次发现

版本兼容性

版本状态引入弃用备注
google.golang.org/grpc v1.42+ active

根因分析

客户端或服务端在流关闭后(已调用 CloseSend、服务端已返回,或上下文取消)调用了 Send。对已终止流的写入会被拒绝。

English

The client or server called Send on a stream after it was closed (CloseSend called, server returned, or context canceled). Writes to a terminal stream are rejected.

generic

解决方案

  1. 80% 成功率
    stream, err := client.Upload(ctx)
    if err != nil { return err }
    for _, m := range msgs {
        if err := stream.Send(m); err != nil {
            stream, err = client.Upload(ctx) // reopen
            if err != nil { return err }
        }
    }
  2. 85% 成功率
    defer stream.CloseSend()
    // ensure all Send calls complete before CloseSend runs

无效尝试

常见但无效的做法:

  1. 90% 失败

    A closed stream cannot be reopened; the same stream handle remains terminal.

  2. 85% 失败

    Closure is a state, not a timing race; sleeping does not reopen the stream.