@FeignClient 实现简便http请求封装方式

@FeignClient(name = "aaa", url = "localhost:8080", decode404 = true) public interface FeignApi {     /**      * http请求      */     @PostMapping("/api/xxxx/baiduaaa")     ResponseResult getSomeMoneyForYourSelfAAA(@RequestBody AAAParam param);          /**      * 模仿上面写的Get方式请求      */     @GetMapping("/api/xxxx/baidubbb")     ResponseResult getSomeMoneyForYourSelfBBB(@RequestBody AAAParam param); }

@EnableFeignClients(basePackages = {"com.aaa"})

ResponseResult response = pmsFeignApi.getSomeMoneyForYourSelfAAA(param);

import java.io.IOException; import java.io.InterruptedIOException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import okhttp3.Interceptor; import okhttp3.Request; import okhttp3.Response; public class OkHttpRetryInterceptor implements Interceptor {undefined     private static final Logger LOGGER = LoggerFactory.getLogger(OkHttpRetryInterceptor.class);     /**      * 最大重试次数      */     private int                 executionCount;     /**      * 重试的间隔      */     private long                retryInterval;     OkHttpRetryInterceptor(Builder builder) {undefined         this.executionCount = builder.executionCount;         this.retryInterval = builder.retryInterval;     }     @Override     public Response intercept(Chain chain) throws IOException {undefined         Request request = chain.request();         Response response = doRequest(chain, request);         int retryNum = 0;         while ((response == null || !response.isSuccessful()) && retryNum <= executionCount) {undefined             LOGGER.info("intercept Request is not successful - {}", retryNum);             final long nextInterval = getRetryInterval();             try {undefined                 LOGGER.info("Wait for {}", nextInterval);                 Thread.sleep(nextInterval);             } catch (final InterruptedException e) {undefined                 Thread.currentThread().interrupt();                 throw new InterruptedIOException();             }             retryNum++;             // retry the request             response = doRequest(chain, request);         }         return response;     }     private Response doRequest(Chain chain, Request request) {undefined         Response response = null;         try {undefined             response = chain.proceed(request);         } catch (Exception e) {undefined         }         return response;     }     /**      * retry间隔时间      */     public long getRetryInterval() {undefined         return this.retryInterval;     }     public static final class Builder {undefined         private int  executionCount;         private long retryInterval;         public Builder() {undefined             executionCount = 3;             retryInterval = 1000;         }         public Builder executionCount(int executionCount) {undefined             this.executionCount = executionCount;             return this;         }         public Builder retryInterval(long retryInterval) {undefined             this.retryInterval = retryInterval;             return this;         }         public OkHttpRetryInterceptor build() {undefined             return new OkHttpRetryInterceptor(this);         }     } }

import java.util.concurrent.TimeUnit; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.AutoConfigureBefore; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.cloud.netflix.feign.FeignAutoConfiguration; import org.springframework.cloud.netflix.feign.ribbon.CachingSpringLoadBalancerFactory; import org.springframework.cloud.netflix.feign.ribbon.LoadBalancerFeignClient; import org.springframework.cloud.netflix.ribbon.SpringClientFactory; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import feign.Client; import feign.Feign; import feign.ribbon.RibbonClient; import okhttp3.ConnectionPool; import okhttp3.OkHttpClient; @Configuration @ConditionalOnMissingBean({ OkHttpClient.class, Client.class }) @ConditionalOnClass(Feign.class) @AutoConfigureBefore(FeignAutoConfiguration.class) public class FeignClientConfig {undefined     @Value("${feign.invoke.http.connectTimeoutMillis:3000}")     private int connectTimeoutMillis;     @Value("${feign.invoke.http.readTimeoutMillis:10000}")     private int readTimeoutMillis;     @Value("${feign.invoke.http.retryExecutionCount:3}")     private int retryExecutionCount;     @Value("${feign.invoke.http.retryInterval:1000}")     private int retryInterval;     public FeignClientConfig() {undefined     }     @Bean     @ConditionalOnMissingBean({ OkHttpClient.class })     public OkHttpClient okHttpClient() {undefined         OkHttpRetryInterceptor okHttpRetryInterceptor = new OkHttpRetryInterceptor.Builder().executionCount(retryExecutionCount)                                                                                             .retryInterval(retryInterval)                                                                                             .build();         return new OkHttpClient.Builder().retryOnConnectionFailure(true)                                          .addInterceptor(okHttpRetryInterceptor)                                          .connectionPool(new ConnectionPool())                                          .connectTimeout(connectTimeoutMillis, TimeUnit.MILLISECONDS)                                          .readTimeout(readTimeoutMillis, TimeUnit.MILLISECONDS)                                          .build();     }     @Bean     @ConditionalOnMissingBean({ Client.class })     public Client feignClient(CachingSpringLoadBalancerFactory cachingFactory, SpringClientFactory clientFactory) {undefined         if (cachingFactory == null) {undefined             RibbonClient.Builder builder = RibbonClient.builder();             builder.delegate(new feign.okhttp.OkHttpClient(this.okHttpClient()));             return builder.build();         } else {undefined             return new LoadBalancerFeignClient(new feign.okhttp.OkHttpClient(this.okHttpClient()), cachingFactory,                                                clientFactory);         }     } }

   io.github.openfeign  feign-ribbon  9.0.0  

@FeignClient(name = "xxxApi", url = "${xxx.url}") public interface xxxClient {      @RequestMapping(method = RequestMethod.POST)      public String createLink(@RequestHeader(name = "accessKey", defaultValue = "xx") String accessKey,          @RequestHeader(name = "accessSecret") String accessSecret, @RequestBody String linkConfig); }

    @Autowired     private xxxClient xxClient;     @HystrixCommand(commandKey = "xxxLink", fallbackMethod = "xxxError", commandProperties = { @HystrixProperty(name = "requestCache.enabled", value = "true"),                                                                                                                            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "5000") })     public String xxLink(String accessKey, String accessSecret, String linkConfig) {         LOG.info("[xxLink]  LinkConfig is {}", linkConfig);         String resp = xxxClient.createLink(accessKey, accessSecret, linkConfig);         LOG.info("[xxxLink] response : {}", resp);         return resp;     }