surging English
surging 是一个分布式微服务框架,提供高性能RPC远程服务调用，采用Zookeeper、Consul作为surging服务的注册中心，集成了哈希，随机，轮询作为负载均衡的算法，RPC集成采用的是netty框架，采用异步传输。
启动配置：
var host = new ServiceHostBuilder() .RegisterServices(option=> { option.Initialize(); //初始化服务 option.RegisterServices();//依赖注入领域服务 option.RegisterRepositories();//依赖注入仓储 option.RegisterModules();//依赖注入第三方模块 option.RegisterServiceBus();//依赖注入ServiceBus }) .RegisterServices(builder => { builder.AddMicroService(option => { option.AddServiceRuntime();// // option.UseZooKeeperManager(new ConfigInfo("127.0.0.1:2181")); //使用Zookeeper管理 option.UseConsulManager(new ConfigInfo("127.0.0.1:8500"));//使用Consul管理 option.UseDotNettyTransport();//使用Netty传输 option.UseRabbitMQTransport();//使用rabbitmq 传输 option.AddRabbitMQAdapt();//基于rabbitmq的消费的服务适配 builder.Register(p => new CPlatformContainer(ServiceLocator.Current));//初始化注入容器 }); }) .SubscribeAt() //消息订阅 .UseServer("127.0.0.1", 98) //.UseServer("127.0.0.1", 98，“true”) //自动生成Token //.UseServer("127.0.0.1", 98，“123456789”) //固定密码Token .UseStartup<Startup>() .Build(); using (host.Run()) { Console.WriteLine($"服务端启动成功，{DateTime.Now}。"); }服务路由访问配置：
[ServiceBundle("api/{Service}")]订阅功能：
ServiceLocator.GetService< ISubscriptionAdapt >().SubscribeAt();增加服务容错、服务容错降级、服务强制降级
- 增加容错策略Injection，脚本注入：
[Command(Strategy= StrategyType.Injection ,Injection = @"return null;")][Command(Strategy= StrategyType.Injection ,Injection = @"return Task.FromResult(new Surging.IModuleServices.Common.Models.UserModel { Name=""fanly"", Age=18 });",InjectionNamespaces =new string[] { "Surging.IModuleServices.Common"})] - 增加容错策略Injection，本地模块注入：
[Command(Strategy= StrategyType.Injection ,Injection = @"return true;")] 增加缓存降级，怎么使用？
在业务接口方法上添加如下特性
[Command(Strategy= StrategyType.Failover,FailoverCluster =3,RequestCacheEnabled =true)] //RequestCacheEnabled =true 就是启用缓存怎么拦截获取缓存
在业务接口方法上添加如下特性
[InterceptMethod(CachingMethod.Get, Key = "GetUser_id_{0}", Mode = CacheTargetType.Redis, Time = 480)]怎么拦截删除缓存
在业务接口方法上添加如下特性
[InterceptMethod(CachingMethod.Remove, "GetUser_id_{0}", "GetUserName_name_{0}", Mode = CacheTargetType.Redis)]怎么添加缓存KEY
在业务模型属性上添加，如下特性，可以支持多个
[CacheKey(1)]配置拦截器
.AddClientIntercepted(typeof(CacheProviderInterceptor))IDE:Visual Studio 2017 15.3 Preview ,vscode
框架：.NET core 2.0
如有任何问题可以加入QQ群：615562965
[博客园]:https://www.cnblogs.com/fanliang11