gRPC调用方式

在gRPC中，一共包含四种调用方式。

Unary RPC:一元RPC
Server-side streaming RPC: 服务端流式RPC
Client-side streaming RPC: 客户端流式RPC
Bidirectional streaming RPC: 双向流式RPC

Streaming RPC

streaming RPC 适用于大数据包场景，可以进行实时交互；

**服务端流式RPC **：客户端发起一次普通的RPC请求，服务端通过流式响应多次发送数据集，客户端Recv接收数据集
客户端流式RPC：客户端发起多次请求给服务端，而服务端仅响应客户端一次
双向流式RPC: 由客户端以流式请求服务端，服务端同样以流式响应客户端。

代码实现

1、proto文件：创建proto文件定义三种流模式服务，执行protoc命令编译代码；

syntax = "proto3";package pb;option go_package = "pb/;pb";message Reply {string type = 1;string value = 2;
}message Request {string type = 1;string value = 2;
}service Streaming {rpc ServerStream (Request) returns (stream Reply);rpc ClientStream (stream Request) returns (Reply);rpc Bidirectional (stream Request) returns (stream Reply);
}

2、server：
客户端流模式下服务端手到 io._EOF时服务端需要通过 _stream.SendAndClose 向客户端返回；客户端 stream.CloseAndRecv 与之对应

var port stringfunc init() {flag.StringVar(&port, "p", "8000", "启动端口号")flag.Parse()
}type StreamServer struct {pb.UnimplementedStreamingServer
}func (ss StreamServer) ServerStream(in *pb.Request, stream pb.Streaming_ServerStreamServer) error {for i := 0; i < 20; i++ {err := stream.Send(&pb.Reply{Type: "Server-Side stream", Value: fmt.Sprintf("val:%d", i)})if err != nil {return err}}return nil
}func (ss StreamServer) ClientStream(stream pb.Streaming_ClientStreamServer) error {for {recv, err := stream.Recv()if err == io.EOF {return stream.SendAndClose(&pb.Reply{Type:  "Client-Side stream",Value: "close",})}if err != nil {return err}log.Printf("%v", recv)}
}
func (ss StreamServer) Bidirectional(stream pb.Streaming_BidirectionalServer) error {i := 0for {_ = stream.Send(&pb.Reply{Type: "Bidirectional stream", Value: fmt.Sprintf("val:%d", i)})recv, err := stream.Recv()if err == io.EOF {return nil}if err != nil {return err}log.Printf("%v", recv)i++}
}func main() {server := grpc.NewServer()pb.RegisterStreamingServer(server, &StreamServer{})reflection.Register(server)lis, _ := net.Listen("tcp", ":"+port)_ = server.Serve(lis)
}

3、client ：未方便后面测试，通过参数 -m 启动不同流模式客户端；

var port string
var method intfunc init() {flag.StringVar(&port, "p", "8000", "启动端口号")flag.IntVar(&method, "m", 1, "流模式")flag.Parse()
}
func ServerStreamClient(client pb.StreamingClient, r *pb.Request) error {stream, err := client.ServerStream(context.Background(), r)if err != nil {return err}for {recv, err := stream.Recv()if err == io.EOF {break}if err != nil {return err}log.Printf("response:%v", recv)}return nil
}func ClientStreamClient(client pb.StreamingClient) error {stream, err := client.ClientStream(context.Background())if err != nil {return err}for i := 0; i < 10; i++ {_ = stream.Send(&pb.Request{Type: "ClientStreamClient", Value: fmt.Sprintf("val:%d", i)})}recv, err := stream.CloseAndRecv()log.Printf("resp :%v", recv)return err
}func Bidirectional(client pb.StreamingClient) error {stream, err := client.Bidirectional(context.Background())if err != nil {return err}for i := 0; i < 10; i++ {_ = stream.Send(&pb.Request{Type: "BidirectionalClient", Value: fmt.Sprintf("val:%d", i)})recv, err := stream.Recv()if err == io.EOF {break}if err != nil {log.Printf("resp :%v", err)return err}log.Printf("resp :%v", recv)}return stream.CloseSend()
}func main() {conn, _ := grpc.Dial(":"+port, grpc.WithTransportCredentials(insecure.NewCredentials()))defer conn.Close()log.Printf("mothod %d", method)client := pb.NewStreamingClient(conn)switch method {case 1:_ = ServerStreamClient(client, &pb.Request{Type: "ss client", Value: "ok"})case 2:_ = ClientStreamClient(client)case 3:_ = Bidirectional(client)default:log.Fatal("error method")}
}

4、启动测试；

go run server.go
go run client.go -m 1/2/3

gRPC 快速体验（2）:Streaming RPC相关推荐

【rnnoise快速体验】rnnoise从编译到训练
运行环境为Ubuntu18.04 C部分下载源码从github上下载源码,目前只有master分支,就拿master分支下来. 准备编译环境干净的linux环境可能会没有安装gcc等编译工具所 ...
基于android os 5.1,Android 5.1.1版氢OS快速体验
本文约5304字,需9分钟阅读(全文浏览) [更新2015.07.15]作为一加氢OS的内测成员,小编在今天收到了氢OS最新的测试包.然而这个测试包有些不一样,它不再是基于Android 5.0.2系 ...
go test 如何输出到控制台_GO笔记之GO命令快速体验
上篇文章利用go run和go build命令分析介绍了GO的编译执行流程.GO提供给我们的命令当然远不止这两个.本文将在所能及的范围内,尽量地介绍GO提供的所有命令,从而实现对它们有个整体的认识. ...
gRPC快速入门记录
为什么使用grpc 1.protocl buffer一种高效的序列化结构. 2.支持http 2.0标准化协议. http/2 1.http/2对每个源只需创建一个持久连接,在这一个连接内,可以并行的 ...
【华为云技术分享】使用CloudIDE快速体验基于华为云ModelArts SDK的AI开发
华为云ModelArts一站式AI开发与管理平台,能够支撑开发者从数据到AI应用的全流程开发过程,包含数据处理.算法开发.模型训练.模型管理.部署等,支持图像分类.图像检测.视频分析.语音识别.产品推 ...
uniapp开发：uniapp快速体验vue3.2之setup语法糖，怎么使用怎么爽
目录概要拉开序幕的setup语法糖生命周期钩子 ref函数与reactive函数对比 computed计算属性监视(watch.watchEffect) 组件注册组件传值 provide/i ...
gRPC快速入门（三）——Protobuf应用示例
gRPC快速入门(三)--Protobuf应用示例一.Protobuf使用流程在工程开发中使用Protobuf流程如下: (1)定义proto描述文件,以proto作为后缀名. (2)使用Prot ...
Android 集成 Agora SDK 快速体验 RTC 版多人视频聊天|掘金技术征文
RTC (Real-Time Communication) 作为实时通讯领域的"新贵",在互动直播.远程控制.多人视频会议.屏幕共享等领域广受好评,如果你还不了解 RTC ,Tak ...
如何快速体验腾迅信鸽推送
作者:zhanhailiang 日期:2014-10-13 信鸽是什么腾讯信鸽(XG Push)是一款专业的免费移动App推送平台,支持百亿级的通知/消息推送,秒级触达移动用户,现已全面支持Andr ...

gRPC 快速体验（2）:Streaming RPC

gRPC调用方式

Streaming RPC

代码实现

gRPC 快速体验（2）:Streaming RPC相关推荐

最新文章

热门文章

gRPC 快速体验 （2）:Streaming RPC

gRPC调用方式

Streaming RPC

代码实现

gRPC 快速体验 （2）:Streaming RPC相关推荐

最新文章

热门文章

gRPC 快速体验（2）:Streaming RPC

gRPC 快速体验（2）:Streaming RPC相关推荐