Go语言双向gRPC流实现：服务器端主动发消息问询

嘿，这个问题问到点子上了——gRPC双向流的核心优势就是双向自由通信，咱们把你关心的点拆开来唠清楚。

在gRPC的双向流式RPC模式下，客户端和服务器一旦建立起连接，双方都能在任意时刻发送消息，没有固定的“请求-响应”顺序限制——就像打电话一样，你可以说一句等对方回应，也可以对方还没说完就插话，甚至两边同时说话（当然底层会做序列化处理，不会乱序）。

其实服务器端的操作逻辑完全由你自己的业务代码掌控，核心就是拿到流式调用的上下文对象（不同语言里命名不一样，比如Go里是ServerStreamingCall，Java里是StreamObserver），只要这个连接还没断开、没出错，你就能调用它的消息发送方法（比如Go的Send()，Java的onNext()）来推送消息。

给你举个直观的伪代码例子（用Go风格，容易理解）：

func (s *MyService) BidirectionalStream(stream pb.MyService_BidirectionalStreamServer) error {
    // 可选：先开个goroutine监听客户端发来的消息
    go func() {
        for {
            clientMsg, err := stream.Recv()
            if err == io.EOF {
                // 客户端关闭了发送流
                return
            }
            // 处理客户端消息，比如记录日志或者触发业务逻辑
            log.Printf("收到客户端消息：%s", clientMsg.Content)
        }
    }()

    // 场景1：定时主动推送消息
    ticker := time.NewTicker(3 * time.Second)
    defer ticker.Stop()
    for range ticker.C {
        err := stream.Send(&pb.ServerMsg{Content: fmt.Sprintf("当前时间：%v", time.Now())})
        if err != nil {
            // 连接出错，退出
            return err
        }
    }

    // 场景2：基于外部事件触发推送（比如数据库更新、消息队列通知）
    // for event := range externalEventChannel {
    //     err := stream.Send(&pb.ServerMsg{Content: fmt.Sprintf("外部事件：%v", event)})
    //     if err != nil {
    //         return err
    //     }
    // }

    return nil
}

触发条件完全看你的业务需求，常见的场景包括：

• 客户端消息触发：服务器收到客户端的某个请求后，返回一个或多个响应（比如客户端发一个查询指令，服务器分批返回结果）
• 定时任务驱动：比如每隔一段时间给客户端推送系统状态、实时数据
• 外部事件驱动：数据库数据更新、第三方服务回调、消息队列有新消息时，主动推送给客户端
• 服务器内部状态变化：比如服务负载过高、配置更新，主动通知所有连接的客户端

• 连接活跃性：只有当流式连接处于活跃状态（双方都没关闭，也没发生网络错误），才能成功发送消息
• 并发安全：如果多个线程/goroutine同时操作同一个流对象发送消息，要注意并发安全（部分语言的gRPC流API本身是线程安全的，但最好查对应语言的官方文档确认）
• 错误处理：一旦客户端断开连接或者出现网络错误，服务器的Send()或Recv()会返回错误，这时要及时清理资源、结束调用

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