SpringCloud 负载均衡

Spring Cloud 负载均衡


  
1. 概念

负责均衡 (Load Balance，简称LB)，是高并发、高可用系统必不可少的关键组件。
当服务流量增大时，通常会采用增加机器的方式来进行扩容，负载均衡就是用来在多个机器大概其它资源中按照肯定的规则合理分配负载
   类似于在公司中，一个团队最开始只有一个人，后来随着工作量的增加，公司又雇用了几个人，就要思量到负载均衡，如何把工作量均衡的分配到这几个人身上，从而提高整个团队的效率！
  2. 分类

负责均衡分为服务端负载均衡和客户端负载均衡:
2.1 服务端负载均衡

在服务端进行负责均衡的算法分配，比较有名的服务端负载均衡器是Nginx，请求先到达Nginx负载均衡器，然后通过负载均衡算法，在多个服务器之间选择一个进行访问：

2.2 客户端负载均衡

在客户端进行负载均衡的算法分配.
把负责均衡的功能以库的方式集成到客户端，而不再是由一台指定的负载均衡设备集中提供
   比如Spring Cloud的Ribbon，请求发送到客户端，客户端从注册中央(如Eureka)获取服务列表，在发送请求前通过负载均衡算法选择一个服务器，然后进行访问
  

Ribbon是Spring Cloud早期的默认实现，由于如今已不再维护，最新版本的Spring Cloud负载均衡集成的是由Spring Cloud官方维护的 Spring Cloud LoadBalancer
3. Spring Cloud LoadBalancer

在SpringCloud中，我们使用Spring Cloud LoadBalancer来实现负载均衡，使用方式如下

• 给RestTemplate这个Bean添加 @LoadBalanced注解
  
  1. package com.order.config;
  3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.web.client.RestTemplate;
  8. @Configuration
  9. public class BeanConfig {
  10.    
  11.     @Bean
  12.     @LoadBalanced
  13.     public RestTemplate restTemplate() {
  14.         return new RestTemplate();
  15.     }
  17. }

  复制代码
• 修改IP端标语为服务名称(OrderServiceImpl)
  
  1. package com.order.service.Impl;
  3. import com.order.mapper.OrderMapper;
  4. import com.order.model.OrderInfo;
  5. import com.order.model.ProductInfo;
  6. import com.order.service.OrderService;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.cloud.client.ServiceInstance;
  9. import org.springframework.cloud.client.discovery.DiscoveryClient;
  10. import org.springframework.stereotype.Service;
  11. import org.springframework.web.client.RestTemplate;
  13. import java.util.List;
  15. @Service
  16. public class OrderServiceImpl implements OrderService {
  18.     @Autowired
  19.     private OrderMapper orderMapper;
  21.     @Autowired
  22.     private DiscoveryClient discoveryClient;
  24.     @Autowired
  25.     private RestTemplate restTemplate;
  26.     @Override
  27.     public OrderInfo selectOrderById(Integer orderId) {
  29.         OrderInfo orderInfo = orderMapper.selectOrderById(orderId);
  30. //        String url = "http://127.0.0.1:9090/product/" + orderInfo.getProductId();
  31.         String url = "http://product-service/product/" + orderInfo.getProductId();
  32.         ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);
  33.         orderInfo.setProductInfo(productInfo);
  34.         return orderInfo;
  35.     }
  36. }

  复制代码
• 启动多个product-service实例
  先复制一份实例：
  
  
  
  更改实例名称，并修改选项：
  
  
  
  选择 Add VM options 选项：
  
  
  
  添加 -Dserver.port=自定义端标语
  
  
  
  

部署好后同时启动多个product-service实例，并革新eureka-server：

可以看到新创建的几个实例都加入了注册中央！
这个时间我们来调用order-service服务，并多次革新调用，可以看到每个product-service都被均衡的调用到了！

4. 负载均衡策略

负载均衡策略是一种头脑，无论是哪种负载均衡器，它们的负载均衡策略都是相似的。Spring Cloud LoadBalancer 仅支持两种负载均衡策略：轮询策略 和 随机策略：

• 轮询(Round Robin)：指服务器轮番处理用户的请求，这个一种实现最简单，也最常用的策略
  
• 随机选择(Random)：随机选择一个后端服务器来处理新的请求
  

Spring Cloud LoadBalancer 默认负载均衡策略是 轮询策略，实现的是RoundRobinLoadBalancer，如果服务的消费者需要采用随机的负载均衡策略也可以自行定义：
   参考官网所在：Spring Cloud LoadBalancer :: Spring Cloud Commons
  详细操作：

• 定义随机算法对象，通过@Bean将器加载到Spring容器中
  
  1. package com.order.config;
  3. import org.springframework.cloud.client.ServiceInstance;
  4. import org.springframework.cloud.loadbalancer.core.RandomLoadBalancer;
  5. import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
  6. import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
  7. import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.core.env.Environment;
  11. public class LoadBalancerClient {
  12.     @Bean
  13.     ReactorLoadBalancer<ServiceInstance> randomLoadBalancer(Environment environment,
  14.                                                             LoadBalancerClientFactory loadBalancerClientFactory) {
  15.         String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
  16.         return new RandomLoadBalancer(loadBalancerClientFactory
  17.                 .getLazyProvider(name, ServiceInstanceListSupplier.class),
  18.                 name);
  19.     }
  20. }

  复制代码
• 在RestTemplate配置类上方使用@LoadBalancerClient 大概 @LoadBalancerClients 注解(根据不同的服务提供方配配置不同的客户端负载均衡算法策略，这里我们使用@LoadBalancerClient )
  
  1. package com.order.config;
  3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  4. import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClient;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  7. import org.springframework.web.client.RestTemplate;
  9. @LoadBalancerClient(name = "product-service", configuration = CustomLoadBalancerConfiguration.class)
  10. @Configuration
  11. public class BeanConfig {
  13.     @Bean
  14.     @LoadBalanced
  15.     public RestTemplate restTemplate() {
  16.         return new RestTemplate();
  17.     }
  19. }

  复制代码
  注：@LoadBalancerClient注解中的name表示该负载均衡策略对哪个服务生效(服务提供方)，Configuration表示该负载均衡器使用哪个负载均衡策略。
  配置完成后，后续对product-service服务实例的调用就是随机的了！！
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。