超詳細講解SpringCloud Commons公共抽象的用法

2022-04-21 19:00:08

Spring Cloud Commons公共抽象

Spring Cloud將服務發現、負載均衡和斷路器等通用模型封裝在一個公共抽象中，可以被所有的Spring Cloud使用者端使用，不依賴於具體的實現（例如服務發現就有Eureka和Consul等不同的實現)，這些公共抽象位於Spring Cloud Commons專案中。

@EnableDiscoveryClient

Commons提供@EnableDiscoveryClient註釋。這通過META-INF/spring.factories查詢DiscoveryClient介面的實現。Discovery Client的實現將在org.springframework.cloud.client.discovery.EnableDiscoveryClient鍵下的spring.factories中新增一個設定類。DiscoveryClient實現的範例是Spring Cloud Netflix Eureka，Spring Cloud Consul發現和Spring Cloud Zookeeper發現。

預設情況下，DiscoveryClient的實現將使用遠端發現伺服器自動註冊本地Spring Boot伺服器。可以通過在@EnableDiscoveryClient中設定autoRegister=false來禁用此功能。

服務註冊ServiceRegistry

Commons現在提供了一個ServiceRegistry介面，它提供了諸如register(Registration)和deregister(Registration)之類的方法，允許您提供客製化的註冊服務。Registration是一個標記介面。

@Configuration
@EnableDiscoveryClient(autoRegister=false)
public class MyConfiguration {
    private ServiceRegistry registry;

    public MyConfiguration(ServiceRegistry registry) {
        this.registry = registry;
    }
    // called via some external process, such as an event or a custom actuator endpoint
    public void register() {
        Registration registration = constructRegistration();
        this.registry.register(registration);
    }
}

每個ServiceRegistry實現都有自己的Registry實現。

RestTemplate的負載均衡

建立RestTemplate範例的時候，使用@LoadBalanced註解可以將RestTemplate自動設定為使用負載均衡的狀態。@LoadBalanced將使用Ribbon為RestTemplate執行負載均衡策略。

建立負載均衡的RestTemplate不再能通過自動設定來建立，必須通過設定類建立，具體範例如下所示:

@Configuration
public class MyConfiguration {
@LoadBalanced
@Bean
RestTemplate restTemplate(){
return new RestTemplate():
}
}
public class MyApplication {
@Autowired
private RestTemplate restTemplate ;
public string getMyApplicationName() {
//使用restTemplate存取my-application微服務的/name介面
string name = restTemplate.getFor0bject("http://my-application/name",string.class) ;
return name;
}
}

URI需要使用服務名來指定需要存取應用服務，Ribbon使用者端將通過服務名從服務發現應用處獲取具體的服務地址來建立一個完整的網路地址，以實現網路呼叫。

RestTemplate的失敗重試

負載均衡的RestTemplate可以新增失敗重試機制。預設情況下，失敗重試機制是關閉的，啟用方式是將Spring Retry新增到應用程式的類路徑中。還可以設定

spring.cloud.loadbalancer.retry.enabled=false禁止類路徑中Spring retry的重試邏輯。

如果想要新增一個或者多個RetryListener到重試請求中，可以建立一個型別為LoadBalancedRetryListenerFactory的Bean，用來返回將要用於重試機制的RetryListener的列表，如下程式碼所示:

@Configuration
public class RryListenerConfiguration {
@Bean
LoadBalancedRetryListenerFactory retryListenerFactory( {
return new LoadBalancedRetryListenerFactoryO {
@override
public RetryListener[] createRetryListeners (String service)
return new RetryListener[] {new RetryListener ( {
@Override
//重試開始前的工作
public<T,E extends Throwable> boolean open(RetryContext context,RetryCallback<T，E>callback){
return true;
}
//重試結束後的工作@Override
public<T, E extends Throwable> void close(RetryContext context,RetryCallback<T，E>callback,Throwable throwable){
}
//重試出錯後的工作@Override
publicT,E extends Throwable> void onError(RetryContext context,RetryCal1back<T，E>callback,Throwable throwable){
}
}};
}};
}}

其中，自定義設定類中定義了生成LoadBalancedRetryListenerFactory範例的@Bean方法，該工廠類的createRetryListeners方法會生成一個RetryListener範例，用於進行網路請求的重試。

到此這篇關於超詳細講解SpringCloud Commons 公共抽象的用法的文章就介紹到這了,更多相關SpringCloud 公共抽象內容請搜尋it145.com以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援it145.com！