脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 网络编程 → ASP.NET → 实用技巧 → .NET Core中gRPC使用

.NET Core(.NET6)中gRPC使用实践

 更新时间：2022年04月14日 10:37:47   作者：包子wxl  
gRPC是高性能的远程过程调用（RPC）框架，本文主要介绍了.NET Core(.NET6)中gRPC使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

一、简介

简单解析一下gRPC，gRPC 是一个由Google开源的，跨语言的，高性能的远程过程调用（RPC）框架。

特点：

  • 跨语言
  • 内容protobuf格式（比json体积小）,网络传输快
  • 使用HTTP/2进行传输

适合高性能轻量的微服务，一般对外的接口用restful api，内部服务的调用用gRPC。gRPC是一个分布式服务框架，和以前的WebService，WCF类似。

二、创建gRPC服务端

1.创建gRPC项目

新建一个gRPC模板的项目

特别的地方就这里4点。

1.基于http2来通信。

2.proto协议文件，greet.proto是项目默认给我们的一个hello world的示例。它会根据协议自动生成需要的类。

3.服务类，Greeter.GreeterBase来自于2中的proto文件自动生成的类，生成的类在\obj\Debug\net6.0\Protos 目录下。

自动生成的类：

4.Program.cs添加了gRPC服务，和把GreeterService注册到管道中。

2.编写自己的服务

怎么样写自己的调用服务呢？

1.创建proto文件

参照上面的示例创建自己的Proto文件

代码:

syntax = "proto3";

option csharp_namespace = "GrpcDemo.Service";

package order;

// 订单服务定义
service Order {
  // 创建订单
  rpc CreateOrder (CreateRequest) returns (CreateResult);
  //查询订单
  rpc QueryOrder (QueryRequest) returns (QueryResult);
}

//创建订单请求参数
message CreateRequest {
  string orderNo = 1;
  string orderName=2;
  double price=3;
}

//创建订单返回结果
message CreateResult {
  bool result = 1;
  string message=2;
}

//查询订单请求参数
message QueryRequest{
    int id=1;
}
//查询订单返回结果
message QueryResult{
    int id=1;
    string orderNo=2;
    string orderName=3;
    double price=4;
}

生成一下就能看到对应的类已经生成了。

2.实现定义的服务

创建OrderService.cs

public class OrderService:Order.OrderBase
    {
        private readonly ILogger<GreeterService> _logger;
        public OrderService(ILogger<GreeterService> logger)
        {
            _logger = logger;
        }
        /// <summary>
        /// 创建订单
        /// </summary>
        /// <param name="request"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        public override Task<CreateResult> CreateOrder(CreateRequest request, ServerCallContext context)
        {
            //报存数据库 todo

            return Task.FromResult(new CreateResult
            {
                Result=true,
                Message="订单创建成功"
            });
        }
        /// <summary>
        /// 查询订单
        /// </summary>
        /// <param name="request"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        public override Task<QueryResult> QueryOrder(QueryRequest request, ServerCallContext context)
        {
            //查询数据库 //todo

            return Task.FromResult(new QueryResult
            {
                OrderInfo=new OrderInfo
                {
                    Id = request.Id,
                    OrderNo = DateTime.Now.ToString("yyyyMMddHHmmss"),
                    OrderName = "冰箱",
                    Price = 1288
                }
            });
        }
    }

继承的Order.OrderBase 是上面的proto文件生成的，然后实现了proto里面定义的两个服务。

然后在program.cs里面把服务注入管道。

到这里服务端就完成了，就可以启动服务端了。

浏览器访问不了，要通过gRPC客户端才能访问，下面就建一个gRPC客户端。

三、创建gRPC客户端

1.创建客户端项目

1.1、这里创建一个控制台程序。

1.2、然后添加Nuget包

Google.Protobuf
Grpc.Net.Client
Grpc.Tools
Grpc.Net.clientFactory

1.3、把服务端的proto文件拷贝过来

1.4、编辑项目文件，把proto里面的内容替换掉，默认是服务端的配置

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

生成的时候，客户端也生成了对应proto的类

2.grPC服务https的调用

因为服务端提供了http和https的端口，这里先调用https的

创建GrpcRequestTest.cs类

/// <summary>
    /// gRPC请求测试
    /// </summary>
    public class GrpcRequestTest
    {
        public void CreateOrder()
        {
            //常规使用，https
            string url = "https://localhost:7246";
            using(var channel=GrpcChannel.ForAddress(url))
            {
                var client = new Order.OrderClient(channel);
                var reply = client.CreateOrder(new CreateRequest()
                {
                    OrderNo = DateTime.Now.ToString("yyyMMddHHmmss"),
                    OrderName = "冰箱22款",
                    Price = 1688
                });

                Console.WriteLine($"结果:{reply.Result},message:{reply.Message}");
            }
            Console.ReadKey();
        }
    }

结果：

3.gRPC内网http调用

public void CreateOrder()
        {
             //使用http
            AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
            string url = "http://localhost:5246";

            using(var channel=GrpcChannel.ForAddress(url))
            {
                var client = new Order.OrderClient(channel);
                var reply = client.CreateOrder(new CreateRequest()
                {
                    OrderNo = DateTime.Now.ToString("yyyMMddHHmmss"),
                    OrderName = "冰箱22款",
                    Price = 1688
                });

                Console.WriteLine($"结果:{reply.Result},message:{reply.Message}");
            }
            Console.ReadKey();
        }

比起https，前面多了一行。结果：

4.IOC注入的方式调用gRPC

4.1、program.cs里面注入gRPCClient

// See https://aka.ms/new-console-template for more information
using GrpcDemo.Client;
using GrpcDemo.Service;
using Microsoft.Extensions.DependencyInjection;

Console.WriteLine("Hello, World!");

IServiceCollection services = new ServiceCollection();
services.AddTransient<GrpcRequestTest>();

#region gRPC Client注册
AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
services.AddGrpcClient<Order.OrderClient>(options =>
{
    options.Address = new Uri("http://localhost:5246");
}).ConfigureChannel(grpcOptions =>
{
    //可以完成各种配置，比如token
});
#endregion

//构建容器
IServiceProvider serviceProvider = services.BuildServiceProvider();
//解析grpc请求测试
var grpcRequestTest = serviceProvider.GetService<GrpcRequestTest>();
//执行
grpcRequestTest.CreateOrder();

grpcRequestTest里代码：

/// <summary>
    /// gRPC请求测试
    /// </summary>
    public class GrpcRequestTest
    {
        private Order.OrderClient _orderClient;
        public GrpcRequestTest(Order.OrderClient orderClient)
        {
            _orderClient = orderClient;
        }
        public void CreateOrder()
        {
            var reply = _orderClient.CreateOrder(new CreateRequest()
            {
                OrderNo = DateTime.Now.ToString("yyyMMddHHmmss"),
                OrderName = "冰箱22款",
                Price = 1688
            });
            Console.WriteLine($"结果:{reply.Result},message:{reply.Message}");
            Console.ReadKey();
        }
    }

结果：

四、webapi中加入gRPC

通常我们的服务有对外提供对外接口，又要对内提供gRPC服务，那怎么做呢，下面在webapi中加入gRPC服务

1.创建asp.net core mvc项目

2.安装nuget包

Grpc.AspNetCore

3.添加protebuf文件

把上面的proto文件复制过来

4.添加Service

public class OrderService : Order.OrderBase
    {
        private readonly ILogger<OrderService> _logger;
        public OrderService(ILogger<OrderService> logger)
        {
            _logger = logger;
        }
        /// <summary>
        /// 创建订单
        /// </summary>
        /// <param name="request"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        public override Task<CreateResult> CreateOrder(CreateRequest request, ServerCallContext context)
        {
            //报存数据库 todo

            return Task.FromResult(new CreateResult
            {
                Result = true,
                Message = "订单创建成功"
            });
        }
        /// <summary>
        /// 查询订单
        /// </summary>
        /// <param name="request"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        public override Task<QueryResult> QueryOrder(QueryRequest request, ServerCallContext context)
        {
            //查询数据库 //todo

            return Task.FromResult(new QueryResult
            {
                OrderInfo = new OrderInfo
                {
                    Id = request.Id,
                    OrderNo = DateTime.Now.ToString("yyyyMMddHHmmss"),
                    OrderName = "冰箱",
                    Price = 1288
                }
            });
        }
    }

5.注册gRPC服务

在Program.cs文件中

到这里，就把gRPC加入到webapi里面了。

6.验证

启动asp.net core mvc程序

浏览器能访问，证明restful api是没问题的。

然后再用上面的客户端访问一下gRPC的服务。

结果：

这样就成功对外提供api接口和对内提供gRPC服务了。

源码地址：https://github.com/weixiaolong325/GrpcDemo.Service

到此这篇关于.NET Core(.NET6)中gRPC使用实践的文章就介绍到这了,更多相关.NET Core中gRPC使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • .NET实现文件跨服务器上传下载的方法

    .NET实现文件跨服务器上传下载的方法

    这篇文章主要给大家介绍了.NET文件如何实现跨服务器上传下载的方法，文中通过图片介绍的很详细，相信对大家的理解和学习具有一定的参考借鉴价值，有需要的朋友们可以跟着小编来一起学习学习吧。
    2016-12-12
  • WCF如何绑定netTcpBinding寄宿到控制台应用程序详解

    WCF如何绑定netTcpBinding寄宿到控制台应用程序详解

    这篇文章主要给大家介绍了关于WCF如何绑定netTcpBinding寄宿到控制台应用程序的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用WCF具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2019-07-07
  • .NET Core自定义配置文件

    .NET Core自定义配置文件

    这篇文章介绍了.NET Core自定义配置文件的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-07-07
  • .NET MAUI项目中创建超链接

    .NET MAUI项目中创建超链接

    这篇文章介绍了.NET MAUI项目中创建超链接的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-03-03
  • asp.net中调用winrar实现压缩解压缩的代码

    asp.net中调用winrar实现压缩解压缩的代码

    asp.net压缩解压缩，需要服务器安装WinRar，并且把Rar.exe拷贝到网站根目录。这样我们就可以方面的执行压缩解压缩了。
    2008-09-09
  • asp.net core实现文件上传功能

    asp.net core实现文件上传功能

    这篇文章主要为大家详细介绍了asp.net core实现文件上传功能，怎么做单文件和多文件上传，感兴趣的小伙伴们可以参考一下
    2016-06-06
  • 深入理解.NET对象的内存布局

    深入理解.NET对象的内存布局

    在.NET中，理解对象的内存布局是非常重要的，这将帮助我们更好地理解.NET的运行机制和优化代码，本文将介绍.NET中的对象内存布局，感兴趣的可以了解一下
    2023-08-08
  • asp.net slickupload 使用方法(文件上传)

    asp.net slickupload 使用方法(文件上传)

    asp.net下使用slickupload上传文件的代码
    2009-05-05
  • asp.net GridView和DataList实现鼠标移到行行变色

    asp.net GridView和DataList实现鼠标移到行行变色

    在设计页面添加了DataList控件后，我在使用DataList绑定数据时是通过单元格来绑定的,因此鼠标效果就在源代码页面去实现
    2009-02-02
  • ASP.NET过滤器的应用方法介绍

    ASP.NET过滤器的应用方法介绍

    ASP.NET过滤器的应用方法介绍，需要的朋友可以参考一下
    2013-06-06

最新评论