首页 开发教程 正文
我要发布

core grpc

开发教程
2025-12-07 0 940

如有疑问可直接加QQ：2292709323，微信：yaofengv，联系

  • Overt.Core.Grpc – Base Grpc.Core 谷歌自带
  • Overt.Core.Grpc.H2 – Base Grpc.Net 微软自带

Overt.Core.Grpc

项目层次说明

Overt.Core.Grpc v1.0.6
基于Google的Grpc.Core驱动，适用于Console服务场景，基于TCP长连接实现微服务场景

1. 项目目录

|-Config                                        配置模型
|
|-Client                                        客户端功能实现，服务发现
|
|-dllconfigs                                    配置文件保存
|
|-Intercept                                     拦截器
|-|-IServerTracer                               服务端拦截器接口
|-|-IClientTracer                               客户端拦截器接口
|  
|-Manager                                       启动、客户端调用类
|-|-GrpcServiceManager.cs                       服务端启动类
|-|-GrpcClientManager.cs                        客户端获取Client类
|
|-Service                                       服务端
|
|-GrpcServiceCollectionExtensions.cs            netcore注入

2. 版本及支持

  • Nuget版本：v1.0.6
  • 框架支持： Framewok 4.5 – 4.6 / NetStandard 2.0

3. 项目依赖

  • NetStandard 2.0
Consul 0.7.2.6  
Google.Protobuf 3.8.0
Grpc 1.21.0
Microsoft.Extensions.Configuration.Json 2.0.0
Microsoft.Extensions.Options.ConfigurationExtensions 2.0.0
  • Framwork 4.5 – 4.7
Consul 0.7.2.6  
Google.Protobuf 3.8.0
Grpc 1.21.0

使用

1. Nuget包引用

Install-Package Overt.Core.Grpc -Version 1.0.6

2. 配置信息

优先级：{第三方配置中心} > 环境变量 > Host内部配置 > 自动取IP内网

（1）服务端配置信息
  • 支持默认配置文件appsettings.json [Consul节点可不要，如无则不是集群]
{
  \"GrpcServer\": {
    \"Service\": {
      \"Name\": \"OvertGrpcServiceApp\",                    // 服务名称使用服务名称去除点：OvertGrpcServiceApp
      \"Host\": \"service.g.lan\",                          // 专用注册的域名 （可选）格式：ip[:port=default]
      \"HostEnv\": \"serviceaddress\",                      // 获取注册地址的环境变量名字（可选，优先）环境变量值格式：ip[:port=default]
      \"Port\": 10001,                                    // 端口自定义
      \"Consul\": {
        \"Path\": \"dllconfigs/consulsettings.json\"        // Consul路径
      }
    }
  }
}
// 添加section
<configSections>
  <section name=\"grpcServer\" type=\"Overt.Core.Grpc.GrpcServerSection, Overt.Core.Grpc\" />
</configSections>

// 添加节点
<grpcServer>
  <service name=\"OvertGrpcServiceApp\" port=\"10005\" host=\"专用注册的域名（可选）格式：ip[:port=default]\" hostEnv=\"获取注册地址的环境变量名字（可选）环境变量值格式：ip[:port=default]\">
    <registry>
      <consul path=\"dllconfigs/Consul.config\" />
    </registry>
  </service>
</grpcServer>
（2）客户端配置信息
  • 命名：[命名空间].dll.json 文件夹(dllconfigs)
{
  \"GrpcClient\": {
    \"Service\": {
      \"Name\": \"grpcservice\",                        // 服务名称与服务端保持一致
      \"MaxRetry\":  0,                               // 最大可重试次数，默认不重试
      \"Discovery\": {
        \"EndPoints\": [                              // 单点模式
          {
            \"Host\": \"127.0.0.1\",
            \"Port\": 10001
          }
        ],
        \"Consul\": {                                 // Consul集群,集群优先原则
          \"Path\": \"dllconfigs/consulsettings.json\"
        }
      }
    }
  }
}
<?xml version=\"1.0\" encoding=\"utf-8\" ?>
<configuration>
  <configSections>
    <section name=\"grpcClient\" type=\"Overt.Core.Grpc.GrpcClientSection, Overt.Core.Grpc\"/>
  </configSections>

  <grpcClient>
    <service name=\"\" maxRetry=\"0\">
      <discovery>
        <server>
          <endpoint host=\"\" port=\"\"></endpoint>
          <endpoint host=\"\" port=\"\"></endpoint>
        </server>
        <consul path=\"dllconfigs/Consul.config\"></consul>
      </discovery>
    </service>
  </grpcClient>
</configuration>
（3）Consul配置文件
  • 命名：consulsettings.json 不要改动
{
  \"ConsulServer\": {
    \"Service\": {
      \"Address\": \"http://consul.***g.lan\"     // 默认8500端口
    }
  }
}
<?xml version=\"1.0\" encoding=\"utf-8\" ?>
<configuration>
  <configSections>
    <section name=\"consulServer\" type=\"Overt.Core.Grpc.ConsulServerSection, Overt.Core.Grpc\"/>
  </configSections>
  <consulServer>
    <service address=\"http://consul.***g.lan\"></service>
  </consulServer>
</configuration>

3. 服务端的使用

（1）NetCore

  • 强制依赖注入模式
services.AddSingleton<GrpcExampleService.GrpcExampleServiceBase, GrpcExampleServiceImpl>();          // Grpc服务的实现
services.AddSingleton<IHostedService, GrpcExampleHostedService>();                                   // Grpc服务启动服务类：如下
services.AddGrpcTracer<ConsoleTracer>();                                                             // Grpc注入拦截器，继承IServerTracer（可选）

// 使用第三方配置
services.AddGrpcConfig(config => 
{
    // 以配置中心apollo为例
    config.AddApollo(context.Configuration.GetSection(\"apollo\")).AddDefault();
});
using Microsoft.Extensions.Hosting;
using Overt.Core.Grpc;
using Overt.GrpcExample.Service.Grpc;
using System.Threading;
using System.Threading.Tasks;

namespace Overt.GrpcService.App
{
    public class GrpcService : IHostedService
    {
        GrpcExampleService.GrpcExampleServiceBase _grpcServiceBase;
        IServerTracer _tracer;
        public GrpcService(GrpcExampleService.GrpcExampleServiceBase serviceBase, IServerTracer tracer)         // 依赖注入Grpc服务基础类
        {
            _serviceBase = serviceBase;
            _tracer = tracer;
        }


        public Task StartAsync(CancellationToken cancellationToken)
        {
            return Task.Factory.StartNew(() =>
            {
                GrpcServiceManager.Start(GrpcExampleService.BindService(_serviceBase), _tracer);
            }, cancellationToken);
        }

        public Task StopAsync(CancellationToken cancellationToken)
        {
            return Task.Factory.StartNew(() =>
            {
                GrpcServiceManager.Stop();
            }, cancellationToken);
        }
    }
}
  • 实现类写法
原因：服务启动的时候是一个单例，那么所有服务之下的全部是单实例，而数据层需要使用多实例

// 只注入 IServiceProvider
IServiceProvider _provider;
public GrpcExampleServiceImpl(IServiceProvider provider)
{
    _provider = provider;
}

// 其他利用provider即时获取
using(var scope = _provider.CreateSocpe())
{
    var _userService = scope.ServiceProvider.GetService<IUserService>();
}

（2）Framework 4.6

  • 直接调用GrpcServiceManager来启动
using Grpc.Core;
using Overt.Core.Grpc;
using Overt.Log;
using System;

namespace Overt.GrpcService
{
    public class MainService
    {
        public MainService()
        {
            
        }
        public void Start(string serviceName)               // 启动服务
        {
            GrpcServiceManager.Start(Library.GrpcService.BindService(new GrpcServiceImpl()), tracer: new ConsoleTracer(), whenException: (ex) =>
            {
                LogHelper.Info(\"\", ex);
            });
        }

        public void Stop(string serviceName)                // 停止服务
        {
            GrpcServiceManager.Stop();
        }
        public void ShutDown(string serviceName)
        {
            GrpcServiceManager.Stop();
        }
    }
}

4. 客户端使用

（1）NetCore

  • 强制依赖注入模式
  • 配置文件默认使用    [命名空间].dll.json     可通过vs.menu工具生成nuget包
  • 注入中直接调用如下
// 注入Grpc客户端
services.AddGrpcClient();

// 自定义配置文件 / 默认使用命名空间.dll.json
services.Configure<GrpcClientOptions<GrpcExampleServiceClient>>((cfg) =>
{
    cfg.ConfigPath = \"dllconfig/Overt.GrpcExample.Service.Grpc.dll.json\";  // 可不传递
});

// 使用第三方配置
services.AddGrpcConfig(config => 
{
    // 以配置中心apollo为例
    config.AddApollo(context.Configuration.GetSection(\"apollo\")).AddDefault();
});


// 获取注入的对象
IGrpcClient<GrpcExampleServiceClient> _grpcClient;
public IndexModel(IGrpcClient<GrpcExampleServiceClient> grpcClient)
{
    _grpcClient = grpcClient;
}


var res = _grpcClient.Client.Ask(new Service.Grpc.AskRequest() { Key = \"abc\" });

（2）Framework

  • 客户端代理类，编译在Dll中，源码如下，可忽略
using Grpc.Core;
using Overt.Core.Grpc;
using Overt.Core.Grpc.Intercept;
using System;
using System.Collections.Concurrent;
using System.IO;
using __GrpcService = Overt.GrpcExample.Service.Grpc.GrpcExampleService;
namespace Overt.GrpcExample.Service.Grpc
{
#if NET45 || NET46 || NET47
    public class ClientManager
    {
        public static IClientTracer Tracer { get; set; } = default(IClientTracer);
        private static string DefaultConfigPath { get; set; } = \"dllconfigs/Overt.GrpcExample.Service.Grpc.dll.config\";
        public static __GrpcService.GrpcExampleServiceClient Instance
        {
            get
            {
                return ClientManager<__GrpcService.GrpcExampleServiceClient>.Instance;
            }
        }
        private static readonly ConcurrentDictionary<Type, string> configMap = new ConcurrentDictionary<Type, string>();
        public static void Configure<T>(string configPath) { configMap.AddOrUpdate(typeof(T), configPath, (t, s) => configPath); }
        public static string GetConfigure<T>() { if (configMap.TryGetValue(typeof(T), out string configPath)) return configPath; return DefaultConfigPath; }
    }
    public class ClientManager<T> : ClientManager where T : ClientBase
    {
        public static new T Instance
        {
            get
            {
                var configPath = GetConfigure<T>();
                var abConfigPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, configPath);
                return GrpcClientManager<T>.Get(abConfigPath, Tracer);
            }
        }
    }
#endif
}
  • 使用代理类执行
// 自定义配置文件 / 默认使用命名空间.dll.json / 在主进程入口进行配置T为服务Client
ClientManger.Configure<T>(\"dllconfig/abc.config\");

ClientManager.Instance.[Method]

// T为服务Client
ClientManager<T>.Instance.[Method]

5. 更新说明

  • 2024-07-22 v1.0.9
  1. consul支持Token
  • 2022-04-06 v1.0.8
  1. 升级底层驱动为最新版本
  2. Grpc => 2.40.0
  • 2021-07-01 v1.0.7
  1. 升级底层驱动为最新版本
  2. Google.Protobuf => 3.17.3
  • 2021-03-31 v1.0.6
  1. 重构GrpcClientOptions
  2. 升级驱动为最新版本
  • 2021-03-30 v1.0.5
  1. Tracer提供修改Channel Target能力，可供外部自定义选择节点；
  2. 升级底层驱动为最新版本
  3. 增加自定义Interceptor的注入
  4. 调整ServiceStart的参数配置，使用GrpcOptions进行承接
  5. 增加invokers的自定义获取，增加ServiceId的获取
  6. 支持framework版本的自定义invoker获取策略
  • 2021-02-25 v1.0.4.1
  1. 增加第三方配置的支持，比如apollo，可使用services.AddGrpcConfig进行扩展(目前仅支持dotnetcore)
  • 2019-11-28 v1.0.3.1
  1. 优化对Consul新版本的支持
  • 2019-11-28 v1.0.3
  1. 注册中心监听到变动后，忽略黑名单，本地连接全部重置
  • 2019-09-29 v1.0.2
  1. 客户端使用Consul注册中心，支持单服务变动监听，新注册服务或者服务挂掉，更加实时
  • 2019-08-16 v1.0.1
  1. 支持多服务模式
  • 2019-08-01 v1.0.0
  1. 修改命名空间，更新nuget包为Overt.Core.Grpc 更新默认版本为1.0.0
  • 2019-06-05 v1.0.0.1
  1. 客户端优化连接服务失败的情况下，拉入黑名单，导致节点不存在的问题

Overt.Core.Grpc.H2

项目层次说明

Overt.Core.Grpc.H2 v2.0.1
用于>= netcoreapp3.0版本，用于http2协议，依赖微软的grpc.net，适用于Web服务场景，基于http2实现微服务场景

1. 项目目录

|-Config                                        配置模型
|
|-Client                                        客户端功能实现，服务发现
|
|-dllconfigs                                    配置文件保存
|
|-Service                                       服务端
|
|-GrpcServiceCollectionExtensions.cs            netcore注入

2. 版本及支持

  • Nuget版本：V 2.0.1
  • 框架支持： netstandard2.1 / netcoreapp3.0 / net5.0 / net6.0

3. 项目依赖

Consul 1.6.10.7
Google.Protobuf 3.21.5
Grpc.Net.Client 2.47.0
Microsoft.Extensions.Configuration.Json 5.0.0
Microsoft.Extensions.Options.ConfigurationExtensions 5.0.0

使用

1. Nuget包引用

Install-Package Overt.Core.Grpc.H2 -Version 2.1.0

2. 配置信息

优先级：{第三方配置中心} > 环境变量 > Host内部配置 > 自动取IP+启动端口内网

（1）服务端配置信息
  • 支持默认配置文件appsettings.json [Consul节点可不要，如无则不是集群]
{
  \"GrpcServer\": {
    \"Service\": {
      \"Name\": \"OvertGrpcServiceApp\",                    // 服务名称使用服务名称去除点：OvertGrpcServiceApp
      \"Host\": \"service.g.lan\",                          // 专用注册的域名 （可选）格式：ip[:port=default]
      \"HostEnv\": \"serviceaddress\",                      // 获取注册地址的环境变量名字（可选，优先）环境变量值格式：ip[:port=default]
      \"Port\": 10001,                                    // 端口自定义
      \"Consul\": {
        \"Path\": \"dllconfigs/consulsettings.json\"        // Consul路径
      }
    }
  }
}
（2）客户端配置信息
  • 命名：[命名空间].dll.json 文件夹(dllconfigs)
{
  \"GrpcClient\": {
    \"Service\": {
      \"Name\": \"grpcservice\",                        // 服务名称与服务端保持一致
      \"Scheme\":  \"http\",                            // foraddress 协议 http/https
      \"Discovery\": {
        \"EndPoints\": [                              // 单点模式
          {
            \"Host\": \"127.0.0.1\",
            \"Port\": 10001
          }
        ],
        \"Consul\": {                                 // Consul集群,集群优先原则
          \"Path\": \"dllconfigs/consulsettings.json\"
        }
      }
    }
  }
}
（3）Consul配置文件
  • 命名：consulsettings.json 不要改动
{

下载源码

通过命令行克隆项目:

git clone https://github.com/overtly/core-grpc.git

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在
点赞 (0)

申明：本文由第三方发布，内容仅代表作者观点，与本网站无关。对本文以及其中全部或者部分内容的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。本网发布或转载文章出于传递更多信息之目的，并不意味着赞同其观点或证实其描述，也不代表本网对其真实性负责。

左子网 开发教程 core grpc https://www.zuozi.net/31662.html

CachingFramework.Redis
上一篇： CachingFramework.Redis
HelloAbp
下一篇： HelloAbp
常见问题

发货方式是什么？

  • 1、自动：拍下后，点击（下载）链接即可下载；2、手动：拍下后，联系卖家发放即可或者联系官方找开发者发货。
查看详情

交易周期是多久呢？

  • 1、源码默认交易周期：手动发货商品为1-3天，并且用户付款金额将会进入平台担保直到交易完成或者3-7天即可发放，如遇纠纷无限期延长收款金额直至纠纷解决或者退款！；
查看详情

能退款么？

  • 1、描述：源码描述(含标题)与实际源码不一致的（例：货不对板）； 2、演示：有演示站时，与实际源码小于95%一致的（但描述中有”不保证完全一样、有变化的可能性”类似显著声明的除外）； 3、发货：不发货可无理由退款； 4、安装：免费提供安装服务的源码但卖家不履行的； 5、收费：价格虚标，额外收取其他费用的（但描述中有显著声明或双方交易前有商定的除外）； 6、其他：如质量方面的硬性常规问题BUG等。 注：经核实符合上述任一，均支持退款，但卖家予以积极解决问题则除外。
查看详情

注意事项

  • 1、左子会对双方交易的过程及交易商品的快照进行永久存档，以确保交易的真实、有效、安全！ 2、左子无法对如“永久包更新”、“永久技术支持”等类似交易之后的商家承诺做担保，请买家自行鉴别； 3、在源码同时有网站演示与图片演示，且站演与图演不一致时，默认按图演作为纠纷评判依据（特别声明或有商定除外）； 4、在没有”无任何正当退款依据”的前提下，商品写有”一旦售出，概不支持退款”等类似的声明，视为无效声明； 5、在未拍下前，双方在QQ上所商定的交易内容，亦可成为纠纷评判依据（商定与描述冲突时，商定为准）； 6、因聊天记录可作为纠纷评判依据，故双方联系时，只与对方在左子上所留的QQ、手机号沟通，以防对方不承认自我承诺。 7、虽然交易产生纠纷的几率很小，但一定要保留如聊天记录、手机短信等这样的重要信息，以防产生纠纷时便于左子介入快速处理。
查看详情

相关文章

猜你喜欢
发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务

联系官方团队 在线提交工单
TA的动态
左子网

分享最新WordPress教程共同学习，共同进步，共同成长！

QQ交流群
左子网

QQ交流群

您的支持，是我们最大的动力！
热门文章
热门标签
随机推荐
热门评论
终身VIP会员限时钜惠
首页 源码 菜单 案例 我的