故如虹,知恩;故如月,知明
排名
6
文章
6
粉丝
16
评论
8
{{item.articleTitle}}
{{item.blogName}} : {{item.content}}
ICP备案 :渝ICP备18016597号-1
网站信息:2018-2024TNBLOG.NET
技术交流:群号656732739
联系我们:contact@tnblog.net
欢迎加群交流技术

.net core 3.0 gRPC自定义服务

5903人阅读 2020/1/31 21:56 总访问:3837998 评论:0 收藏:0 手机
分类: .NET Core


服务器端


新建gRPC项目


右键Protos文件夹-->新建一个.proto,选择协议缓冲区文件,用于描述gRPC的消息和服务

名字随便取,这里就叫UpImg吧

然后把包名,服务名称,参数和返回值名称都修改一下

把默认的方法名SayHello和参数与返回值也修改一下

修改成我们自己定义的参数和返回值

新建一个UpImgService,实现我们刚刚上面定义的gRPC服务描述UpImg.proto

注意直接实现是找不到新建的服务的

因为还没有在obj\Debug\netcoreapp3.0下面生成相应的类

需要双击我们项目编辑csproj文件,把新建的UpImg.proto加入到配置中

加入配置中后保存一下在obj\Debug\netcoreapp3.0中即可生成相应的类

然后继续实现UpImg.proto,实现很简单注意参数和返回值即可


客户端

客户端需要添加包:Grpc.Net.Client、Google.Protobuf、Grpc.Tools

  <ItemGroup>
    <PackageReference Include="Google.Protobuf" Version="3.11.2" />
    <PackageReference Include="Grpc.Net.Client" Version="2.26.0" />
    <PackageReference Include="Grpc.Tools" Version="2.26.0">
      <PrivateAssets>all</PrivateAssets>
      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
    </PackageReference>
  </ItemGroup>


把UpImg.proto复制到客户端中的Proto(这里使用的是直接复制进去)


同样在客户端加入配置,加入配置和客户端会自动生成相应的代码

然后调用即可:

public async void UpLoad()
{
    //设置允许不安全的HTTP2支持
    AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
    var channel = GrpcChannel.ForAddress("http://localhost:50001");
    var client = new UpImg.UpImgClient(channel);
    var reply = await client.DoUpLoadAsync(new UpImgRequest { Img = "hello girl" });
    Console.WriteLine(reply.Message);
}


gRPC调用由于目标计算机积极拒绝,无法连接。
修改端口设置,可能是https造成的

代码:

public static IHostBuilder CreateHostBuilder(string[] args) =>
    Host.CreateDefaultBuilder(args)
        .ConfigureWebHostDefaults(webBuilder =>
        {
            webBuilder.ConfigureKestrel(options => {

                options.ListenLocalhost(8099,a=>a.Protocols= Microsoft.AspNetCore.Server.Kestrel.Core.HttpProtocols.Http2);
            });

            webBuilder.UseStartup<Startup>();
        });


还有可能出错Grpc.Core.RpcException:“Status(StatusCode=Unimplemented, Detail="Service is unimplemented.")”
以为你还没有启动你调用的那个服务


教学视频下载地址:
https://download.tnblog.net/resource/index/b957af70490347dcb0f6ddb2d5ceff21

代码下载地址:
https://download.tnblog.net/resource/index/e44c600a2647443f90ca5285ddc8660f

欢迎加群讨论技术,群:677373950(满了,可以加,但通过不了),2群:656732739

评价