core grpc
1.0.0
Wenn Sie Fragen haben, fügen Sie bitte direkt QQ: 2292709323, WeChat: yaofengv, Kontakt hinzu
Overt.Core.Grpc v1.0.6
Basierend auf dem Grpc.Core-Treiber von Google eignet es sich für Konsolendienstszenarien und implementiert Mikrodienstszenarien basierend auf langen TCP-Verbindungen.
|-Config 配置模型
|
|-Client 客户端功能实现，服务发现
|
|-dllconfigs 配置文件保存
|
|-Intercept 拦截器
|-|-IServerTracer 服务端拦截器接口
|-|-IClientTracer 客户端拦截器接口
|
|-Manager 启动、客户端调用类
|-|-GrpcServiceManager.cs 服务端启动类
|-|-GrpcClientManager.cs 客户端获取Client类
|
|-Service 服务端
|
|-GrpcServiceCollectionExtensions.cs netcore注入
- Nuget-Version: v1.0.6
- Framework-Unterstützung: Framewok 4.5 - 4.6 / NetStandard 2.0
- 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
- Rahmen 4.5-4.7
Consul 0.7 .2 .6
Google . Protobuf 3.8 .0
Grpc 1.21 .0 Install - Package Overt . Core . Grpc - Version 1.0 .6 Priorität: {Third Party Configuration Center} > Umgebungsvariablen > Interne Hostkonfiguration > IP- Intranet automatisch abrufen
- Unterstützen Sie die Standardkonfigurationsdatei appsettings.json [Consul-Knoten ist nicht erforderlich, andernfalls handelt es sich nicht um einen Cluster]
{
"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 >
- Benennung: Ordner [namespace].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 >
- Name: consulsettings.json Nicht ändern
{
"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 >
- Abhängigkeitsinjektionsmodus erzwingen
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 ) ;
}
}
}
- Schreiben von Implementierungsklassen
原因：服务启动的时候是一个单例，那么所有服务之下的全部是单实例，而数据层需要使用多实例
// 只注入 IServiceProvider
IServiceProvider _provider ;
public GrpcExampleServiceImpl ( IServiceProvider provider )
{
_provider = provider ;
}
// 其他利用provider即时获取
using ( var scope = _provider . CreateSocpe ( ) )
{
var _userService = scope . ServiceProvider . GetService < IUserService > ( ) ;
}
- Rufen Sie zum Starten direkt GrpcServiceManager auf
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 ( ) ;
}
}
}
- Abhängigkeitsinjektionsmodus erzwingen
- Die Konfigurationsdatei verwendet standardmäßig [namespace].dll.json. Nuget-Pakete können über das vs.menu-Tool generiert werden.
- Rufen Sie während der Injektion direkt Folgendes auf:
// 注入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" } ) ;
- Die in DLL kompilierte Client-Proxy-Klasse lautet wie folgt und kann ignoriert werden
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
}
- Mit Proxy-Klasse ausführen
// 自定义配置文件 / 默认使用命名空间.dll.json / 在主进程入口进行配置T为服务Client
ClientManger.Configure<T>("dllconfig/abc.config");
ClientManager.Instance.[Method]
// T为服务Client
ClientManager<T>.Instance.[Method]
- Konsul unterstützt Token
- Aktualisieren Sie den zugrunde liegenden Treiber auf die neueste Version
- Grpc => 2.40.0
- Aktualisieren Sie den zugrunde liegenden Treiber auf die neueste Version
- Google.Protobuf => 3.17.3
- GrpcClientOptions umgestalten
- Aktualisieren Sie den Treiber auf die neueste Version
- Tracer bietet die Möglichkeit, das Kanalziel zu ändern und so eine externe benutzerdefinierte Auswahl von Knoten zu ermöglichen.
- Aktualisieren Sie den zugrunde liegenden Treiber auf die neueste Version
- Fügen Sie eine benutzerdefinierte Interceptor-Injektion hinzu
- Passen Sie die Parameterkonfiguration von ServiceStart an und nehmen Sie dies mit GrpcOptions vor.
- Erhöhen Sie die benutzerdefinierte Erfassung von Aufrufern und erhöhen Sie die Erfassung von ServiceId
- Unterstützung einer benutzerdefinierten Aufrufer-Erfassungsstrategie für die Framework-Version
- Fügen Sie Unterstützung für Konfigurationen von Drittanbietern hinzu, z. B. Apollo, die mithilfe von Services.AddGrpcConfig erweitert werden können (derzeit wird nur Dotnetcore unterstützt).
- Optimieren Sie die Unterstützung für neue Versionen von Consul
- Nachdem das Registrierungscenter die Änderungen erkennt, ignoriert es die Blacklist und setzt alle lokalen Verbindungen zurück.
- Der Kunde nutzt das Consul-Registrierungscenter, um die Überwachung einzelner Dienständerungen, neuer Registrierungsdienste oder Dienstausfälle in Echtzeit zu unterstützen
- Unterstützt den Multi-Service-Modus
- Ändern Sie den Namespace, aktualisieren Sie das Nuget-Paket auf Overt.Core.Grpc und aktualisieren Sie die Standardversion auf 1.0.0
- Wenn der Client den Verbindungsdienst nicht optimieren kann, wird er auf die schwarze Liste gesetzt, was zu dem Problem führt, dass der Knoten nicht vorhanden ist.
Overt.Core.Grpc.H2 v2.0.1
Wird für die Version >= netcoreapp3.0 verwendet, wird für das http2-Protokoll verwendet, basiert auf grpc.net von Microsoft, ist für Webdienstszenarien geeignet und implementiert Mikrodienstszenarien basierend auf http2
|-Config 配置模型
|
|-Client 客户端功能实现，服务发现
|
|-dllconfigs 配置文件保存
|
|-Service 服务端
|
|-GrpcServiceCollectionExtensions.cs netcore注入
- Nuget-Version: V 2.0.1
- Framework-Unterstützung: netstandard2.1/netcoreapp3.0/net5.0/net6.0
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 Install - Package Overt . Core . Grpc . H2 - Version 2.1 .0 Priorität: {Third Party Configuration Center} > Umgebungsvariablen > Interne Hostkonfiguration > IP + Startport- Intranet automatisch beziehen
- Unterstützen Sie die Standardkonfigurationsdatei appsettings.json [Consul-Knoten ist nicht erforderlich, andernfalls handelt es sich nicht um einen Cluster]
{
"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路径
}
}
}
}
- Benennung: Ordner [namespace].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 "
}
}
}
}
}
- Name: consulsettings.json Nicht ändern
{
"ConsulServer" : {
"Service" : {
"Address" : " http://consul.g.lan " // 默认8500端口
}
}
}
- Konsul registrieren
public void ConfigureServices ( IServiceCollection services )
{
.. .
// 其他
.. .
services . AddGrpcService ( ) ; // 应用关闭时，节点可自动移除
// 按需使用第三方配置
services . AddGrpcConfig ( config =>
{
// 以配置中心apollo为例
config . AddApollo ( context . Configuration . GetSection ( "apollo" ) ) . AddDefault ( ) ;
} ) ;
}
public void Configure ( IApplicationBuilder app , IWebHostEnvironment env )
{
.. .
// 其他
.. .
app . UseGrpcRegister ( ) ;
}
- Abhängigkeitsinjektionsmodus erzwingen
- Die Konfigurationsdatei verwendet standardmäßig [namespace].dll.json. Nuget-Pakete können über das vs.menu-Tool generiert werden.
- Rufen Sie während der Injektion direkt Folgendes auf:
// 注入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" } ) ; 1.NET5_0_OR_GREATER unterstützt Subchannel, Resolver und LoadBalancer sowie Anpassung
- Unterstützen Sie externe Konfigurationszentren wie Apollo
- Unterstützt die Konfiguration der Codeänderungsdatei
- AddHostedService
- Die erste Version basiert auf Microsofts Treiber grpc.net und ist an net5.0 angepasst
