SpringBoot feign動(dòng)態(tài)設(shè)置數(shù)據(jù)源(https請(qǐng)求)

更新時(shí)間：2021年08月26日 10:05:53 作者：此處省略一個(gè)字

這篇文章主要介紹了SpringBoot如何在運(yùn)行時(shí)feign動(dòng)態(tài)添加數(shù)據(jù)源,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

1、背景

在使用springboot-feign/spingcloud-feign時(shí)，需要在啟動(dòng)springboot的時(shí)候，注入的方式將feigncofing配置好，也就是說項(xiàng)目啟動(dòng)以后只能有一個(gè)數(shù)據(jù)源，且不能修改，在網(wǎng)上找了很多資料沒有找到解決方案（網(wǎng)上應(yīng)該有，只是我沒有找到），后面只能是硬著頭皮看源碼，問題解決，在此記錄一下，希望可以幫到有緣人

2、代碼

其實(shí)在這里用的原生的feign，并不是springboot/springcloud封裝的feign，廢話不說，上代碼

public <T> T getRemote(Class<T> apiType, String url, String apiCert, String certPassWord) {
    // apiCert 是p12文件讀了以后的數(shù)據(jù)，可以把p12文件放在本地，我這里是偽代碼了
    feign.Client.Default client = FeignClient(apiCert, certPassWord);
    Decoder decoder =
        (response, type) -> {
          final String result =
              IOUtils.toString(response.body().asInputStream(), StandardCharsets.UTF_8);
          if (String.class.getName() == type.getTypeName()) {
            return result;
          }
          try {
            return JSON.parseObject(result, type);
          } catch (Exception e) {
            log.error("json parse exception");
          }
          return result;
        };
    ErrorDecoder errorDecoder =
        (methodKey, response) -> {
          try {
            final String result =
                IOUtils.toString(response.body().asInputStream(), StandardCharsets.UTF_8);
            log.info("feign client decoder response body : {}", result);
            throw new SysStatusException(response.status(), result);
          } catch (IOException e) {
            log.info("feign client decoder response error {}", e);
          }
          throw new BizStatusException(response.status(), BizCommMessage.ERROR_MSG);
        };
    T remote =
        Feign.builder()
            .decoder(decoder)
            .errorDecoder(errorDecoder)
            .client(url)
            .target(apiType, client);
    return remote;
  }
public Client getFeignClient(String apiCert, String certPassWord) {
    final SSLSocketFactory sslSocketFactory = getSSLSocketFactory(apiCert, certPassWord);
    feign.Client.Default aDefault = new Client.Default(sslSocketFactory, new NoopHostnameVerifier());
    return aDefault;
  }
public static SSLSocketFactory getSSLSocketFactory(String apiCert, String certPassWord) {
    byte[] bytes = apiCert.getBytes();
    try (ByteArrayInputStream inputStream = new ByteArrayInputStream(bytes)) {
      KeyStore keyStore = KeyStore.getInstance(KEY_STORE_TYPE);
      keyStore.load(inputStream, certPassWord.toCharArray());
      SSLContext sslContext =
          SSLContexts.custom()
              // 忽略掉對(duì)服務(wù)器端證書的校驗(yàn),特別重要，被這行代碼坑過
              .loadTrustMaterial((TrustStrategy) (chain, authType) -> true)
              .loadKeyMaterial(keyStore, certPassWord.toCharArray())
              .build();
      return sslContext.getSocketFactory();
    } catch (IOException e) {
      log.error("=======init feign client throw IOException======={}", e);
    } catch (KeyStoreException e) {
      log.error("=======init feign client throw KeyStoreException======={}", e);
    } catch (UnrecoverableKeyException e) {
      log.error("=======init feign client throw UnrecoverableKeyException======={}", e);
    } catch (CertificateException e) {
      log.error("=======init feign client throw CertificateException======={}", e);
    } catch (NoSuchAlgorithmException e) {
      log.error("=======init feign client throw NoSuchAlgorithmException======={}", e);
    } catch (KeyManagementException e) {
      log.error("=======init feign client throw KeyManagementException======={}", e);
    }
    return null;
  }

2.2、編寫請(qǐng)求方法

public interface TestRemote {
  @Override
  @RequestLine("POST /apis/{test}/query")
  @Headers({"Content-Type: application/json","Accept: application/json"})
  @Body("{body}")
  String query(@Param("test") String test, @Param("body") String body);
}

2.3、發(fā)送請(qǐng)求

public static void main(String[] args) {
   TestRemote testRemote = getRemote(TestRemote.class,String url, String apiCert, String certPassWord);
    testRemote.query("test","{\"id\":1}");
  }