Golang如何使用gRPC实现双向流通信_Golang gRPC双向流通信实践详解

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

Golang如何使用gRPC实现双向流通信_Golang gRPC双向流通信实践详解

2025-11-25

浏览次数：次

返回列表

首先定义支持双向流的.proto文件，生成Go代码后分别实现服务器和客户端逻辑，通过stream.Send和stream.Recv实现全双工通信。

golang如何使用grpc实现双向流通信_golang grpc双向流通信实践详解

在Go语言中使用gRPC实现双向流通信，可以高效地处理客户端与服务器之间持续交互的场景，比如实时聊天、日志推送、监控系统等。gRPC基于HTTP/2协议，天然支持双向流（Bidirectional Streaming），允许客户端和服务器同时发送多个消息，形*双工通信。

定义.proto文件支持双向流

要实现双向流通信，首先需要在.proto文件中定义一个服务方法，其请求和响应都使用stream关键字。

示例：chat.proto

syntax = "proto3";

package chat;

service ChatService {
rpc ChatStream(stream Message) returns (stream Message);
}

message Message {
string user = 1;
string content = 2;
}

这里ChatStream方法接收一个流式的Message，并返回一个流式的Message，表示客户端和服务器都可以连续发送消息。

生成Go代码

使用protoc配合gRPC插件生成Go代码：

protoc -I . --go_out=plugins=grpc:. chat.proto

会生成chat.pb.go文件，包含服务接口和数据结构定义。

实现服务器端逻辑

服务器需实现服务接口，并在处理函数中通过stream.Recv()接收消息，用stream.Send()发送消息。

美图云修

商业级AI影像处理工具

50 查看详情美图云修

示例服务器代码：

func (s *ChatServer) ChatStream(stream chat.ChatService_ChatStr

eamServer) error {
  for {
    msg, err := stream.Recv()
    if err == io.EOF {
      return nil
    }
    if err != nil {
      return err
    }

    // 处理消息，可广播给其他客户端
    response := &chat.Message{
      User: "Server",
      Content: "Echo: " + msg.Content,
    }

    stream.Send(response)
  }
}

注意：服务器在Recv遇到io.EOF时表示客户端关闭了发送流。

实现客户端逻辑

客户端通过调用ChatStream获得一个流对象，使用Send和Recv与服务器通信。

示例客户端代码：

stream, _ := client.ChatStream(context.Background())

// 开启goroutine接收服务器消息
go func() {
  for {
    msg, err := stream.Recv()
    if err == io.EOF {
      break
    }
    if err != nil {
      log.Fatal(err)
    }
    fmt.Printf("收到: %s - %s\n", msg.User, msg.Content)
  }
}()

// 发送消息
for i := 0; i   msg := &chat.Message{User: "Client", Content: fmt.Sprintf("消息 %d", i)}
  stream.Send(msg)
  time.Sleep(time.Second)
}

stream.CloseSend()

客户端使用独立的goroutine接收消息，避免阻塞发送流程。调用CloseSend通知服务器不再发送数据。

基本上就这些。只要.proto定义正确，收发逻辑清晰，gRPC的双向流在Go中使用非常直接。关键是理解流的生命周期和EOF的处理。实际项目中可结合上下文取消、超时控制和连接复用提升稳定性。

以上就是Golang如何使用gRPC实现双向流通信_Golang gRPC双向流通信实践详解的详细内容，更多请关注其它相关文章！

# 多个 # 网站站内外优化 # 网站建设推广推荐 LS15227优秀 # 安平网络营销策划推广 # 营销推广费编号 # 矩阵seo筑榜 # 修文网站seo优化价格 # Js渲染seo # 生命十大关键词排名图片 # 优化网站程序 # 鹤壁做推广网站的公司 # 相关文章 # 并在 # go # 全双工 # 流式 # 发送消息 # 如何使用 # 数据结构 # 美图 # 客户端 # 实时聊天 # stream # go语言 # golang