Grpc的四种通信方式

最新推荐文章于 2025-04-24 13:57:34 发布

GzmObject

最新推荐文章于 2025-04-24 13:57:34 发布

阅读量1.6k

点赞数

文章标签： rpc 开发语言 go

本文链接：https://blog.csdn.net/GzmObject/article/details/130175189

版权

文章介绍了gRPC的四种通信方式：简单RPC、服务端流式、客户端流式和双向流式。简单RPC适用于单次请求-响应，而服务端流式适用于服务器向客户端持续发送大量数据，如股票实时数据。客户端流式常用于大文件上传，允许分块发送。双向流式则适合实时聊天或多人协作应用，支持同时进行发送和接收数据。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

rpc

我们知道对于net/rpc来说 , 我们需要注册一个函数那么就需要满足

func (t *T) MethodName(argType T1 ,replyType *T2) error

很明显这个是一个请求对应一个响应 , 因此即是简单的rpc通信

grpc通信类别

grpc 分为以下四种通信方式 :

简单RPC : 一个请求 , 返回一个响应
服务端流式RPC : 一个请求 , 返回多个响应
客户端流式RPC : 多个请求 , 返回一个响应
双向流式RPC : 多个请求 , 返回多个响应

服务端流模式

我们只需要在proto中更改一下即可

业务场景 :
客户端向服务端发送一个股票代码 , 服务端就把该股票的实时数据源源不断的返回给客户端

提问1 : 为什么我不能用简单RPC模式返回一个切片的形式代替服务端流模式呢
其实可以代替 , 但是对于服务器如果要生成大量数据传输给客户端,那么简单的RPC模式就要等待所有数据都生成完毕才能收到响应。这会使得客户端等待时间过长,甚至导致网络超时

service YourService {
   
  rpc serverStreamHello(Person) returns (stream Result) {
   }
}

处理流数据

// 调用serverStreamHello方法并获取响应流
stream, err := client.ServerStreamHello(context.Background(), person)
if err != nil {
   
    log.Fatalf("Failed to call RPC method: %v", err)
}

// 遍历响应流并处理每个Result消息
for {
   
    result, err := stream

最低0.47元/天解锁文章