surging English

surging ,RPCZookeeperConsulsurgingRPCnettythrift

surging

,,,.net core surging.net core,

CRUD

service host,eventbus,rpc

docker k8srancherdocker

2.ServiceId RoutePath

3.surging

6. Devops,

docker hub : docker pull serviceengine/surging:

nuget:Install-Package surging -Version

var host = new ServiceHostBuilder()
               .RegisterServices(builder =>
               {
                   builder.AddMicroService(option =>
                   {
                       option.AddServiceRuntime();//
                       option.AddRelateService();//
                        option.AddConfigurationWatch();//
                       // 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
                     //  option.UseProtoBufferCodec();//protobuf
                       option.UseMessagePackCodec();//MessagePack
                       builder.Register(p => new CPlatformContainer(ServiceLocator.Current));//
                   });
               })
               .SubscribeAt()     //
             //.UseServer("127.0.0.1", 98)
             //.UseServer("127.0.0.1", 98true) //Token
             //.UseServer("127.0.0.1", 98123456789) //Token
               .UseServer(options=> {
                   options.Ip = "127.0.0.1";
                   options.Port = 98;
                   //options.IpEndpoint = new IPEndPoint(IPAddress.Any, 98);
                   //options.Ip = "0.0.0.0";
                   options.ExecutionTimeoutInMilliseconds = 30000; //
                   options.Strategy=(int)StrategyType.Failover; //
                   options.RequestCacheEnabled=true; //
                   options.Injection="return null"; //
                   options.InjectionNamespaces= new string[] { "Surging.IModuleServices.Common" }); //
                   options.BreakeErrorThresholdPercentage=50;  //
                   options.BreakeSleepWindowInMilliseconds=60000; //
                   options.BreakerForceClosed=false;   //
                   options.BreakerRequestVolumeThreshold = 20;//10
                   options.MaxConcurrentRequests=100000;//
                   options.ShuntStrategy=AddressSelectorMode.Polling; //
                   options.NotRelatedAssemblyFiles = "Centa.Agency.Application.DTO\\w*|StackExchange.Redis\\w*"; //
               })
               //.UseLog4net("Configs/log4net.config") //log4net
               .UseNLog(LogLevel.Error, "Configs/NLog.config")// NLog 
               //.UseLog4net(LogLevel.Error) //log4net
               //.UseLog4net()  //log4net
               .Configure(build =>
               build.AddEventBusFile("eventBusSettings.json", optional: false))//eventBusSettings.json
               .Configure(build =>
                build.AddCacheFile("cacheSettings.json", optional: false))//cacheSettings.json
               .UseProxy() //Proxy
               .UseStartup<Startup>()
               .Build();
               
           using (host.Run())
           {
               Console.WriteLine($"{DateTime.Now}");
           }

{
  "ConnectionString": "${Register_Conn}|127.0.0.1:8500", // ${} |,
  "SessionTimeout": "${Register_SessionTimeout}|50",
  "ReloadOnChange": true
}

 {
  "Ip": "${Server_IP}|127.0.0.1",
  "WatchInterval": 30,
  "Port": "${Server_port}",
  "Token": "true",
   "Protocol": "${Protocol}|Tcp", //Http,Tcp
  "RootPath": "${RootPath}",
  "RequestCacheEnabled": false
}

 {
  "Ip": "${Server_IP}|0.0.0.0",//IP
  "WatchInterval": 30,
  "Port": "${Server_port}|98",//
   "MappingIp": "${Mapping_ip}",//IP
  "MappingPort": "${Mapping_Port}",//
   "Protocol": "${Protocol}|Tcp", //Http,Tcp
  "Token": "true",
  "RootPath": "${RootPath}",
  "RequestCacheEnabled": false
}

[ServiceBundle("api/{Service}")]

JWT

   [Authorization(AuthType = AuthorizationType.JWT)];

AppSecret

 [Authorization(AuthType = AuthorizationType.AppSecret)];

 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)]

[CacheKey(1)]

 .AddClientIntercepted(typeof(CacheProviderInterceptor))

surging

IDE:Visual Studio 2017 15.5,vscode
.NET core 2.1
QQ615562965