// 添加节点 ``` ##### [](#qqukmp)（2）客户端配置信息 > - 命名：[命名空间].dll.json 文件夹(dllconfigs) ```json { "GrpcClient": { "Service": { "Name": "grpcservice", // 服务名称与服务端保持一致 "MaxRetry": 0, // 最大可重试次数，默认不重试 "Discovery": { "EndPoints": [ // 单点模式 { "Host": "127.0.0.1", "Port": 10001 } ], "Consul": { // Consul集群,集群优先原则 "Path": "dllconfigs/consulsettings.json" } } } } } ``` ```xml

``` ##### [](#wt0bso)（3）Consul配置文件 > - 命名：consulsettings.json 不要改动 ```json { "ConsulServer": { "Service": { "Address": "http://consul.g.lan" // 默认8500端口 } } } ``` ```xml

``` #### [](#meoyxy)3. 服务端的使用 #### [](#4n4nah)（1）NetCore > - 强制依赖注入模式 ```csharp services.AddSingleton(); // Grpc服务的实现 services.AddSingleton(); // Grpc服务启动服务类：如下 services.AddGrpcTracer(); // Grpc注入拦截器，继承IServerTracer（可选） ``` ```csharp 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); } } } ``` > - 实现类写法 ```csharp 原因：服务启动的时候是一个单例，那么所有服务之下的全部是单实例，而数据层需要使用多实例 // 只注入 IServiceProvider IServiceProvider _provider; public GrpcExampleServiceImpl(IServiceProvider provider) { _provider = provider; } // 其他利用provider即时获取 using(var scope = _provider.CreateSocpe()) { var _userService = scope.ServiceProvider.GetService(); } ``` #### [](#q9v0og)（2）Framework 4.6 > - 直接调用GrpcServiceManager来启动 ```csharp 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(); } } } ``` #### [](#zxcgny)4. 客户端使用 #### [](#egbtce)（1）NetCore > - 强制依赖注入模式 > - 配置文件默认使用 [命名空间].dll.json 可通过vs.menu工具生成nuget包 > - 注入中直接调用如下 ```csharp // 注入Grpc客户端 services.AddGrpcClient(); // 自定义配置文件 / 默认使用命名空间.dll.json services.Configure>((cfg) => { cfg.ConfigPath = "dllconfig/Overt.GrpcExample.Service.Grpc.dll.json"; // 可不传递 }); // 获取注入的对象 IGrpcClient _grpcClient; public IndexModel(IGrpcClient grpcClient) { _grpcClient = grpcClient; } var res = _grpcClient.Client.Ask(new Service.Grpc.AskRequest() { Key = "abc" }); ``` #### [](#4tuqar)（2）Framework > - 客户端代理类，编译在Dll中，源码如下，可忽略 ```csharp 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 configMap = new ConcurrentDictionary(); public static void Configure(string configPath) { configMap.AddOrUpdate(typeof(T), configPath, (t, s) => configPath); } public static string GetConfigure() { if (configMap.TryGetValue(typeof(T), out string configPath)) return configPath; return DefaultConfigPath; } } public class ClientManager : ClientManager where T : ClientBase { public static new T Instance { get { var configPath = GetConfigure(); var abConfigPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, configPath); return GrpcClientManager.Get(abConfigPath, Tracer); } } } #endif } ``` > - 使用代理类执行 ``` // 自定义配置文件 / 默认使用命名空间.dll.json / 在主进程入口进行配置T为服务Client ClientManger.Configure("dllconfig/abc.config"); ClientManager.Instance.[Method] // T为服务Client ClientManager.Instance.[Method] ``` #### [](#ut52ry)5. 更新说明 - 2019-11-28 v 1.0.3.1 > 1. 优化对Consul新版本的支持 - 2019-11-28 v 1.0.3 > 1. 注册中心监听到变动后，忽略黑名单，本地连接全部重置 - 2019-09-29 v 1.0.2 > 1. 客户端使用Consul注册中心，支持单服务变动监听，新注册服务或者服务挂掉，更加实时 - 2019-08-16 v 1.0.1 > 1. 支持多服务模式 - 2019-08-01 v 1.0.0 > 1. 修改命名空间，更新nuget包为Overt.Core.Grpc 更新默认版本为1.0.0 - 2019-06-05 v 1.0.10.2 > 1. 客户端优化连接服务失败的情况下，拉入黑名单，导致节点不存在的问题 - 2019-06-05 v 1.0.10 > 1. 升级Grpc版本为 1.21.0 > 2. 升级Google.Protobuf版本为3.8.0 - 2019-03-06 v 1.0.9
> 1. 升级Grpc版本为 1.19.0
> 2. Consul节点默认Passing > 3. ConsulSettings添加环境变量支持 - 2019-01-29 v 1.0.8 > 1. 升级Grpc版本为 1.18.0 > 2. 其他一系列升级以及Bug修复 - 2018-11-13 v 1.0.6.10 (****) > 1. 添加IServerTracer作为服务端拦截器接口，实现即可拦截 > 2. 添加IClientTracer作为客户端拦截器接口，实现即可拦截 > 3. 升级Google.Protobuf v 3.6.1 > 4. **重要**[下载地址](http://10.0.60.89:8082/) ```csharp Overt.Core.Grpc.dll Consul.dll Grpc.Core.dll Google.Protobuf.dll runtime/* libgrpc_* grpc_csharp_* App.config/Web.config ``` - 2018-11-10 v 1.0.6.9 > 1. 升级Grpc v1.16.0 支持Intercept - 2018-09-07 v 1.0.6.6 > 1. 影响服务端驱动 > 2. 更改ServciceHost获取以环境变量优先 - 2018-08-24 v 1.0.6.5 > 1. 影响客户端驱动 > 2. 修复发布过程中异常加入黑名单后，连接全部丢失问题 - 2018-08-21 v 1.0.6.4 > 1. 添加服务与Consul自检功能，升级Consul v0.7.2.6 / Grpc v1.14.1.0 > 2. 升级该版本需要同时发布**以下内容** ```csharp Overt.Core.Grpc.dll Consul.dll Grpc.Core.dll Google.Protobuf.dll runtime/* libgrpc_* grpc_csharp_* App.config/Web.config ``` ---