您好,登錄后才能下訂單哦!
今天小編給大家分享一下SpringCloud Commons公共抽象方法怎么用的相關(guān)知識點,內(nèi)容詳細(xì),邏輯清晰,相信大部分人都還太了解這方面的知識,所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來了解一下吧。
Spring Cloud將服務(wù)發(fā)現(xiàn)、負(fù)載均衡和斷路器等通用模型封裝在一個公共抽象中,可以被所有的Spring Cloud客戶端使用,不依賴于具體的實現(xiàn)(例如服務(wù)發(fā)現(xiàn)就有Eureka和Consul等不同的實現(xiàn)),這些公共抽象位于Spring Cloud Commons項目中。
Commons提供@EnableDiscoveryClient注釋。這通過META-INF/spring.factories查找DiscoveryClient接口的實現(xiàn)。Discovery Client的實現(xiàn)將在org.springframework.cloud.client.discovery.EnableDiscoveryClient鍵下的spring.factories中添加一個配置類。DiscoveryClient實現(xiàn)的示例是Spring Cloud Netflix Eureka,Spring Cloud Consul發(fā)現(xiàn)和Spring Cloud Zookeeper發(fā)現(xiàn)。
默認(rèn)情況下,DiscoveryClient的實現(xiàn)將使用遠(yuǎn)程發(fā)現(xiàn)服務(wù)器自動注冊本地Spring Boot服務(wù)器??梢酝ㄟ^在@EnableDiscoveryClient中設(shè)置autoRegister=false來禁用此功能。
Commons現(xiàn)在提供了一個ServiceRegistry接口,它提供了諸如register(Registration)和deregister(Registration)之類的方法,允許您提供定制的注冊服務(wù)。Registration是一個標(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); } }
每個ServiceRegistry實現(xiàn)都有自己的Registry實現(xiàn)。
創(chuàng)建RestTemplate實例的時候,使用@LoadBalanced注解可以將RestTemplate自動配置為使用負(fù)載均衡的狀態(tài)。@LoadBalanced將使用Ribbon為RestTemplate執(zhí)行負(fù)載均衡策略。
創(chuàng)建負(fù)載均衡的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微服務(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)建一個完整的網(wǎng)絡(luò)地址,以實現(xiàn)網(wǎng)絡(luò)調(diào)用。
負(fù)載均衡的RestTemplate可以添加失敗重試機制。默認(rèn)情況下,失敗重試機制是關(guān)閉的,啟用方式是將Spring Retry添加到應(yīng)用程序的類路徑中。還可以設(shè)置
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; } //重試結(jié)束后的工作@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實例,用于進(jìn)行網(wǎng)絡(luò)請求的重試。
以上就是“SpringCloud Commons公共抽象方法怎么用”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會為大家更新不同的知識,如果還想學(xué)習(xí)更多的知識,請關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。