Spring Cloud Ribbon实现客户端负载均衡的示例

时间：2021-04-03 07:46:17|栏目：JAVA代码|点击：次

前面我们已经完成了注册中心和服务提供者两个基础组件。本文就介绍使用Spring Cloud Ribbon在客户端负载均衡的调用服务。

对于大型应用系统负载均衡(LB:Load Balancing)是首要被解决一个问题。在微服务之前LB方案主要是集中式负载均衡方案，在服务消费者和服务提供者之间又一个独立的LB，LB通常是专门的硬件，如F5，或者是基于软件的，如VS、HAproxy等。LB上有所有服务的地址映射表，当服务消费者调用某个目标服务时，它先向LB发起请求，由LB以某种策略（比如：Round-Robin）做负载均衡后将请求转发到目标服务。

而微服务的出现，则为LB的实现提供了另外一种思路：把LB的功能以库的方式集成到服务消费方的进程内，而不是由一个集中的设备或服务器提供。这种方案称为软负载均衡（Soft Load Balancing）或者客户端负载均衡。在Spring Cloud中配合Eureka的服务注册功能，Ribbon子项目则为REST客户端实现了负载均衡。

使用Spring Cloud Ribbon实现服务消费者

新建spring-cloud-sample-tutorial-consumer项目

在spring-cloud-sample-tutorial下新建spring-cloud-sample-tutorial-consumer子项目

添加ribbon和eureka依赖

<dependencies>
 <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka</artifactId>
 </dependency>
 <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-ribbon</artifactId>
 </dependency>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
</dependencies>

配置applicatioin.properties，注册中心地址

spring.application.name=consumer
server.port=30001
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

编写UserController，添加@LoadBalanced注解，启用Ribbon负载均衡

@Controller
@RequestMapping("user")
public class UserController {
 
 @Bean
 @LoadBalanced
 RestTemplate initRestTemplate(){
  return new RestTemplate();
 }
 
 @Autowired
 private RestTemplate restTemplate;
 
 @RequestMapping("add")
 @ResponseBody
 public String add(String userName, String age){
  return restTemplate.getForEntity("http://PRODUCER/user/add",String.class,userName,age).getBody();
 }
}

编写ConsumerApplication，添加@EnableEurekaClient，启用服务注册

@EnableEurekaClient
@SpringBootApplication
public class ConsumerApplication {
 public static void main(String[] args) {
  SpringApplication.run(ConsumerApplication.class,args);
 }
}

集群部署Producer

为了模拟集群的Producer,在producer项目中新建application-profile1.properties和application-profile2.properties。

application-profile1.properties

spring.application.name=producer
server.port=20001
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

application-profile2.properties

spring.application.name=producer
server.port=20002
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

为了测试负载的效果，我们把被调用服务的端口打出来

@Controller
@RequestMapping("user")
public class UserController {
 private Logger logger = LoggerFactory.getLogger(getClass());
 
 @Autowired
 private DiscoveryClient client;
 @RequestMapping("add")
 @ResponseBody
 public String addUser(String userName, String age) {
  return "Success from " + client.getLocalServiceInstance().getHost() + ":" + client.getLocalServiceInstance().getPort() ;
 }
}

启动测试

启动注册中心

分别配置Active Profiles为profile1和profile2，启动两次，完成注册中心集群的服务启动。