SpringCloud利用Feign访问外部http请求

       大家好，目前接手了一个项目，具体的逻辑并不复杂，主要是一个"中间商"角色， 比如客户端通过我访问高德地图API，就不需要带秘钥，直接带高德API所需的入参和url后缀，就可以访问。

      目前遇到这样一个问题，项目架构师要求所有的项目自己写的htttpClintUtils或者其他工具，需要替换到feign的形式来完成调用，但是，目前这个项目访问外部的http接口很多，比如，提供的高德服务就有10多种，一共有大几十类型，这样的话，如果按照以前的方式，一个接口指定一个高德子服务，那岂不是要累死 = =！

     累死人的写法:(仅参考)

@FeignClient(value = "test",url = "http://ip:port")
public interface TestFeign {
    /**
     * @return 高德服务接口
     * @description 访问高德地理编码服务
     */
    @PostMapping(value = "/Amap/geo")
    Object geo(@RequestBody GeoEntity entity);

    /**
     * @return 高德服务接口
     * @description 访问高德逆地理编码服务
     */
    @PostMapping(value = "/Amap/regeo")
    Object regeo(@RequestBody RegeoEntity entity);


    .........
    ...........
}

       然后如果我除了高德服务还有其他外部服务，并且其他外部服务下的子接口，不一定就两个，那这样写的话，要头大死，并且这样的写法，在服务的内部，不能做秘钥和权限的动态配置，只能在url上做指定，比较笨拙，所以就需要一种可以灵活访问外部httpClient的Feign接口，只需要我指定一个url,指定下提交的post数据，就可以得到返回结果，岂不是美滋滋？

       话不多说，先上pom.xml

 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

        <!-- 引入 httpclient -->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
        </dependency>
        <dependency>
            <groupId>com.netflix.feign</groupId>
            <artifactId>feign-httpclient</artifactId>
            <version>8.18.0</version>
        </dependency>

前两个是feign和服务降级用到的包，后两个是用Apache Http替换原生的feign-http-client用来提供连接池等功能。

bootstap.yml 部分配置:

feign:
  httpclient:
    enabled: true
  hystrix:
    enabled: true
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 3000  #降级超时时间,我设置为3秒。 feign.retry默认超时时间是5s.

设置了个降级超时时间，还有启动了feign访问外部httpClient配置和服务降级配置。

在spingbootApplication启动类上增加注解:

@EnableFeignClients  @EnableHystrix

代码部分:

public interface HttpRequestFeign {

    @RequestLine("GET")
    String sendGetRequest(URI baseUri);

    @RequestLine("POST")
    String sendPostRequest(URI baseUri, Map map);
}

调用部分,这里我在我的BaseController构造注解，其他服务Controller继承，提供调用能力:

 @Autowired
    public BaseController(Decoder decoder, Encoder encoder) {
        httpRequestFeign = Feign.builder().encoder(encoder).decoder(decoder)
                .target(Target.EmptyTarget.create(HttpRequestFeign.class));

    }

 protected String httpPostSend( String url, Map map) {
        String response = "";
        try {
            response = httpRequestFeign.sendPostRequest(new URI(url), map);
            logger.info("调用外部服务返回的数据为->{}", response);
            // 这里改成重试的超时异常
        } catch (RetryableException a) {
            logger.error("调用外部服超时错误->{}", response);
        } catch (Exception e) {
            logger.error("调用外部服异常错误->{}", response);
        }
        return response;
    }

这里只列举了Post的，Get方式，就不用了携带map参数了。

然后在你的Controller层增加降级@HystrixCommand注解,并指定降级方法:

 @HystrixCommand(fallbackMethod = "fallback")
 @PostMapping(value = "/1_0_0/{subServer}", produces = "application/json;charset=UTF-8")
 public Object send(@RequestBody Map<String, Object> map, @PathVariable String subServer) {

.......................
....................


 private Object fallback(Map<String, String> map, String subserver, Throwable e) {
        logger.error("xxx服务发生问题,入参:{},地址:{}", map, subserver);
        return Result.fail(ResultCode.INTERNAL_SERVER_ERROR.getCode(), ERROR_MSG + e.toString());
    }

在send方法里可以自行进行拼接url,而Map就是传递给第三方服务的数据。