本期主角——Spring Cloud Commons:公共抽象

Spring Cloud Commons公共抽象

Spring Cloud將服務發(fā)現、負載均衡和斷路器等通用模型封裝在一個公共抽象中，可以被所有的Spring Cloud客戶端使用，不依賴于具體的實現（例如服務發(fā)現就有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發(fā)現和Spring Cloud Zookeeper發(fā)現。

默認情況下，DiscoveryClient的實現將使用遠程發(fā)現服務器自動注冊本地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的負載均衡

創(chuàng)建RestTemplate實例的時候，使用@LoadBalanced注解可以將RestTemplate自動配置為使用負載均衡的狀態(tài)。@LoadBalanced將使用Ribbon為RestTemplate執(zhí)行負載均衡策略。

創(chuàng)建負載均衡的RestTemplate不再能通過自動配置來創(chuàng)建，必須通過配置類創(chuàng)建，具體實例如下所示:

@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客戶端將通過服務名從服務發(fā)現應用處獲取具體的服務地址來創(chuàng)建一個完整的網絡地址，以實現網絡調用。

RestTemplate的失敗重試

負載均衡的RestTemplate可以添加失敗重試機制。默認情況下，失敗重試機制是關閉的，啟用方式是將Spring Retry添加到應用程序的類路徑中。還可以設置

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

如果想要添加一個或者多個RetryListener到重試請求中，可以創(chuàng)建一個類型為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 公共抽象內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論