Spring Cloud：第三章：Ribbon客服端負載均衡

負載均衡是對系統的高可用、網絡壓力的緩解和處理能力擴容的重要手段。了解Ribbon對于我們使用Spring Cloud來講非常的重要。它是一個基于Http和TCP的用戶端負載均衡工具。它不像服務注冊中心、配置中心、API網關那樣獨立部署，但是它幾乎存在于每個微服務的基礎設施中。

基于Ribbon+RestTemplate的用法

1、引入依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>

注意：Eureka預設內建了Ribbon，隻需引入Eureka JAR即可。

2、在啟動類中注入配置

package com.mimaxueyuan.consumer.robbin;
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.context.annotation.Primary;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableDiscoveryClient
public class RibbonConsumerApplication {

    @Bean
    @LoadBalanced // 需要使用負載均衡,必須與Bean一同使用
    public RestTemplate balanceRestTemplate() {
        return new RestTemplate();
    }
    
    @Primary //自動裝配時當出現多個Bean候選者時，被注解為@Primary的Bean将作為首選者，否則将抛出異常 
    @Bean //需要多個RestTemplate, 有的RestTemplate使用負載均衡，有的不使用,不使用的不增加@LoadBalanced注解
    public RestTemplate noBalanceRestTemplate() {
        return new RestTemplate();
    }
    
    public static void main(String[] args) {
        SpringApplication.run(RibbonConsumerApplication.class, args);
    }

}

3、編寫 Controller——示範使用負載均衡和不使用負載均衡的用法及差別

package com.mimaxueyuan.consumer.robbin.controller;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient;
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;
import com.mimaxueyuan.consumer.entity.User;

@RestController
public class RibbonController {

    // 注入restTemplate, 這個類已經在RibbonConsumerApplication中初始化,不使用負載均衡
    @Autowired
    private RestTemplate noBalanceRestTemplate;

    // 注入restTemplate, 這個類已經在RibbonConsumerApplication中初始化,并且使用負載均衡
    @Autowired // 預設按照類型注入,如果需要按照名字注入需要使用@Qualifier注解
    //@LoadBalanced //使用帶有負載均衡的RestTemplate
    @Qualifier("balanceRestTemplate")
    private RestTemplate balanceRestTemplate;

    // 以下注入負載均衡用戶端LoadBalancerClient是一個接口,下面隻有一個RibbonLoadBalancerClient實作類
    @Autowired
    private LoadBalancerClient loadBalancerClient;
    @Autowired
    private RibbonLoadBalancerClient ribbonLoadBalancerClient;

    /**
     * 不使用ribbon的舊調用方式
     *
     * @author Kevin
     * @Title: old
     * @return
     * @return: String
     */
    @GetMapping("/ribbon/old/get/{id}")
    public String old(@PathVariable("id") String id) {
        
        // 使用noBalanceRestTemplate是非負載均衡的,是以沒問題
        String result = noBalanceRestTemplate.getForObject("http://localhost:9907/get/"+id, String.class);
        System.out.println("[hardcode1]" + result);
        
        // 由于balanceRestTemplate已經使用了Ribbon做負載均衡,是以使用寫死方式就不允許了,會提示:No instances available for localhost
        result = balanceRestTemplate.getForObject("http://localhost:9907/get/"+id, String.class);
        System.out.println("[hardcode2]" + result);
        
        return "result";
    }

    /**
     * ribbon使用
     *
     * @author Kevin
     * @Title: ribbon 
     * @param id
     * @return
     * @return: String
     */
    @GetMapping("/ribbon/get/{id}")
    public String ribbon(@PathVariable("id") String id) {
        // -----------------以下代碼使用ribbon做用戶端負載均衡
        // 使用provider的instanceName替代ip和端口的寫死
        String result = balanceRestTemplate.getForObject("http://mima-cloud-producer/get/"+id, String.class);
        System.out.println("[ribbon]" + result);

        System.out.println("[loadBalancerClient]choose的結果,代表負載均衡之後要選擇的服務執行個體");
        ServiceInstance instance = loadBalancerClient.choose("mima-cloud-producer");
        System.out.println("host:" + instance.getHost() + ",port:" + instance.getPort() + ",serviceId=" + instance.getServiceId() + ",uri=" + instance.getUri());

        System.out.println("[ribbonLoadBalancerClient]choose的結果,代表負載均衡之後要選擇的服務執行個體");
        instance = ribbonLoadBalancerClient.choose("mima-cloud-producer");
        System.out.println("host:" + instance.getHost() + ",port:" + instance.getPort() + ",serviceId=" + instance.getServiceId() + ",uri=" + instance.getUri());
        
        System.out.println("[ribbonLoadBalancerClient]choose的結果,代表負載均衡之後要選擇的服務執行個體");
        instance = ribbonLoadBalancerClient.choose("mima-cloud-producer");
        System.out.println("host:" + instance.getHost() + ",port:" + instance.getPort() + ",serviceId=" + instance.getServiceId() + ",uri=" + instance.getUri());
        try {
            // 根據負載均衡後的服務,建構一個通路url
            // 第二個參數不能為null
            System.out.println("根據負載均衡後的服務,建構一個通路url");
            URI reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI(""));
            System.out.println("reconstructURI1-yes:" + reconstructURI);
            // 拼寫在請求位址後邊，需要注意是否需要添加/
            reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI("/ribbon/get"));
            System.out.println("reconstructURI2-yes:" + reconstructURI);
            reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI("http"));
            System.out.println("reconstructURI3-no:" + reconstructURI);
            reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI("https"));
            System.out.println("reconstructURI4-no:" + reconstructURI);
            reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI("test"));
            System.out.println("reconstructURI5-no:" + reconstructURI);
            // 使用http:/xxx、https:/xxx可以用于切換http協定還是https協定
            reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI("http:/ribbin/get"));
            System.out.println("reconstructURI6-yes:" + reconstructURI);
            reconstructURI = ribbonLoadBalancerClient.reconstructURI(instance, new URI("https:/ribbin/get"));
            System.out.println("reconstructURI7-yes:" + reconstructURI);
        } catch (URISyntaxException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return "ribbon's demo,please to see console output";
    }

    @GetMapping("/nobalance/get/{id}")
    public String nobalance(@PathVariable("id") String id) {
        // -----------------以下代碼使用寫死方式調用服務
        // 如果restTemplate已經使用了Ribbon做負載均衡,也就是使用了@LoadBaleced注解,依然使用寫死方式就不允許了,會提示:No instances available for localhost

        String result = noBalanceRestTemplate.getForObject("http://localhost:9907/get/"+id, String.class);
        System.out.println("[noBalanceRestTemplate-hardcode1]" + result); //正常通路
        result = noBalanceRestTemplate.getForObject("http://localhost:9908/get/"+id, String.class);
        System.out.println("[noBalanceRestTemplate-hardcode2]" + result); //正常通路

        try {
            //異常通路，Ribbon負載均衡隻能通過服務名調用
            result = balanceRestTemplate.getForObject("http://localhost:9907/get/"+id, String.class);
            System.out.println("[balanceRestTemplate-hardcode1]" + result); 
            //異常通路，Ribbon負載均衡隻能通過服務名調用
            result = balanceRestTemplate.getForObject("http://localhost:9908/get/"+id, String.class);
            System.out.println("[balanceRestTemplate-hardcode2]" + result); 
        } catch (Exception e) {
            System.out.println("使用balanceRestTemplate同時使用位址寫死錯誤：" + e.getMessage());
        }
        return "ribbon's demo,please to see console output";
    }

    @SuppressWarnings("unchecked")
    @GetMapping("listAll")
    public List<User> listAll() {
        // restTemplate怎樣傳回一個List對象
        List<User> list = balanceRestTemplate.getForObject("http://mima-cloud-producer/listAll", List.class);
        return list;
    }

}

其中 mima-cloud-producer 為服務名，啟動兩個服務節點如下：

Spring Cloud：第三章：Ribbon客服端負載均衡

基于Ribbon+RestTemplate的用法

1、引入依賴

2、在啟動類中注入配置

3、編寫 Controller——示範使用負載均衡和不使用負載均衡的用法及差別

繼續閱讀

馴服爛代碼_馴服Tomcat：Tomcat 5的過濾技巧

基于Springboot+VUE+Mysql的大學生校園疫情防控管理系統

Using MessageConverter

馴服爛代碼_C＃中的馴服配置

Spring Cloud整合Sleuth，當請求完成後，Zipkin沒有鍊路資訊

JAVA自學之路——馬士兵

Rabbitmq指令行手動建立隊列

整合 Spring 開發架構及服務端技術

SSM整合02---Spring-SpringMVC層一、添加web架構支援二、web.xml三、spring-mvc.xml

SSM架構（二）------------表現層的SpringMVC

Intellij idea基于Maven 的SSM 架構整合

Spring資料和Redis

SpringMVC的啟動過程源碼分析1 SpringMVC 配置XML的方式啟動2 SpringMVC純注解模式啟動

Java Spring 架構

SpringCloud微服務（四）之ribbon筆記ribbon是什麼？入門案例自定義均衡負載算法

nginx location中斜線的位置的重要性