Ribbon(一) 负载均衡基础-如何配置负载均衡并测试

素颜马尾好姑娘i 2022-12-13 14:24 139阅读 0赞

在spring cloud的服务注册与发现中，我们在Eureka Client中当要使用服务消费者调用服务的时候，是通过负载均衡方式调用的。一般的用法如下：

1.在配置类中，声明一个RestTemplate的bean，用@LoadBalanced注解修饰：

//一个配置类:由spring托管
    @SpringBootConfiguration
    public class AppConfig {
        @Bean //创建一个 restTemplate 的模板操作对象
        @LoadBalanced    // 加入负载均衡.   此处的负载均衡是全局配置
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

以上表示在一个配置类中，通过spring 容器创建一个restTemplate,并交给容器托管，同时给restTemplate加入负载均衡功能.

2.在进行http调用的地方，通过@Autowired方式，注入RestTemplate，再通过restTemplate调用。调用时，写服务名就可以，比如按照下面这种方式调用。

@Service
    public class ProductController {
        //直接访问eureka中的服务名即可,这样 ribbon会拉取到服务实例列表，再利用负载均衡算法获取一个服务.
        private final static String RESTURI="http://MICROSERVICE-PROVIDER-PRODUCT/";
    
        @Autowired
        private RestTemplate restTemplate;
       
        public Product get(Integer id) {
            return restTemplate.getForObject(RESTURI+"product/get/"+id, Product.class);
        }
    
    }

通过这两步操作，进行调用时，就可以通过服务名，得到多个服务实例的信息，通过负载均衡的方式进行调用。

那么如何测试并得知当前负载均衡起作用了呢?

我们可以在程序中注入一个 LoadBalancerClient的对象，它封装了一个服务提供方的元信息，然后再输出它的信息，即可了解到底是谁提供了服务.

@Resource
     private LoadBalancerClient loadBalancerClient;   //服务提供方法信息

@Service
    public class ProductController {
        //直接访问eureka中的服务名即可,这样 ribbon会拉取到服务实例列表，再利用负载均衡算法获取一个服务.
        private final static String RESTURI="http://MICROSERVICE-PROVIDER-PRODUCT/";
    
        @Autowired
        private RestTemplate restTemplate;
    
         @Resource
        private LoadBalancerClient loadBalancerClient;   //服务提供方法信息
       
        public Product get(Integer id) {
            //获取服务提供方信息
            ServiceInstance serviceInstance = this.loadBalancerClient.choose("MICROSERVICE-PROVIDER-PRODUCT") ;
            System.out.println(
                    "【*** 服务提供实例信息 ***】host = " + serviceInstance.getHost()
                            + "、port = " + serviceInstance.getPort()
                            + "、serviceId = " + serviceInstance.getServiceId());
            return restTemplate.getForObject(RESTURI+"product/get/"+id, Product.class);
        }  
    }

可以通过IDEA的输出查看结果,请仔细分析输出结果:

1. 首先我注册了三个服务实例在服务名 **MICROSERVICE-PROVIDER-PRODUCT 下. **

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70][]

2. 运行消费端，访问消费端多次，查看输出的结果.  [http://localhost:9999/consumer/product/get/1][http_localhost_9999_consumer_product_get_1]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70 1][]

3. 在IDEA的控制台，会出现以下信息，试分析:

2020-10-12 15:58:36.611  INFO 3312 --- [nio-9999-exec-1] c.n.l.DynamicServerListLoadBalancer      : DynamicServerListLoadBalancer for client MICROSERVICE-PROVIDER-PRODUCT initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=MICROSERVICE-PROVIDER-PRODUCT,current list of Servers=[192.168.1.20:8889, 192.168.1.20:8888, 192.168.1.20:8890],Load balancer stats=Zone stats: {defaultzone=[Zone:defaultzone;	Instance count:3;	Active connections count: 0;	Circuit breaker tripped count: 0;	Active connections per server: 0.0;]
    },Server stats: [[Server:192.168.1.20:8888;	Zone:defaultZone;	Total Requests:0;	Successive connection failure:0;	Total blackout seconds:0;	Last connection made:Thu Jan 01 08:00:00 CST 1970;	First connection made: Thu Jan 01 08:00:00 CST 1970;	Active Connections:0;	total failure count in last (1000) msecs:0;	average resp time:0.0;	90 percentile resp time:0.0;	95 percentile resp time:0.0;	min resp time:0.0;	max resp time:0.0;	stddev resp time:0.0]
    , [Server:192.168.1.20:8890;	Zone:defaultZone;	Total Requests:0;	Successive connection failure:0;	Total blackout seconds:0;	Last connection made:Thu Jan 01 08:00:00 CST 1970;	First connection made: Thu Jan 01 08:00:00 CST 1970;	Active Connections:0;	total failure count in last (1000) msecs:0;	average resp time:0.0;	90 percentile resp time:0.0;	95 percentile resp time:0.0;	min resp time:0.0;	max resp time:0.0;	stddev resp time:0.0]
    , [Server:192.168.1.20:8889;	Zone:defaultZone;	Total Requests:0;	Successive connection failure:0;	Total blackout seconds:0;	Last connection made:Thu Jan 01 08:00:00 CST 1970;	First connection made: Thu Jan 01 08:00:00 CST 1970;	Active Connections:0;	total failure count in last (1000) msecs:0;	average resp time:0.0;	90 percentile resp time:0.0;	95 percentile resp time:0.0;	min resp time:0.0;	max resp time:0.0;	stddev resp time:0.0]
    ]}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@3551b1ad

以上可以明显看到服务提供者的IP都为192.168.1.20,端口分别为 8888,8889,8890. ,这说明已经注册到Eureka中,并被ribbon拉取到，形成服务列表( ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@3551b1ad ).

在访问n次消费端后，控制台的输出如下,试分析:

【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8889、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8890、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    2020-10-12 15:58:37.595  INFO 3312 --- [erListUpdater-0] c.netflix.config.ChainedDynamicProperty  : Flipping property: MICROSERVICE-PROVIDER-PRODUCT.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8888、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8889、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8890、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8888、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8889、serviceId = MICROSERVICE-PROVIDER-PRODUCT
    【*** 服务提供实例信息 ***】host = 192.168.1.20、port = 8890、serviceId = MICROSERVICE-PROVIDER-PRODUCT

三个服务被轮流的访问到了，这是一种轮询的负载均衡策略( ribbon默认的策略）。通过这种策略，可以将访问请求均匀地定位到各个服务提供的服务器上.

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70]: /images/20221123/741b51af7e2343e0b13cd4e63f391687.png
[http_localhost_9999_consumer_product_get_1]: http://localhost:9999/consumer/product/get/1
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70 1]: /images/20221123/5cbbf93bfd3542cda3f50b71c1c947cd.png