系列章节

GRPC与.net core

GRPC截止时间与元数据

GRPC与netcore Identity

GRPC与netcore IdentityServer4

概述

GRPC的数据交互模式有：

1.单项RPC，最简单的数据交换方式，客户端发出单个请求，收到单个响应

2.服务端流式RPC，是在服务端收到客户端的请求之后，返回一个应答流，客户端收到流之后处理。

3.客户端流式RPC，与单项类似，但客户端发送的是流式RPC

4.双向流式RPC，调用由客户端调用方法来初始化，而服务端则接收到客户端的元数据，方法名和截止时间。服务端可以选择发送回它的初始元数据或等待客户端发送请求。下一步怎样发展取决于应用，因为客户端和服务端能在任意顺序上读写 - 这些流的操作是完全独立的。例如服务端可以一直等直到它接收到所有客户端的消息才写应答，或者服务端和客户端可以像"乒乓球"一样：服务端后得到一个请求就回送一个应答，接着客户端根据应答来发送另一个请求，以此类推。

单项RPC较简单不做示例了。

首先在vs2019中net core3.0中新建GRPC项目。然后定义响应的proto文件，根据proto文件生成响应的服务端与客户端代码。

1.服务端流式RPC

1.定义 protofile

syntax = "proto3";

option csharp_namespace = "GrpcGreeter";

package Greet;

// The greeting service definition.

service Greeter {

  // Sends a greeting

  rpc SayHello (HelloRequest) returns (HelloReply) {}

  rpc GetStreamContent (StreamRequest) returns (stream StreamContent) {}

}

// The request message containing the user's name.

message HelloRequest {

  string name = ;

}

// The response message containing the greetings.

message HelloReply {

  string message = ;

}

message StreamRequest {

  string fileName = ;

}

message StreamContent {

  bytes content = ;

}

2.实现服务端Service

重新生成项目，然后实现GetStreamContent，简单的读取文件内容，并将内容返回给Client

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Threading.Tasks;

using Google.Protobuf;

using Grpc.Core;

namespace GrpcGreeter

{

    public class GreeterService : Greeter.GreeterBase

    {

        public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)

        {

            return Task.FromResult(new HelloReply

            {

                Message = "Hello " + request.Name

            });

        }

        public override Task GetStreamContent(StreamRequest request, IServerStreamWriter<StreamContent> responseStream, ServerCallContext context)

        {

            return Task.Run(async () =>

             {

                 using (var fs = File.Open(request.FileName, FileMode.Open)) // 从 request 中读取文件名并打开文件流

                 {

                     var remainingLength = fs.Length; // 剩余长度

                     var buff = new byte[]; // 缓冲区，这里我们设置为 1 Mb

                     while (remainingLength > ) // 若未读完则继续读取

                     {

                         var len = await fs.ReadAsync(buff); // 异步从文件中读取数据到缓冲区中

                         remainingLength -= len; // 剩余长度减去刚才实际读取的长度

                         // 向流中写入我们刚刚读取的数据

                         await responseStream.WriteAsync(new StreamContent

                         {

                             Content = ByteString.CopyFrom(buff, , len)

                         });

                     }

                 }

             });

        }

    }

}

3.实现Client

新建一个netcore 3.0的Console项目，并引入Nuget包

Install-Package Grpc.Net.Client -Version 0.1.-pre1

Install-Package Google.Protobuf -Version 3.8.

Install-Package Grpc.Tools -Version 1.22.

编辑项目文件，修改如下节点

<Protobuf Include="Protos\greet.proto" GrpcServices="Client" />

重新生成项目，Client端主要实现发送请求，请求是一个服务器端的文件路径。然后实现接收服务端的流，并保存到Client本地。

using Grpc.Net.Client;

using GrpcGreeter;

using System;

using System.Collections.Generic;

using System.IO;

using System.Net.Http;

namespace GrpcGreeterClient

{

    class Program

    {

        static async System.Threading.Tasks.Task Main(string[] args)

        {

            AppContext.SetSwitch(

                "System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport",

                true);

            var httpClient = new HttpClient();

            // The port number(50051) must match the port of the gRPC server.

            httpClient.BaseAddress = new Uri("http://localhost:50051");

            var client = GrpcClient.Create<Greeter.GreeterClient>(httpClient);

            //

            var reply = await client.SayHelloAsync(

                              new HelloRequest { Name = "GreeterClient" });

            Console.WriteLine("Greeting: " + reply.Message);

            Console.ReadKey();

            //

            var result = client.GetStreamContent(new StreamRequest { FileName = @"D:\Docs.zip" });  //发送请求

            var iter = result.ResponseStream;

            using (var fs = new FileStream(@"D:\Docs2.zip", FileMode.Create)) // 新建一个文件流用于存放我们获取到数据

            {

                while (await iter.MoveNext()) // 迭代

                {

                    iter.Current.Content.WriteTo(fs); // 将数据写入到文件流中

                }

            }

            Console.ReadKey();

        }

    }

}

文件生成成功

2.客户端流式RPC

1.定义 protofile

syntax = "proto3";

option csharp_namespace = "GRPC.TEST";

package Greet;

// The greeting service definition.

service Greeter {

  rpc getResult (stream Value) returns (Result) {}

}

//定义Value消息类型，用于客户端消息

message Value {

    int32 value = ;

}

//定义Result消息类型，包含总和，数字数量和平均值，用于服务端消息返回

message Result {

    int32 sum = ;

    int32 cnt = ;

    double avg = ;

}

2.实现服务端Service

重新生成项目，并实现如下

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Threading.Tasks;

using Google.Protobuf;

using Grpc.Core;

namespace GRPC.TEST

{

    public class GreeterService : Greeter.GreeterBase

    {

        public override async Task<Result> getResult(IAsyncStreamReader<Value> requestStream, ServerCallContext context)

        {

            while (await requestStream.MoveNext())

            {

                var point = requestStream.Current;

            }

            return new Result { Sum =  };

        }

    }

}

3.实现Client

新建一个netcore 3.0的Console项目，并引入Nuget包，安装nuget包与其他操作同上一个例子，实现代码如下

using Grpc.Net.Client;

using System;

using System.Collections.Generic;

using System.IO;

using System.Net.Http;

namespace GRPC.TEST.CLIENT

{

    class Program

    {

        static async System.Threading.Tasks.Task Main(string[] args)

        {

            AppContext.SetSwitch(

                 "System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport",

                 true);

            var httpClient = new HttpClient();

            // The port number(50051) must match the port of the gRPC server.

            httpClient.BaseAddress = new Uri("http://localhost:50051");

            var client = GrpcClient.Create<Greeter.GreeterClient>(httpClient);

            using (var call = client.getResult())

            {

                await call.RequestStream.WriteAsync(new Value { Value_ =  });

                await call.RequestStream.CompleteAsync();

                var response = await call.ResponseAsync;

            }

            Console.ReadKey();

        }

    }

}

3.双向流式RPC

1.定义proto

syntax = "proto3";

option csharp_namespace = "GRPC.TEST";

package Greet;

// The greeting service definition.

service Greeter {

  rpc getResult (stream Value) returns (stream Result) {}

}

//定义Value消息类型，用于客户端消息

message Value {

    int32 value = ;

}

//定义Result消息类型，包含总和，数字数量和平均值，用于服务端消息返回

message Result {

    int32 sum = ;

    int32 cnt = ;

    double avg = ;

}

2.服务端实现

重新生成项目，并实现如下

public override async Task getResult(IAsyncStreamReader<Value> requestStream, IServerStreamWriter<Result> responseStream, ServerCallContext context)

        {

            while (await requestStream.MoveNext())

            {

                var note = requestStream.Current;

                await responseStream.WriteAsync(new Result { Sum =  });

            }

        }

3.客户端代码

新建一个netcore 3.0的Console项目，并引入Nuget包，安装nuget包与其他操作同上一个例子，实现代码如下

using Grpc.Net.Client;

using System;

using System.Collections.Generic;

using System.IO;

using System.Net.Http;

using System.Threading.Tasks;

namespace GRPC.TEST.CLIENT

{

    class Program

    {

        static async System.Threading.Tasks.Task Main(string[] args)

        {

            AppContext.SetSwitch(

       "System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport",

       true);

            var httpClient = new HttpClient();

            // The port number(50051) must match the port of the gRPC server.

            httpClient.BaseAddress = new Uri("http://localhost:50051");

            var client = GrpcClient.Create<Greeter.GreeterClient>(httpClient);

            using (var call = client.getResult())

            {

                var responseReaderTask = Task.Run(async () =>

                {

                    while (await call.ResponseStream.MoveNext())

                    {

                        var note = call.ResponseStream.Current;

                        Console.WriteLine("Received " + note);

                    }

                });

                await call.RequestStream.WriteAsync(new Value { Value_ =  });

                await call.RequestStream.CompleteAsync();

                await responseReaderTask;

            }

            Console.ReadKey();

        }

    }

}

至此，GRPC的几种数据交互分享完毕

最新文章

  1. Xamarin.ios 目录结构
  2. Python成长笔记 - 基础篇 （七）python面向对象
  3. OAuth2.0 基础概述
  4. Xcode6中添加pch全局引用文件
  5. ASCII 字符代码表
  6. 求强连通分量模板（tarjan算法）
  7. c=$[$c%5]到let c=$c%5的转换
  8. atom编辑器启动后文件不能编辑的解决办法
  9. CSS 背景图片 添加 重复和定位。
  10. Spring监听，ApplicationListener
  11. 使用密钥认证机制远程登录Linux
  12. TOleControl(WebBrowser1).Visible := False 这样就可以隐藏浏览器控件
  13. Django xadmin 根据登录用户过滤数据
  14. tomcat报错catalina.sh: line 401: /usr/java/jdk1.7.52/bin/java: No such file or directory
  15. CentOS 6和CentOS 7防火墙的关闭
  16. 解决Android 5.0中出现的警告：Service Intent must be explicit
  17. 11-[CSS]-标准文档流，display，浮动，清除浮动，overflow
  18. Android逆向之旅---带你爆破一款应用的签名验证问题
  19. POSIX 消息队列 和 系列函数
  20. springmvc集成Freemarke配置的几点

热门文章

  1. C# TSF 输入法的获取
  2. js仿黑客帝国文字数字雨效果
  3. XF 开关控件
  4. WPF 代码实现动画
  5. IdentityServer学习目录
  6. MQTT开源代理Mosquitto源码分析（访问控制篇）
  7. 图像滤镜艺术---ZPhotoEngine超级算法库
  8. Win8 Metro(C#)数字图像处理--2.36角点检测算法
  9. LINQ查询表达式---------join子句
  10. SQLSERVER 数据库备份脚本-支持多库备份