SpringCloud系列七：使用Ribbon实现客户端侧负载均衡

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

1. 回顾

在前面，已经实现了微服务的注册与发现。启动各个微服务时，Eureka Client会把自己的网络信息注册到Eureka Server上。

但是，在生成环境中，各个微服务都会部署多个实例，因此还行继续进行优化。

2. Ribbon简介

Ribbon是Netflix发布的负载均衡器，它有助于控制HTTP和TCP客户端的行为。为Ribbon配置服务提供者地址列表后，Ribbon就可基于某种负载均衡算法，

自动地帮助服务消费者去请求。Ribbon默认为我们提供了很多的负载均衡算法，例如轮询、随机等。我们也可为Ribbon实现自定义的负载均衡算法。

在Spring Cloud中，当Ribbon与Eureka配合使用时，Ribbon可自动从Eureka Server获取服务提供者地址列表，并基于负载均衡算法，请求其中一个服务提供者实例。

3. 为服务消费者整合Ribbon

> 复制项目 microservice-consumer-movice，修改ArtifactId为 microservice-consumer-movie-ribbon

> 为项目microservice-consumer-movie添加Ribbon的依赖。但是前文已经为该服务添加spring-cloud-starter-netflix-eureka-client依赖，

该依赖已经包含了 spring-cloud-starter-netflix-ribbon 依赖，所以无需再次引入。

> 在启动类中，为RestTemplate添加@LoadBalanced注解。

package com.itmuch.cloud.microserviceconsumermovie;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;

import org.springframework.context.annotation.Bean;

import org.springframework.web.client.RestTemplate;

@SpringBootApplication

@EnableDiscoveryClient

public class MicroserviceConsumerMovieApplication {

    public static void main(String[] args) {

        SpringApplication.run(MicroserviceConsumerMovieApplication.class, args);

    }

    @Bean

    @LoadBalanced // 实现负载均衡

    public RestTemplate restTemplate() {

        return new RestTemplate();

    }

}

> 修改MovieController类，便于发现是否实现负载均衡

package com.itmuch.cloud.microserviceconsumermovie.controller;

import com.itmuch.cloud.microserviceconsumermovie.pojo.User;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cloud.client.ServiceInstance;

import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.client.RestTemplate;

@RestController

public class MovieController {

    private static final Logger LOGGER = LoggerFactory.getLogger(MovieController.class);

    @Autowired

    private RestTemplate restTemplate;

    @Autowired

    private LoadBalancerClient loadBalancerClient;

    @GetMapping("/user/{id}")

    public User findById(@PathVariable Long id) {

        return this.restTemplate.getForObject("http://microservice-provider-user/" + id, User.class);

    }

    @GetMapping("/log-instance")

    public void logUserInstance() {

        ServiceInstance serviceInstance = this.loadBalancerClient.choose("microservice-provider-user");

        // 打印当前选择的是哪个节点

        MovieController.LOGGER.info("{}:{}:{}", serviceInstance.getServiceId(), serviceInstance.getHost(),

                serviceInstance.getPort());

    }

}