手把手帶你分析SpringBoot自動裝配完成了Ribbon哪些核心操作

更新時間：2021年08月12日 10:41:36 作者：波波烤鴨

這篇文章主要介紹了詳解Spring Boot自動裝配Ribbon哪些核心操作的哪些操作，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

一、項目案例準備

首先我們大家案例環(huán)境，通過【RestTemplate】來實現(xiàn)服務調用，通過【Ribbon】實現(xiàn)客戶端負載均衡操作。

在這里插入圖片描述

1.Order服務

我們的Order服務作為服務提供者。創(chuàng)建SpringBoot項目，并添加相關依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.9</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.bobo.springcloud</groupId>
    <artifactId>spring-cloud-order-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>spring-cloud-order-server</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR10</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

然后在屬性文件中添加相關的配置

spring.application.name=spring-cloud-order-service
server.port=8081

然后創(chuàng)建自定義的Controller 提供對外的服務

@RestController
public class OrderController {
    @Value("${server.port}")
    private int port;
    @GetMapping("/orders")
    public String orders(){
        System.out.println("Order 服務端口是："+port);
        return "Order Services ..... ";
    }
}

然后我們可以分別啟動兩個Order服務，端口分別設置為 8081和8082

2.User服務

User服務作為調用用Order服務的客戶端。也是我們要重點介紹【Ribbon】的服務。同樣創(chuàng)建一個SpringBoot項目，添加相關的依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.bobo.springcloud</groupId>
    <artifactId>spring-cloud-user-service2</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>spring-cloud-user-service2</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR10</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

然后在屬性文件中配置相關信息

spring.application.name=spring-cloud-user-service
spring-cloud-order-service.ribbon.listOfServers=localhost:8081,localhost:8082

然后創(chuàng)建自定義的Controller來實現(xiàn)服務的調用

@RestController
public class UserController {
    @Autowired
    public RestTemplate restTemplate;
    @Autowired
    LoadBalancerClient loadBalancerClient;
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
    @GetMapping("/users")
    public String users(){
        ServiceInstance choose = loadBalancerClient.choose("spring-cloud-order-service");
        String url = String.format("http://%s:%s",choose.getHost(),choose.getPort()+"/orders");
        //return restTemplate.getForObject(url,String.class);
        return restTemplate.getForObject("http://spring-cloud-order-service/orders",String.class);
    }
}

然后啟動User服務訪問，可以看到【Ribbon】默認通過輪詢的方式來實現(xiàn)了服務的調用

在這里插入圖片描述

二、Ribbon原理分析

應用比較簡單，我們主要是來分析下【Ribbon】的核心原理，先來看看自動裝配做了哪些事情。

1.RibbonAutoConfiguration

Ribbon在系統(tǒng)啟動的時候自動裝配完成的設置，我們先來看看對應的spring.factories 中的配置信息吧

請?zhí)砑訄D片描述

emsp; 所以我們要繼續(xù)來看【RibbonAutoConfiguration】配置類，我們貼出【RibbonAutoConfiguration】的關鍵信息

@Configuration
@Conditional({RibbonAutoConfiguration.RibbonClassesConditions.class})
@RibbonClients
@AutoConfigureAfter(
    name = {"org.springframework.cloud.netflix.eureka.EurekaClientAutoConfiguration"}
)
// RibbonAutoConfiguration配置類注入容器后會完成 LoadBalancerAutoConfiguration 和 AsyncLoadBalancerAutoConfiguration 的注入
@AutoConfigureBefore({LoadBalancerAutoConfiguration.class, AsyncLoadBalancerAutoConfiguration.class})
@EnableConfigurationProperties({RibbonEagerLoadProperties.class, ServerIntrospectorProperties.class})
public class RibbonAutoConfiguration {

    /**
    *  如果IoC容器中不存在 LoadBalancerClient 類型的對象就注入一個
    *  具體注入的類型為 RibbonLoadBalancerClient 對象
    **/
    @Bean
    @ConditionalOnMissingBean({LoadBalancerClient.class})
    public LoadBalancerClient loadBalancerClient() {
        return new RibbonLoadBalancerClient(this.springClientFactory());
    }
    // 省略其他代碼

通過源碼查看我們知道在SpringBoot項目啟動的時候完成了【LoadBalancerClient】對象的注入，且具體的類型為【RibbonLoadBalancerClient】，同時還會完成【LoadBalancerAutoConfiguration】這個配置類型的加載。在看【LoadBalancerAutoConfiguration】做了什么事情之前，我們先來搞清楚【@LoadBalanced】注解的作用

2.LoadBalancerAutoConfiguration

@Target({ ElementType.FIELD, ElementType.PARAMETER, ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@Qualifier
public @interface LoadBalanced {
}

【@LoadBalanced】本質上就是一個【@Qualifier】注解。作用就是標記，我們通過案例來演示說明。

定義一個簡單的【User】類

public class User {
    String name;
    public User(String name) {
        this.name = name;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Override
    public String toString() {
        return "User{" +
                "name='" + name + '\'' +
                '}';
    }
}

然后定義一個Java配置類,有兩個添加了【@LoadBalanced】注解，有一個沒有加。

@Configuration
public class JavaConfig {
    @LoadBalanced
    @Bean("user1")
    public User user1(){
        return new User("user1");
    }
    @Bean("user2")
    public User user2(){
        return new User("user2");
    }
    @LoadBalanced
    @Bean("user3")
    public User user3(){
        return new User("user3");
    }

}

然后創(chuàng)建我們的控制器，來測試使用

@RestController
public class UsersController {
    @LoadBalanced
    @Autowired
    List<User> list = Collections.emptyList();
    @GetMapping("/querys")
    public String query(){
        return list.toString();
    }
}

項目結構

請?zhí)砑訄D片描述

啟動SpringBoot項目后我們看效果

請?zhí)砑訄D片描述

搞清楚了【@LoadBalanced】的作用后，我們再來看看【LoadBalancerAutoConfiguration】的配置加載做了什么事情

public class LoadBalancerAutoConfiguration {
    /**
    *   1.
    * 獲取IoC容器中所有的被【@LoadBalanced】注解修飾的RestTemplate對象
    *  這些對象保存在了一個集合中
    **/
	@LoadBalanced
	@Autowired(required = false)
	private List<RestTemplate> restTemplates = Collections.emptyList();
	@Autowired(required = false)
	private List<LoadBalancerRequestTransformer> transformers = Collections.emptyList();
    /**
    *   4.
    *  向容器中注入了 SmartInitializingSingleton 對象，并且實現(xiàn)了 SmartInitializingSingleton 接口中聲明的
    *  afterSingletonsInstantiated 方法，在該方法中 通過3 中的 RestTemplateCustomizer中定義的 customize 方法
    *  實現(xiàn)了 RestTemplate 對象攔截器的植入
    **/
	@Bean
	public SmartInitializingSingleton loadBalancedRestTemplateInitializerDeprecated(
			final ObjectProvider<List<RestTemplateCustomizer>> restTemplateCustomizers) {
		return () -> restTemplateCustomizers.ifAvailable(customizers -> {
			for (RestTemplate restTemplate : LoadBalancerAutoConfiguration.this.restTemplates) {
				for (RestTemplateCustomizer customizer : customizers) {
					customizer.customize(restTemplate);
				}
			}
		});
	}
	@Bean
	@ConditionalOnMissingBean
	public LoadBalancerRequestFactory loadBalancerRequestFactory(
			LoadBalancerClient loadBalancerClient) {
		return new LoadBalancerRequestFactory(loadBalancerClient, this.transformers);
	}
	@Configuration(proxyBeanMethods = false)
	@ConditionalOnMissingClass("org.springframework.retry.support.RetryTemplate")
	static class LoadBalancerInterceptorConfig {
        /**
        *  2. 
        *  創(chuàng)建了一個 LoadBalancerInterceptor 并注入到了容器中
        **/
		@Bean
		public LoadBalancerInterceptor loadBalancerInterceptor(
				LoadBalancerClient loadBalancerClient,
				LoadBalancerRequestFactory requestFactory) {
			return new LoadBalancerInterceptor(loadBalancerClient, requestFactory);
		}
		/**
        *  3. 
        *  創(chuàng)建了一個 RestTemplateCustomizer 并注入到了容器中
        *  而且通過內部類的方式定義定義了 RestTemplateCustomizer 接口中的 customize 方法的邏輯
        **/
		@Bean
		@ConditionalOnMissingBean
		public RestTemplateCustomizer restTemplateCustomizer(
				final LoadBalancerInterceptor loadBalancerInterceptor) {
			return restTemplate -> {
                // 獲取 RestTemplate 中原有的 攔截器
				List<ClientHttpRequestInterceptor> list = new ArrayList<>(
						restTemplate.getInterceptors());
                // 在原有的攔截器的基礎上 添加了一個 LoadBalancerInterceptor
				list.add(loadBalancerInterceptor);
                // 然后將添加有新的 攔截器的集合 設置到了 RestTemplate 對象中
				restTemplate.setInterceptors(list);
			};
		}
	}
   // 省略其他代碼
}

通過對應的備注大家可以搞清楚該配置類的作用是實現(xiàn)了對【RestTemplate】對象(被@LoadBalanced修飾)植入【LoadBalancerInterceptor】攔截器的功能。

總結

Ribbon系統(tǒng)時的操作

請?zhí)砑訄D片描述

本篇文章就到這里了，希望能給你帶來幫助，也希望您能夠多多關注腳本之家的更多內容！

您可能感興趣的文章:

Java動態(tài)代理語法Proxy類原理詳解
這篇文章主要介紹了Java動態(tài)代理語法Proxy類原理詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-04-04
SpringBoot動態(tài)Feign服務調用詳解
Feign是Netflix公司開發(fā)的一個聲明式的REST調用客戶端; Ribbon負載均衡、 Hystrⅸ服務熔斷是我們Spring Cloud中進行微服務開發(fā)非?；A的組件,在使用的過程中我們也發(fā)現(xiàn)它們一般都是同時出現(xiàn)的,而且配置也都非常相似
2022-12-12
@TransactionalEventListener的使用和實現(xiàn)原理分析
這篇文章主要介紹了@TransactionalEventListener的使用和實現(xiàn)原理分析，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2021-12-12
Java實現(xiàn)經(jīng)典游戲2048的示例代碼
2014年Gabriele Cirulli利用周末的時間寫2048這個游戲的程序。本文將用java語言實現(xiàn)這一經(jīng)典游戲，并采用了swing技術進行了界面化處理，需要的可以參考一下
2022-02-02
Spring?依賴查找的使用小結
在不同的編程框架和容器中，依賴查找的方式可能會有所不同，本文主要介紹了Spring依賴查找的使用小結，具有一定的參考價值，感興趣的可以了解一下
2023-12-12
Java中ThreadLocal?導致內存?OOM?的原因分析
這篇文章主要介紹了Java中ThreadLocal導致內存OOM的原因分析，文章基于Java的相關內容展開ThreadLocal導致內存OOM的原因分析，需要的小伙v阿布可以參考一下
2022-05-05
Spring Boot 如何使用Liquibase 進行數(shù)據(jù)庫遷移(操作方法)
在Spring Boot應用程序中使用Liquibase進行數(shù)據(jù)庫遷移是一種強大的方式來管理數(shù)據(jù)庫模式的變化,本文重點講解如何在Spring Boot應用程序中使用Liquibase進行數(shù)據(jù)庫遷移,從而更好地管理數(shù)據(jù)庫模式的變化,感興趣的朋友跟隨小編一起看看吧
2023-09-09
Mybatis關聯(lián)查詢之一對多和多對一XML配置詳解
這篇文章主要介紹了Mybatis關聯(lián)查詢之一對多和多對一XML配置詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2020-10-10
關于Gateway路由匹配規(guī)則解讀
本文詳細介紹了SpringCloudGateway的路由匹配規(guī)則,包括基本概念、常用屬性、實際應用以及注意事項,路由匹配規(guī)則決定了請求如何被轉發(fā)到目標服務,是Gateway的核心功能之一,在配置路由時需要注意順序、性能和安全性
2025-02-02
java實現(xiàn)發(fā)送email小案例
這篇文章主要為大家詳細介紹了java實現(xiàn)發(fā)送email小案例，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2020-02-02