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

Spring Cloud Commons公共抽象

Spring Cloud將服務(wù)發(fā)現(xiàn)、負(fù)載均衡和斷路器等通用模型封裝在一個(gè)公共抽象中，可以被所有的Spring Cloud客戶端使用，不依賴于具體的實(shí)現(xiàn)（例如服務(wù)發(fā)現(xiàn)就有Eureka和Consul等不同的實(shí)現(xiàn))，這些公共抽象位于Spring Cloud Commons項(xiàng)目中。

@EnableDiscoveryClient

Commons提供@EnableDiscoveryClient注釋。這通過META-INF/spring.factories查找DiscoveryClient接口的實(shí)現(xiàn)。Discovery Client的實(shí)現(xiàn)將在org.springframework.cloud.client.discovery.EnableDiscoveryClient鍵下的spring.factories中添加一個(gè)配置類。DiscoveryClient實(shí)現(xiàn)的示例是Spring Cloud Netflix Eureka，Spring Cloud Consul發(fā)現(xiàn)和Spring Cloud Zookeeper發(fā)現(xiàn)。

默認(rèn)情況下，DiscoveryClient的實(shí)現(xiàn)將使用遠(yuǎn)程發(fā)現(xiàn)服務(wù)器自動(dòng)注冊(cè)本地Spring Boot服務(wù)器。可以通過在@EnableDiscoveryClient中設(shè)置autoRegister=false來禁用此功能。

服務(wù)注冊(cè)ServiceRegistry

Commons現(xiàn)在提供了一個(gè)ServiceRegistry接口，它提供了諸如register(Registration)和deregister(Registration)之類的方法，允許您提供定制的注冊(cè)服務(wù)。Registration是一個(gè)標(biāo)記界面。

@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);
    }
}

每個(gè)ServiceRegistry實(shí)現(xiàn)都有自己的Registry實(shí)現(xiàn)。

RestTemplate的負(fù)載均衡

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

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

@Configuration
public class MyConfiguration {
@LoadBalanced
@Bean
RestTemplate restTemplate(){
return new RestTemplate():
}
}
public class MyApplication {
@Autowired
private RestTemplate restTemplate ;
public string getMyApplicationName() {
//使用restTemplate訪問my-application微服務(wù)的/name接口
string name = restTemplate.getFor0bject("http://my-application/name",string.class) ;
return name;
}
}

URI需要使用服務(wù)名來指定需要訪問應(yīng)用服務(wù)，Ribbon客戶端將通過服務(wù)名從服務(wù)發(fā)現(xiàn)應(yīng)用處獲取具體的服務(wù)地址來創(chuàng)建一個(gè)完整的網(wǎng)絡(luò)地址，以實(shí)現(xiàn)網(wǎng)絡(luò)調(diào)用。

RestTemplate的失敗重試

負(fù)載均衡的RestTemplate可以添加失敗重試機(jī)制。默認(rèn)情況下，失敗重試機(jī)制是關(guān)閉的，啟用方式是將Spring Retry添加到應(yīng)用程序的類路徑中。還可以設(shè)置

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

如果想要添加一個(gè)或者多個(gè)RetryListener到重試請(qǐng)求中，可以創(chuàng)建一個(gè)類型為L(zhǎng)oadBalancedRetryListenerFactory的Bean，用來返回將要用于重試機(jī)制的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;
}
//重試結(jié)束后的工作@Override
public<T, E extends Throwable> void close(RetryContext context,RetryCallback<T，E>callback,Throwable throwable){
}
//重試出錯(cuò)后的工作@Override
publicT,E extends Throwable> void onError(RetryContext context,RetryCal1back<T，E>callback,Throwable throwable){
}
}};
}};
}}

其中，自定義配置類中定義了生成LoadBalancedRetryListenerFactory實(shí)例的@Bean方法，該工廠類的createRetryListeners方法會(huì)生成一個(gè)RetryListener實(shí)例，用于進(jìn)行網(wǎng)絡(luò)請(qǐng)求的重試。

到此這篇關(guān)于超詳細(xì)講解SpringCloud Commons 公共抽象的用法的文章就介紹到這了,更多相關(guān)SpringCloud 公共抽象內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論