springCloud的Feign在项目中的使用总结——https请求、结合hystrix、httpclient配置等

柔情只为你懂 2022-01-30 01:09 714阅读 0赞

转自：[https://blog.csdn.net/nb7474/article/details/86700847][https_blog.csdn.net_nb7474_article_details_86700847]

版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/nb7474/article/details/86700847  
目录  
一、前言  
二、具体使用  
1. feign发送post请求参数的传递  
2. 访问https地址  
3. httpclient替换feign底层的urlConection  
4. 集成hystrix进行超时回调  
三、总结  
四、其他  
1. 为什么有了hystrix控制最大连接数，还需要自定义连接池配置？  
一、前言  
Feign目前在网上能找的的有两种使用方式，一种是基于springcloud，使用@feignClient+@requestMapping。一种是github上的开源项目，使用@RequestLine注解。

此次示例使用的是第一种方式，但是并没有使用springcloud的服务中心eureka。主要记录了使用feign发送请求参数的传递，访问https地址、httpclient替换feign底层的urlConection，集成hystrix进行超时回调。

二、具体使用  
在具体使用之前需要进行相关jar的依赖添加：

<dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-starter-openfeign</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>  
        </dependency>  
          
        <dependency>  
              
            <groupId>io.github.openfeign</groupId>  
            <artifactId>feign-httpclient</artifactId>  
              
        </dependency>  
  
feign-httpclient用于httpclient替换feign底层http请求。  
spring-cloud-starter-netflix-ribbon在进行https地址调用的时候会用到。相关的application.yml配置在具体demo按需要添加。

1. feign发送post请求参数的传递  
@FeignClient(name="feignService",url="$\{dlc.amap.ip\}")  
public interface FeignHttpsService \{  
      
    @RequestMapping(value="$\{dlc.amap.address\}=\{sign\}",method = RequestMethod.POST,consumes = MediaType.APPLICATION\_JSON\_UTF8\_VALUE)  
    String sendPost(@RequestBody String str, @PathVariable String sign);  
      
    @RequestMapping(value="helloget",method = RequestMethod.GET)  
    String sendGet();  
      
\}  
  
定义一个接口，接口中有发送get和post两种请求的方法，此接口不需要写实现方法，在项目中使用@autowired注解引入进行使用即可。

@RestController  
public class FeignController \{

@Autowired  
    private FeignHttpsService feignHttpService;  
      
    @Autowired  
    private FeignService feignService;  
      
    @RequestMapping("test")  
    public String test()\{  
          
        String string = "\{\\n" +  
                "    \\"account\\":\\"leads\_catalyst\_intg\\",\\n" +  
                "    \\"busiextStr\\":\\"eyJwYXJhbXMiOnsiVmFyXzE1IjoieHN2IiwiVmFyXzEyIjoid2NwIiwiVmFyXzEzIjoic21uIiwiVmFyXzE0IjoiYXRxIn0sInF1cyI6ImF1dG8tc3RkLW1sLWNvbSMxMDEwMDAifQ==\\",\\n" +  
                "    \\"mobile\\":\\"PbrUyeLK9SlJu0S+JyzPnk44L6BKIAOkG56FaE0vuBIkBPwWjPFQBPsjPOmDbezuhqspD7CJR6KeJUUUbZddi5goTRm+iDHJyE9jKhGoXQOIpY7v8bv0/1lXaW8EipqHQ8WLo0lRMtRg+6rdynDOULIwnv0ieQWjM9babHfG9QE=\\"\\n" +  
                "\}";  
          
        String sign = "dc5dfed260441a5ca69ecb6cbaecba9b";  
        String sendPost = feignHttpService.sendPost(string,sign);  
          
        System.out.println("https的Post请求："+sendPost);  
          
        return sendPost;  
    \}  
      
    @RequestMapping("get")  
    public String test2()\{  
          
        String sendPost = feignService.sendGet();  
          
        return sendPost;  
    \}  
      
\}  
  
在FeignHttpsService接口中可以发现并没有写什么具体的url，全部都是使用$\{\}的方式引入，这样做的好处是可以统一管理url，我们一般是通过ip+实例名进行访问url，在application.yml文件中对url与实例名进行配置，如果后面有需要改动url的情况，只需要改动配置文件即可，不要改动代码。

dlc:  
  amap:  
    ip: https://127.0.0.1:6543/  
    address: api/test?sign  
  
在FeignHttpsService接口中还可以看到参数的传递也是使用\{\}进行替换，需要注意的是@RequestBody注解是要通过post传递的参数内容, @PathVariable表示是要在url后面进行拼接的参数。

通过日志打印可以清楚的看到最终访问的url：

2019-01-28 17:58:13.489 DEBUG 2868 --- \[-feignService-1\] c.example.demo.client.FeignHttpsService  : \[FeignHttpsService\#sendPost\] ---> POST https://127.0.0.1:6543/api/test?sign=dc5dfed260441a5ca69ecb6cbaecba9b HTTP/1.1  
2019-01-28 17:58:13.490 DEBUG 2868 --- \[-feignService-1\] c.example.demo.client.FeignHttpsService  : \[FeignHttpsService\#sendPost\] Content-Type: application/json;charset=UTF-8  
  
2. 访问https地址  
@Configuration  
public class FeignConfig \{  
      
    @Bean  
    @ConditionalOnMissingBean  
    public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory,  
                              SpringClientFactory clientFactory) throws NoSuchAlgorithmException, KeyManagementException \{  
        SSLContext ctx = SSLContext.getInstance("SSL");  
        X509TrustManager tm = new X509TrustManager() \{  
            @Override  
            public void checkClientTrusted(X509Certificate\[\] chain,  
                                           String authType) throws CertificateException \{  
            \}  
            @Override  
            public void checkServerTrusted(X509Certificate\[\] chain,  
                                           String authType) throws CertificateException \{  
            \}  
            @Override  
            public X509Certificate\[\] getAcceptedIssuers() \{  
                return null;  
            \}  
        \};  
        ctx.init(null, new TrustManager\[\]\{tm\}, null);  
        return new LoadBalancerFeignClient(new Client.Default(ctx.getSocketFactory(),  
                new HostnameVerifier() \{  
                      
                    @Override  
                    public boolean verify(String hostname, SSLSession session) \{  
                        // TODO Auto-generated method stub  
                        return true;  
                    \}  
                \}) ,  
                cachingFactory, clientFactory);  
    \}  
\}  
  
需要在@Configuration注解修饰的类中进行证书认证忽略的操作，这样就可以访问https开头的url。

3. httpclient替换feign底层的urlConection  
只需在application.yml中新增配置项，其他不需要改变，就可以实现httpclient替换urlconnection。

feign:  
  httpclient:  
    enabled: true  
1  
2  
3  
根据springboot的自动配置原理，如果能够找到httpclient的相关class，就会进行自动配置。在最开始的时候我们已经引入了httpClient的依赖，所以增加配置项即可启用，通过查看源码会发现feign给我们默认配置了一套连接池。

默认的连接池配置：

这里有个问题没解决的就是通过@bean新建一个httpclient的连接池，但是在spring启动的时候没有生效。使用actutor查看发现使用的仍然是最初的feign默认的连接池。按理自定义的bean会将spring创建的bean给覆盖，这里却没有。

@Configuration  
public class FeignConfig \{  
    @Bean  
    public HttpClient httpClient()\{  
        System.err.println("init feign httpclient configuration 1111" );  
        // 生成默认请求配置  
        RequestConfig.Builder requestConfigBuilder = RequestConfig.custom();  
        // 超时时间  
        requestConfigBuilder.setSocketTimeout(5 \* 1000);  
        // 连接时间  
        requestConfigBuilder.setConnectTimeout(5 \* 1000);  
        RequestConfig defaultRequestConfig = requestConfigBuilder.build();  
        // 连接池配置  
        // 长连接保持30秒  
        final PoolingHttpClientConnectionManager pollingConnectionManager = new PoolingHttpClientConnectionManager(30, TimeUnit.MILLISECONDS);  
        // 总连接数  
        pollingConnectionManager.setMaxTotal(5000);  
        // 同路由的并发数  
        pollingConnectionManager.setDefaultMaxPerRoute(100);

// httpclient 配置  
        HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();  
        // 保持长连接配置，需要在头添加Keep-Alive  
        httpClientBuilder.setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy());  
        httpClientBuilder.setConnectionManager(pollingConnectionManager);  
        httpClientBuilder.setDefaultRequestConfig(defaultRequestConfig);  
        HttpClient client = httpClientBuilder.build();

// 启动定时器，定时回收过期的连接  
        Timer timer = new Timer();  
        timer.schedule(new TimerTask() \{  
            @Override  
            public void run() \{  
                //        System.out.println("=====closeIdleConnections===");  
                pollingConnectionManager.closeExpiredConnections();  
                pollingConnectionManager.closeIdleConnections(5, TimeUnit.SECONDS);  
            \}  
        \}, 10 \* 1000, 5 \* 1000);  
        System.out.println("===== Apache httpclient 初始化连接池===");

return client;  
    \}  
\}  
  
4. 集成hystrix进行超时回调  
@FeignClient(name="feignService",url="$\{dlc.amap.ip\}",fallback=FeignFallback.class)  
public interface FeignHttpsService \{  
      
    @RequestMapping(value="$\{dlc.amap.address\}=\{sign\}",method = RequestMethod.POST,consumes = MediaType.APPLICATION\_JSON\_UTF8\_VALUE)  
    String sendPost(@RequestBody String str, @PathVariable String sign);  
      
    @RequestMapping(value="helloget",method = RequestMethod.GET)  
    String sendGet();  
      
      
      
\}

@Component  
class FeignFallback implements FeignHttpsService \{

@Override  
    public String sendPost(String str, String sign) \{  
        // TODO Auto-generated method stub  
        return "sendPost的回调方法";  
    \}

@Override  
    public String sendGet() \{  
        // TODO Auto-generated method stub  
        return "sendGet的回调方法";  
    \}

\}  
  
@FeignClient中指定fallback的回调方法，此方法需要用@Component修饰，并实现@FeignClient修饰的接口。实现方法后需要重写接口，通过重写可以实现在回调方法中进行出现错误时候的日志记录。

application.yml新增超时时间配置，hystrix默认的超时时间是1s，超过这个时间就会调用fallback的方法。

hystrix:  
  command:  
    "FeignHttpsService\#sendPost(String,String)":  
      execution:  
        isolation:  
          thread:  
            timeoutInMilliseconds: 6000  
  
注意：如果不使用指定超时时间的接口及方法 “FeignHttpsService\#sendPost(String,String)”，而是使用默认的default的话，就是所有的fallback的超时时间都是6s。指定哪个方法需要进行超时回调的时候需要使用类名+方法名+方法所需参数类型的方式指定。

三、总结  
以上就是使用springcloud中的feign进行http请求控制的一些使用方法，但是由于目前没找到自定义连接池的方式，所以在使用的过程中需要考虑这一点，还有一个feign是github上开源出来脱离于springcloud的使用，这种是依托于命令式编程。可以进行自定义连接池配置。具体使用还没有进行尝试。

四、其他  
1. 为什么有了hystrix控制最大连接数，还需要自定义连接池配置？  
因为hystrix是在连接池的上一层的，假若连接池最大连接数是100，但是hystrix最大连接数是200，这样是无法触发hystrix熔断机制的，所以在进行hystrix配置的时候，也要考虑连接池配置如何自定义。  
\---------------------   
作者：nb7474   
来源：CSDN   
原文：https://blog.csdn.net/nb7474/article/details/86700847   
版权声明：本文为博主原创文章，转载请附上博文链接！

[https_blog.csdn.net_nb7474_article_details_86700847]: https://blog.csdn.net/nb7474/article/details/86700847