spring集成okhttp3的步骤详解

<dependency>
 <groupId>com.squareup.okhttp3</groupId>
 <artifactId>okhttp</artifactId>
 <version>3.6.0</version>
</dependency>

@Configuration
public class OkHttpConfiguration {
 @Bean
 public X509TrustManager x509TrustManager() {
 return new X509TrustManager() {
  @Override
  public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
  }
  @Override
  public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
  }
  @Override
  public X509Certificate[] getAcceptedIssuers() {
  return new X509Certificate[0];
  }
 };
 }
 @Bean
 public SSLSocketFactory sslSocketFactory() {
 try {
  //信任任何链接
  SSLContext sslContext = SSLContext.getInstance("TLS");
  sslContext.init(null, new TrustManager[]{x509TrustManager()}, new SecureRandom());
  return sslContext.getSocketFactory();
 } catch (NoSuchAlgorithmException e) {
  e.printStackTrace();
 } catch (KeyManagementException e) {
  e.printStackTrace();
 }
 return null;
 }
 /**
 * Create a new connection pool with tuning parameters appropriate for a single-user application.
 * The tuning parameters in this pool are subject to change in future OkHttp releases. Currently
 */
 @Bean
 public ConnectionPool pool() {
 return new ConnectionPool(200, 5, TimeUnit.MINUTES);
 }
 @Bean
 public OkHttpClient okHttpClient() {
 return new OkHttpClient.Builder()
  .sslSocketFactory(sslSocketFactory(), x509TrustManager())
  .retryOnConnectionFailure(false)//是否开启缓存
  .connectionPool(pool())//连接池
  .connectTimeout(10L, TimeUnit.SECONDS)
  .readTimeout(10L, TimeUnit.SECONDS)
  .build();
 }
}

@Component
public class OkHttpUtil {
 private static final Logger logger = LoggerFactory.getLogger(OkHttpUtil.class);
 @Resource
 private OkHttpClient okHttpClient;
 /**
 * get
 *
 * @param url 请求的url
 * @param queries 请求的参数，在浏览器？后面的数据，没有可以传null
 * @return
 */
 public String get(String url, Map<String, String> queries) {
 String responseBody = "";
 StringBuffer sb = new StringBuffer(url);
 if (queries != null && queries.keySet().size() > 0) {
  boolean firstFlag = true;
  Iterator iterator = queries.entrySet().iterator();
  while (iterator.hasNext()) {
  Map.Entry entry = (Map.Entry<String, String>) iterator.next();
  if (firstFlag) {
   sb.append("?" + entry.getKey() + "=" + entry.getValue());
   firstFlag = false;
  } else {
   sb.append("&" + entry.getKey() + "=" + entry.getValue());
  }
  }
 }
 Request request = new Request
  .Builder()
  .url(sb.toString())
  .build();
 Response response = null;
 try {
  response = okHttpClient.newCall(request).execute();
  int status = response.code();
  if (status == 200) {
  return response.body().string();
  }
 } catch (Exception e) {
  logger.error("okhttp put error >> ex = {}", ExceptionUtils.getStackTrace(e));
 } finally {
  if (response != null) {
  response.close();
  }
 }
 return responseBody;
 }
 /**
 * post
 *
 * @param url 请求的url
 * @param params post form 提交的参数
 * @return
 */
 public String post(String url, Map<String, String> params) {
 String responseBody = "";
 FormBody.Builder builder = new FormBody.Builder();
 //添加参数
 if (params != null && params.keySet().size() > 0) {
  for (String key : params.keySet()) {
  builder.add(key, params.get(key));
  }
 }
 Request request = new Request
  .Builder()
  .url(url)
  .post(builder.build())
  .build();
 Response response = null;
 try {
  response = okHttpClient.newCall(request).execute();
  int status = response.code();
  if (status == 200) {
  return response.body().string();
  }
 } catch (Exception e) {
  logger.error("okhttp post error >> ex = {}", ExceptionUtils.getStackTrace(e));
 } finally {
  if (response != null) {
  response.close();
  }
 }
 return responseBody;
 }
 /**
 * post 上传文件
 *
 * @param url
 * @param params
 * @param fileType
 * @return
 */
 public String postFile(String url, Map<String, Object> params, String fileType) {
 String responseBody = "";
 MultipartBody.Builder builder = new MultipartBody.Builder();
 //添加参数
 if (params != null && params.keySet().size() > 0) {
  for (String key : params.keySet()) {
  if (params.get(key) instanceof File) {
   File file = (File) params.get(key);
   builder.addFormDataPart(key, file.getName(), RequestBody.create(MediaType.parse(fileType), file));
   continue;
  }
  builder.addFormDataPart(key, params.get(key).toString());
  }
 }
 Request request = new Request
  .Builder()
  .url(url)
  .post(builder.build())
  .build();
 Response response = null;
 try {
  response = okHttpClient.newCall(request).execute();
  int status = response.code();
  if (status == 200) {
  return response.body().string();
  }
 } catch (Exception e) {
  logger.error("okhttp postFile error >> ex = {}", ExceptionUtils.getStackTrace(e));
 } finally {
  if (response != null) {
  response.close();
  }
 }
 return responseBody;
 }
}

@Resource
private OkHttpUtil okHttpUtil;