feign 如何獲取請(qǐng)求真實(shí)目的ip地址

更新時(shí)間：2021年06月24日 12:05:25 作者：帆影匆匆

這篇文章主要介紹了feign 獲取請(qǐng)求真實(shí)目的ip地址操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

需求

最近小編的項(xiàng)目中出現(xiàn)了很多feign 調(diào)用出現(xiàn) Read Time out 的異常，但因?yàn)闆](méi)有集成鏈路追蹤的第三方框架，查不到原因。

所以想到打印請(qǐng)求的ip地址，判斷是指定的服務(wù)器出現(xiàn)的問(wèn)題還是所有服務(wù)器都有這個(gè)問(wèn)題，但是feign 打印異常日志不會(huì)顯示目的端地址，這就很難受了沒(méi)辦法只能自己改裝下

大致想法

需要改裝肯定需要知道feign 具體請(qǐng)求調(diào)用的源碼，大致需要知道下面幾個(gè)問(wèn)題

feign 集成了ribbon 如何在負(fù)載均衡之后獲取真實(shí)的ip地址
feign 實(shí)際請(qǐng)求 http 源碼在哪
能否替換 feign http 請(qǐng)求的組件

源碼解析

之前小編有兩篇文章分析過(guò) feign相關(guān)的源碼

自定義 feign 調(diào)用實(shí)現(xiàn) hystrix 超時(shí)、異常熔斷

Feign 集成 Hystrix實(shí)現(xiàn)不同的調(diào)用接口不同的設(shè)置

這其中有個(gè)關(guān)鍵的源碼位置在于 InvocationHandler 的 invoke 方法，在feign 組件中大致有兩個(gè)類實(shí)現(xiàn)了此接口

FeignInvocationHandler
HystrixInvocationHandler

如果項(xiàng)目中使用了 Hystrix 那么會(huì)用到HystrixInvocationHandler那個(gè)，否則一般是FeignInvocationHandler（自定義組件的除外）

那么此時(shí)只需要在invoke 方法中打個(gè)斷點(diǎn)就行

此時(shí)跟蹤到

feign.SynchronousMethodHandler#executeAndDecode

Object executeAndDecode(RequestTemplate template) throws Throwable {
    Request request = targetRequest(template);
	.......
    Response response;
    long start = System.nanoTime();
    try {
      // 真正執(zhí)行請(qǐng)求 
      response = client.execute(request, options);
      
      response.toBuilder().request(request).build();
    } catch (IOException e) {
      ....
      throw errorExecuting(request, e);
    }
    .....
  }

通過(guò)debug就知道這個(gè) client 是

LoadBalancerFeignClient
org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient#execute

public Response execute(Request request, Request.Options options) throws IOException {
		try {
			URI asUri = URI.create(request.url());
			String clientName = asUri.getHost();
			URI uriWithoutHost = cleanUrl(request.url(), clientName);
			
			// 封裝 ribbon 請(qǐng)求組件
			FeignLoadBalancer.RibbonRequest ribbonRequest = new FeignLoadBalancer.RibbonRequest(
					this.delegate, request, uriWithoutHost);
			IClientConfig requestConfig = getClientConfig(options, clientName);
			// 這行是關(guān)鍵
			return 
					// 獲取 FeignLoadBalancer
					lbClient(clientName)
					// 負(fù)載之后請(qǐng)求真實(shí)的url
					// com.netflix.client.AbstractLoadBalancerAwareClient#executeWithLoadBalancer(....)
					.executeWithLoadBalancer(ribbonRequest,requestConfig)
					.toResponse();
		}
		catch (ClientException e) {
			....
			throw new RuntimeException(e);
		}
	}

com.netflix.client.AbstractLoadBalancerAwareClient#executeWithLoadBalancer(....)

public T executeWithLoadBalancer(final S request, final IClientConfig requestConfig) throws ClientException {
        LoadBalancerCommand<T> command = buildLoadBalancerCommand(request, requestConfig);
        try {
        	// 在com.netflix.loadbalancer.reactive.LoadBalancerCommand#submit 中會(huì)根據(jù) 負(fù)載均衡算法之后獲取到真實(shí)的ip地址
            return command.submit(
                new ServerOperation<T>() {
                    @Override
                    // 傳入的server 就是真實(shí)的ip
                    public Observable<T> call(Server server) {
                        URI finalUri = reconstructURIWithServer(server, request.getUri());
                        // 路徑替換把原本 http://client-name/xxxx 地址改為 http://127.0.0.1:9090/xxxx
                        S requestForServer = (S) request.replaceUri(finalUri);
                        try {
                        	// 請(qǐng)求父類中的 execute 方法，也就是 上面 lbClient(clientName) 返回的 FeignLoadBalancer
                            return Observable.just(AbstractLoadBalancerAwareClient.this.execute(requestForServer, requestConfig));
                        } 
                        catch (Exception e) {
                            return Observable.error(e);
                        }
                    }
                })
                .toBlocking()
                .single();
        } catch (Exception e) {
            Throwable t = e.getCause();
            if (t instanceof ClientException) {
                throw (ClientException) t;
            } else {
                throw new ClientException(e);
            }
        }        
    }

org.springframework.cloud.openfeign.ribbon.FeignLoadBalancer#execute

@Override
 public RibbonResponse execute(RibbonRequest request, IClientConfig configOverride)
   throws IOException {
  Request.Options options;
  .....
  // 這里的 request 就是 `org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient#execute` 
  // 封裝的FeignLoadBalancer.RibbonRequest
  // request.client() 返回就是 feign.Client.Default  
  Response response = request.client().execute(request.toRequest(), options);
  return new RibbonResponse(request.getUri(), response);
 }

feign.Client.Default#execute

 @Override
    public Response execute(Request request, Options options) throws IOException {
      HttpURLConnection connection = convertAndSend(request, options);
      return convertResponse(connection).toBuilder().request(request).build();
    }

這里的request 中 url 就是真實(shí)的url資源路徑了

現(xiàn)在屢屢邏輯

org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient和feign.Client.Default

都實(shí)現(xiàn)了 feign.Client 接口，但是 LoadBalancerFeignClient 實(shí)際上調(diào)用的還是 feign.Client.Default，無(wú)非做了自己處理（負(fù)載），有些類似于靜態(tài)代理

那么上面的問(wèn)題就只剩下能否替換的問(wèn)題了

@Configuration
class DefaultFeignLoadBalancedConfiguration {
	@Bean
	@ConditionalOnMissingBean
	public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory,
				SpringClientFactory clientFactory) {
		return new LoadBalancerFeignClient(new Client.Default(null, null),
				cachingFactory, clientFactory);
	}
}

這就不需要我來(lái)過(guò)多解釋了，我們只需要自定義一個(gè) LoadBalancerFeignClient 或者實(shí)現(xiàn)Client的類就行然后注入就行

實(shí)現(xiàn)代碼

我選擇的是自定義實(shí)現(xiàn)一個(gè) Client,去繼承 feign.Client.Default

@Slf4j
public class InFeignClient extends Client.Default {
    /**
     */
    public InFeignClient(SSLSocketFactory sslContextFactory, HostnameVerifier hostnameVerifier) {
        super(sslContextFactory, hostnameVerifier);
    }
    @Override
    public Response execute(Request request, Request.Options options) throws IOException {
        try {
            return super.execute(request, options);
        } catch (IOException e) {
            log.warn(" 請(qǐng)求 {} 異常 ======> {}", request.url(), e.getMessage());
            throw e;
        }
    }
}

然后將這個(gè)類替換

@Component
public class RestConfig {
    public CachingSpringLoadBalancerFactory cachingLBClientFactory(
            SpringClientFactory factory) {
        return new CachingSpringLoadBalancerFactory(factory);
    }
    @Bean
    public Client feignClient(SpringClientFactory clientFactory) {
        CachingSpringLoadBalancerFactory bean = cachingLBClientFactory(clientFactory);
        return new LoadBalancerFeignClient(new InFeignClient(null, null), bean, clientFactory);
    }    
}

您可能感興趣的文章: