欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

springcloud的FeignLoadBalancer怎么用

本篇內(nèi)容主要講解“spring cloud的FeignLoadBalancer怎么用”,感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷,實用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“spring cloud的FeignLoadBalancer怎么用”吧!

成都創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),廣靈企業(yè)網(wǎng)站建設(shè),廣靈品牌網(wǎng)站建設(shè),網(wǎng)站定制,廣靈網(wǎng)站建設(shè)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,廣靈網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競爭力??沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿,時刻以成就客戶成長自我,堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

本文主要研究一下spring cloud的FeignLoadBalancer

FeignLoadBalancer

spring-cloud-openfeign-core-2.2.0.M1-sources.jar!/org/springframework/cloud/openfeign/ribbon/FeignLoadBalancer.java

public class FeignLoadBalancer extends
		AbstractLoadBalancerAwareClient<FeignLoadBalancer.RibbonRequest, FeignLoadBalancer.RibbonResponse> {

	private final RibbonProperties ribbon;

	protected int connectTimeout;

	protected int readTimeout;

	protected IClientConfig clientConfig;

	protected ServerIntrospector serverIntrospector;

	public FeignLoadBalancer(ILoadBalancer lb, IClientConfig clientConfig,
			ServerIntrospector serverIntrospector) {
		super(lb, clientConfig);
		this.setRetryHandler(RetryHandler.DEFAULT);
		this.clientConfig = clientConfig;
		this.ribbon = RibbonProperties.from(clientConfig);
		RibbonProperties ribbon = this.ribbon;
		this.connectTimeout = ribbon.getConnectTimeout();
		this.readTimeout = ribbon.getReadTimeout();
		this.serverIntrospector = serverIntrospector;
	}

	@Override
	public RibbonResponse execute(RibbonRequest request, IClientConfig configOverride)
			throws IOException {
		Request.Options options;
		if (configOverride != null) {
			RibbonProperties override = RibbonProperties.from(configOverride);
			options = new Request.Options(override.connectTimeout(this.connectTimeout),
					override.readTimeout(this.readTimeout));
		}
		else {
			options = new Request.Options(this.connectTimeout, this.readTimeout);
		}
		Response response = request.client().execute(request.toRequest(), options);
		return new RibbonResponse(request.getUri(), response);
	}

	@Override
	public RequestSpecificRetryHandler getRequestSpecificRetryHandler(
			RibbonRequest request, IClientConfig requestConfig) {
		if (this.ribbon.isOkToRetryOnAllOperations()) {
			return new RequestSpecificRetryHandler(true, true, this.getRetryHandler(),
					requestConfig);
		}
		if (!request.toRequest().httpMethod().name().equals("GET")) {
			return new RequestSpecificRetryHandler(true, false, this.getRetryHandler(),
					requestConfig);
		}
		else {
			return new RequestSpecificRetryHandler(true, true, this.getRetryHandler(),
					requestConfig);
		}
	}

	@Override
	public URI reconstructURIWithServer(Server server, URI original) {
		URI uri = updateToSecureConnectionIfNeeded(original, this.clientConfig,
				this.serverIntrospector, server);
		return super.reconstructURIWithServer(server, uri);
	}

	//......
}
  • FeignLoadBalancer繼承了AbstractLoadBalancerAwareClient,它的構(gòu)造器接收ILoadBalancer、IClientConfig、ServerIntrospector,設(shè)置的retryHandler為RetryHandler.DEFAULT

  • 其execute方法首先構(gòu)造Request.Options,然后通過request.client().execute來獲取Response,最后返回RibbonResponse

  • FeignLoadBalancer還覆蓋了getRequestSpecificRetryHandler方法,針對ribbon.isOkToRetryOnAllOperations()來構(gòu)建不同的RequestSpecificRetryHandler;還覆蓋了reconstructURIWithServer方法,它使用RibbonUtils的updateToSecureConnectionIfNeeded來構(gòu)建URI

RibbonRequest

spring-cloud-openfeign-core-2.2.0.M1-sources.jar!/org/springframework/cloud/openfeign/ribbon/FeignLoadBalancer.java

	protected static class RibbonRequest extends ClientRequest implements Cloneable {

		private final Request request;

		private final Client client;

		protected RibbonRequest(Client client, Request request, URI uri) {
			this.client = client;
			setUri(uri);
			this.request = toRequest(request);
		}

		private Request toRequest(Request request) {
			Map<String, Collection<String>> headers = new LinkedHashMap<>(
					request.headers());
			return Request.create(request.httpMethod(), getUri().toASCIIString(), headers,
					request.requestBody());
		}

		Request toRequest() {
			return toRequest(this.request);
		}

		Client client() {
			return this.client;
		}

		HttpRequest toHttpRequest() {
			return new HttpRequest() {
				@Override
				public HttpMethod getMethod() {
					return HttpMethod
							.resolve(RibbonRequest.this.toRequest().httpMethod().name());
				}

				@Override
				public String getMethodValue() {
					return getMethod().name();
				}

				@Override
				public URI getURI() {
					return RibbonRequest.this.getUri();
				}

				@Override
				public HttpHeaders getHeaders() {
					Map<String, List<String>> headers = new HashMap<>();
					Map<String, Collection<String>> feignHeaders = RibbonRequest.this
							.toRequest().headers();
					for (String key : feignHeaders.keySet()) {
						headers.put(key, new ArrayList<String>(feignHeaders.get(key)));
					}
					HttpHeaders httpHeaders = new HttpHeaders();
					httpHeaders.putAll(headers);
					return httpHeaders;

				}
			};
		}

		public Request getRequest() {
			return this.request;
		}

		public Client getClient() {
			return this.client;
		}

		@Override
		public Object clone() {
			return new RibbonRequest(this.client, this.request, getUri());
		}

	}
  • RibbonRequest繼承了ClientRequest實現(xiàn)了Cloneable接口,它提供了toHttpRequest方法來將feign的Request轉(zhuǎn)換為spring的HttpRequest

RibbonResponse

spring-cloud-openfeign-core-2.2.0.M1-sources.jar!/org/springframework/cloud/openfeign/ribbon/FeignLoadBalancer.java

	protected static class RibbonResponse implements IResponse {

		private final URI uri;

		private final Response response;

		protected RibbonResponse(URI uri, Response response) {
			this.uri = uri;
			this.response = response;
		}

		@Override
		public Object getPayload() throws ClientException {
			return this.response.body();
		}

		@Override
		public boolean hasPayload() {
			return this.response.body() != null;
		}

		@Override
		public boolean isSuccess() {
			return this.response.status() == 200;
		}

		@Override
		public URI getRequestedURI() {
			return this.uri;
		}

		@Override
		public Map<String, Collection<String>> getHeaders() {
			return this.response.headers();
		}

		Response toResponse() {
			return this.response;
		}

		@Override
		public void close() throws IOException {
			if (this.response != null && this.response.body() != null) {
				this.response.body().close();
			}
		}

	}
  • RibbonResponse實現(xiàn)了IResponse接口,將feign的Response適配為netflix的IResponse

小結(jié)

  • FeignLoadBalancer繼承了AbstractLoadBalancerAwareClient,它的構(gòu)造器接收ILoadBalancer、IClientConfig、ServerIntrospector,設(shè)置的retryHandler為RetryHandler.DEFAULT

  • 其execute方法首先構(gòu)造Request.Options,然后通過request.client().execute來獲取Response,最后返回RibbonResponse

  • FeignLoadBalancer還覆蓋了getRequestSpecificRetryHandler方法,針對ribbon.isOkToRetryOnAllOperations()來構(gòu)建不同的RequestSpecificRetryHandler;還覆蓋了reconstructURIWithServer方法,它使用RibbonUtils的updateToSecureConnectionIfNeeded來構(gòu)建URI

到此,相信大家對“spring cloud的FeignLoadBalancer怎么用”有了更深的了解,不妨來實際操作一番吧!這里是創(chuàng)新互聯(lián)網(wǎng)站,更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢,關(guān)注我們,繼續(xù)學(xué)習(xí)!

網(wǎng)站名稱:springcloud的FeignLoadBalancer怎么用
URL標(biāo)題:http://aaarwkj.com/article42/igjihc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供域名注冊微信小程序、網(wǎng)站排名、企業(yè)網(wǎng)站制作、云服務(wù)器外貿(mào)網(wǎng)站建設(shè)

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

成都網(wǎng)站建設(shè)
精品一区二区三区推荐| 亚洲视频在线男人天堂| 91精品国产自产永久在线| 亚洲美女av一区二区三区| 国产精品一区二区三区欧美| 日本欧美高清一区二区| 国产精品久久久久久久久| 午夜宅男在线视频观看| 亚洲精品中文字幕乱码| 精品久久av一区二区三区| 日本中文一区在线观看| 加勒比东京热视频在线| 国产三级精品电影久久| 三级黄色片免费久久久| 亚洲丰满毛茸茸毛茸茸| 91制片国产在线观看| 国产日韩精品一区二区三区在线| 在线观看免费国产不卡| 亚洲欧洲日本在线天堂| 久久亚洲国产成人精品性色| 欧美午夜福利一级高清| 偷拍一区二区三区四区| 久久人妻一区二区三区免费密臀 | 成人免费av在线网址| 蜜桃传媒18传媒在线| 在线免费观看成人午夜福利| 国产原创av剧情六区| 欧美一日韩一级片免费看| 人妻口爆视频一区二区三区| av天堂最新资源在线| 五月婷婷色综合激情五月| 亚洲一区二区三区有码| 久草热不卡的av在线| 99热在线播放精品观看| 91精品啪在线观看国产日本| 国产亚洲理论片在线观看| 午夜伦理视频免费观看| 日本亚洲欧洲一区二区| 9热在线视频精品这里只有| 日韩亚洲av在线免费观看| 国产av剧情日韩精品|