企业为了确保事情顺利完成而实施的过程，包括最佳实践、架构原则、治理规程、规律以及其他决定性的因素。

　　我理解的就是服务治理就是一颗药，用来治疗服务之间存在的各种疑难杂症从而能让他正常的运行起来。

 

　　为了提高可用性、降低延迟，同一个服务可能会部署多个实例，负载均衡就是为了在服务的多个实例之间进行分配负载，已达到优化资源使用、最大化吞吐率，同时避免过载。

　　服务的流量可能是动态的，如果流量增加，超过服务承载范围，就会影响用户掩。通过限制服务能使用的资源，当监控到流量超过设定的阈值时，服务拒绝处理新的用户请求。当系统压力过大时，对系统的非核心业务进行限流，避免因压力过大导致整个系统奔溃。

　　生产环境中的每个微服务并不是具有百分百的可靠。服务之间跨网络调用，增加了调用失败的可能性。因此，如何保证微服务系统的可靠性，也变得更为复杂和困难。所以，微服务系统在设计之初就需要考虑容错机制，当系统负载过高时，可以确保核心业务不被破坏，以及当某个服务出错时，把影响范围降低到最小，避免整个系统不可用。

　　服务在运行过程中，需要和其他服务协作，同时他也会依赖基础设施或其他服务完成某项业务功能。在这个过程中，就需要多样化的配置信息。源码中硬编码配置信息，虽然实现成本低，但是这种方式不仅缺乏灵活性，而且容易造成信息泄露。因此，较好的方式是将配置与代码分离。采用独立于代码的外部机制存储配置信息。

　　当有rpc请求时，负载均衡策略决定那个子通道即grpc服务器将接收请求。（当前实现的负载算法有随机数与轮询算法）

　　使用方式是在配置文件中直接设置：

　　

  1. "Consul": {
  2.     "ConnectionString": "192.168.180.55:8500",
  3.     "IsHealthCheck": true,
  4.     "Strategy":"Random" //负载策略 Random（随机算法），Polling（轮询算法）
  5.   }

 

　   容错限流配置需要在属性上面设置

　  Service 声明为服务类型

　　HystrixCommand 设置限流 容错，超时等机制

  1.     [Service(Name = "grpc.domain.RpcTest")]
  2.     public class HelloService : RpcTest.RpcTestBase
  3.     {       
  4.         [HystrixCommand(MethodName = nameof(SayHello), ExcuteTimeoutInMilliseconds = 3000)]
  5.         public override async Task<HelloReponse> SayHello(HelloRequest request, ServerCallContext context)
  6.         {           
  7.             var result = await _cache.GetAsync<string>("a");
  9.             return new HelloReponse()
  10.             {
  11.                 Code = 1,
  12.                 Msg = "hello simple",
  13.                 Result = JsonConvert.SerializeObject(result)
  14.             };
  15.         }        
  16.     }

　　HystrixCommand 可配置治理功能　　

  1.     public class HystrixCommandAttribute : Attribute
  2.     {
  3.         public string MethodName { get; set; }
  5.         /// <summary>
  6.         /// 执行超时时间
  7.         /// </summary>
  8.         public int ExcuteTimeoutInMilliseconds { get; set; } = 10000;
  10.         /// <summary>
  11.         /// 最大信号量
  12.         /// </summary>
  13.         public int MaxRequests { get; set; } = 0;
  15.         /// <summary>
  16.         /// 最大信号量的限定时间
  17.         /// 默认1s
  18.         /// </summary>
  19.         public int MaxRequestsTime { get; set; } = 1000;
  21.         /// <summary>
  22.         /// 至少多少请求失败，熔断器才发挥起作用
  23.         /// </summary>
  24.         public int BreakerRequestCircuitBreaker { get; set; } = 10;
  26.         /// <summary>
  27.         /// 是否开启服务降级
  28.         /// </summary>
  29.         public bool EnableServiceDegradation { get; set; }
  31.         /// <summary>
  32.         /// 降级缓存类型
  33.         /// </summary>
  34.         public CacheModel Cache { get; set; } = CacheModel.Memory;
  36.         /// <summary>
  37.         /// 降级缓存时间
  38.         /// 单位 秒
  39.         /// </summary>
  40.         public int ServiceDegradationTimeSpan { get; set; } = 10;
  41.     }

QQ群：592407137 期待大家一起研究，学习~~

开源不易，如果喜欢，请给予一个Start 给予支持。谢谢！

版权声明：本文为alangur原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/alangur/p/12965908.html