android系统定制开发springcloud ribbon 配置负载均衡策略以及自定义策略

一、android系统定制开发系统内置的策略有以下几种。

 android系统定制开发这个负载策略配置说白了就是让 android系统定制开发这个客户端负载均衡器怎么进行访问服务提供者列表。是轮流访问？随机访问？权重？等。

Ribbon 的策略
策略类    命名    说明
RandomRule    随机策略    随机选择 Server
RoundRobinRule    轮训策略    按顺序循环选择 Server
RetryRule    重试策略    在一个配置时问段内当选择 Server 不成功，则一直尝试选择一个可用的 Server
BestAvailableRule    最低并发策略    逐个考察 Server，如果 Server 断路器打开，则忽略，再选择其中并发连接最低的 Server
AvailabilityFilteringRule    可用过滤策略    过滤掉一直连接失败并被标记为 circuit tripped 的 Server，过滤掉那些高并发连接的 Server（active connections 超过配置的网值）
ResponseTimeWeightedRule    响应时间加权策略    根据 Server 的响应时间分配权重。响应时间越长，权重越低，被选择到的概率就越低；响应时间越短，权重越高，被选择到的概率就越高。这个策略很贴切，综合了各种因素，如：网络、磁盘、IO等，这些因素直接影响着响应时间
ZoneAvoidanceRule    区域权衡策略    综合判断 Server 所在区域的性能和 Server 的可用性轮询选择 Server，并且判定一个 AWS Zone 的运行性能是否可用，剔除不可用的 Zone 中的所有 Server
 

二、示例

1.只要在启动时创建一个IRule对象，注入容器，即可。因为系统内置的容器需要在真正 发起请求时才会创建，并且判断系统容器中没有IRule对象。

 

  1. @SpringBootApplication
  2. @Slf4j
  3. @EnableDiscoveryClient
  4. @RestController
  5. public class ConsumeApplication {
  6.  
  7.     @Autowired
  8.     RestTemplate restTemplate;
  9.  
  10.     @Bean
  11.     @LoadBalanced
  12.     public RestTemplate getRestTemplate(){
  13.         HttpComponentsClientHttpRequestFactory clientHttpRequestFactory = new HttpComponentsClientHttpRequestFactory();
  14.         clientHttpRequestFactory.setConnectTimeout(5 * 1000);
  15.         clientHttpRequestFactory.setReadTimeout(5 * 1000);
  16.         return new RestTemplate(clientHttpRequestFactory);
  17.     }
  18.  
  19.     @Bean
  20.     public IRule ribbonRule() {
  21.         return new RandomRule();
  22.     }
  23.  
  24.  
  25.  
  26.     public static void main(String[] args) {
  27.         SpringApplication.run(ConsumeApplication.class, args);
  28.     }
  29.     @GetMapping("test")
  30.     public String getContent(){
  31.         log.info("发起请求");
  32.         String ret =  restTemplate.getForObject("http://provider/provider",String.class);
  33.         return ret;
  34.     }
  35.  
  36. }

2.在创建ribbonLoadBalancer时就会使用最新的RULE

三、在发起调用时触发RULE的choose方法

 1.源码  ，这个很简单，就是随机取一个实例。

  1. package com.netflix.loadbalancer;
  2.  
  3. import java.util.List;
  4. import java.util.Random;
  5.  
  6. import com.netflix.client.config.IClientConfig;
  7.  
  8. /**
  9.  * A loadbalacing strategy that randomly distributes traffic amongst existing
  10.  * servers.
  11.  * 
  12.  * @author stonse
  13.  * 
  14.  */
  15. public class RandomRule extends AbstractLoadBalancerRule {
  16.     Random rand;
  17.  
  18.     public RandomRule() {
  19.         rand = new Random();
  20.     }
  21.  
  22.     /**
  23.      * Randomly choose from all living servers
  24.      */
  25.     @edu.umd.cs.findbugs.annotations.SuppressWarnings(value = "RCN_REDUNDANT_NULLCHECK_OF_NULL_VALUE")
  26.     public Server choose(ILoadBalancer lb, Object key) {
  27.         if (lb == null) {
  28.             return null;
  29.         }
  30.         Server server = null;
  31.  
  32.         while (server == null) {
  33.             if (Thread.interrupted()) {
  34.                 return null;
  35.             }
  36.             List<Server> upList = lb.getReachableServers();
  37.             List<Server> allList = lb.getAllServers();
  38.  
  39.             int serverCount = allList.size();
  40.             if (serverCount == 0) {
  41.                 /*
  42.                  * No servers. End regardless of pass, because subsequent passes
  43.                  * only get more restrictive.
  44.                  */
  45.                 return null;
  46.             }
  47.  
  48.             int index = rand.nextInt(serverCount);
  49.             server = upList.get(index);
  50.  
  51.             if (server == null) {
  52.                 /*
  53.                  * The only time this should happen is if the server list were
  54.                  * somehow trimmed. This is a transient condition. Retry after
  55.                  * yielding.
  56.                  */
  57.                 Thread.yield();
  58.                 continue;
  59.             }
  60.  
  61.             if (server.isAlive()) {
  62.                 return (server);
  63.             }
  64.  
  65.             // Shouldn't actually happen.. but must be transient or a bug.
  66.             server = null;
  67.             Thread.yield();
  68.         }
  70.         return server;
  72.     }

四、可以针对单个服务自定义IRULE规则。

1.编写IRULE

  1. package com.net.sample.consume;
  2.  
  3. import com.netflix.client.config.IClientConfig;
  4. import com.netflix.loadbalancer.AbstractLoadBalancerRule;
  5. import com.netflix.loadbalancer.ILoadBalancer;
  6. import com.netflix.loadbalancer.IRule;
  7. import com.netflix.loadbalancer.Server;
  8.  
  9. import java.util.List;
  10. import java.util.Random;
  11.  
  12. public class FirstRule extends AbstractLoadBalancerRule {
  13.  
  14.     public FirstRule() {
  15.  
  16.     }
  17.  
  18.     /**
  19.      * Randomly choose from all living servers
  20.      */
  21.     public Server choose(ILoadBalancer lb, Object key) {
  22.         if (lb == null) {
  23.             return null;
  24.         }
  25.         Server server = null;
  26.  
  27.         while (server == null) {
  28.             if (Thread.interrupted()) {
  29.                 return null;
  30.             }
  31.             List<Server> upList = lb.getReachableServers();
  32.             List<Server> allList = lb.getAllServers();
  33.  
  34.             int serverCount = allList.size();
  35.             if (serverCount == 0) {
  36.                 /*
  37.                  * No servers. End regardless of pass, because subsequent passes
  38.                  * only get more restrictive.
  39.                  */
  40.                 return null;
  41.             }
  42.  
  43.             int index = 0;
  44.             server = upList.get(index);
  45.  
  46.             if (server == null) {
  47.                 /*
  48.                  * The only time this should happen is if the server list were
  49.                  * somehow trimmed. This is a transient condition. Retry after
  50.                  * yielding.
  51.                  */
  52.                 Thread.yield();
  53.                 continue;
  54.             }
  55.  
  56.             if (server.isAlive()) {
  57.                 return (server);
  58.             }
  59.  
  60.             // Shouldn't actually happen.. but must be transient or a bug.
  61.             server = null;
  62.             Thread.yield();
  63.         }
  65.         return server;
  67.     }
  69.     @Override
  70.     public Server choose(Object key) {
  71.         return choose(getLoadBalancer(), key);
  72.     }
  74.     @Override
  75.     public void initWithNiwsConfig(IClientConfig clientConfig) {
  76.         // TODO Auto-generated method stub
  78.     }
  79. }

2.编写CONFIGIGATION,这个配置类不在程序启动初始化时加载，而是在请求时，由RIBBON内部的SpringClientFactory的子applicationContext来创建和实例化。

  1. package com.net.sample.consume;
  2.  
  3. import com.netflix.client.config.IClientConfig;
  4. import com.netflix.loadbalancer.IRule;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  7.  
  8. import javax.annotation.Resource;
  9.  
  10. @Configuration
  11. /** 用来标记使用的注解，方便排除或者引用 **/
  12. @AvoidScan
  13. public class RibbonFirstLoadBalancingConfiguration {
  14.  
  15.  
  16.     @Bean
  17.     public IRule ribbonRule() {
  18.         return new FirstRule();
  19.     }
  20.  
  21. }

3.启动类加上，启动时排除上面的配置的包。RibbonClient针对每个服务端进行单独的配置，就是configuation实例，由这个内部来创建IRULE,IRuleFilter,ServerList都可以自定义。

  1. @SpringBootApplication
  2. @Slf4j
  3. @EnableDiscoveryClient
  4. @RestController
  5. @ComponentScan(excludeFilters = @ComponentScan.Filter(type = FilterType.ANNOTATION,value = AvoidScan.class))
  6. @RibbonClient(name = "provider",configuration = RibbonFirstLoadBalancingConfiguration.class)
  7. public class ConsumeApplication {

 4.这里看到进入了我们自定义的IRULE规则选择服务实例。 

网站建设定制开发 软件系统开发定制 定制软件开发 软件开发定制 定制app开发 app开发定制 app开发定制公司 电商商城定制开发 定制小程序开发 定制开发小程序 客户管理系统开发定制 定制网站 定制开发 crm开发定制 开发公司 小程序开发定制 定制软件 收款定制开发 企业网站定制开发 定制化开发 android系统定制开发 定制小程序开发费用 定制设计 专注app软件定制开发 软件开发定制定制 知名网站建设定制 软件定制开发供应商 应用系统定制开发 软件系统定制开发 企业管理系统定制开发 系统定制开发