OKHttpUtil

OKHttpUtil

package com.jdyun.weixin.util;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.MalformedURLException;
import java.net.URL;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import java.security.KeyManagementException;
import java.security.cert.X509Certificate;
import okhttp3.ConnectionPool;
import okhttp3.FormBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.FormBody.Builder;
import okhttp3.MediaType;

/**
* Description: 用okhttp进行get和post的访问
* Copyright: jdy groups 2019年1月29日
* Company: jdyun 
* @author jdyun
* @date 2018年1月29日
* @version 1.0
*/
@Component  
public class OKHttpUtil {  

    protected static Logger logger=LoggerFactory.getLogger(OKHttpUtil.class); //log
    protected static Logger interfaceLog = LoggerFactory.getLogger("interfaceLog");//interfaceLog


    private static OkHttpClient httpClient;


    @Value("${client.backurl}")
    String backurl;

    @Value("${client.name}")
    String name;

    @Value("${client.secretkey}")
    String secretkey;


    /** 
               * 绕过验证 
     *   
     * @return 
     * @throws NoSuchAlgorithmException  
     * @throws KeyManagementException  
     */  
    @Bean
    //获取这个SSLSocketFactory 
    public static SSLSocketFactory getSSLSocketFactory() { 
      try { 
        SSLContext sslContext = SSLContext.getInstance("SSL"); 
        sslContext.init(null, getTrustManager(), new SecureRandom()); 
        return sslContext.getSocketFactory(); 
      } catch (Exception e) { 
        throw new RuntimeException(e); 
      } 
    } 

    @Bean
    //获取TrustManager 
    private static TrustManager[] getTrustManager() { 
      TrustManager[] trustAllCerts = new TrustManager[]{ 
          new X509TrustManager() { 
            @Override
            public void checkClientTrusted(X509Certificate[] chain, String authType) { 
            } 

            @Override
            public void checkServerTrusted(X509Certificate[] chain, String authType) { 
           } 

           @Override
            public X509Certificate[] getAcceptedIssuers() { 
             return new X509Certificate[]{}; 
            } 
          } 
      }; 
      return trustAllCerts; 
    } 

    //获取HostnameVerifier 
    public static HostnameVerifier getHostnameVerifier() { 
      HostnameVerifier hostnameVerifier = new HostnameVerifier() { 
        @Override
        public boolean verify(String s, SSLSession sslSession) { 
          return true; 
        } 
      }; 
      return hostnameVerifier; 
    } 

    public OKHttpUtil(){
        if(httpClient == null){
            ConnectionPool pool = new ConnectionPool(5, 50, TimeUnit.MINUTES);
            // 配置请求的超时设置  设置连接池属性 设置ssl绕过验证
            httpClient = new OkHttpClient.Builder() //
                    .connectTimeout(1, TimeUnit.MINUTES) //
                    .followRedirects(true) //
                    .readTimeout(1, TimeUnit.MINUTES) //
                    .retryOnConnectionFailure(false) //
                    .writeTimeout(3, TimeUnit.MINUTES) //
                    .connectionPool(pool) //
                    .sslSocketFactory(getSSLSocketFactory())
                    .hostnameVerifier(getHostnameVerifier())
                    .build();
        }
    }

    private  void config(Request.Builder builder) {  
        builder.addHeader("User-Agent", "Mozilla/5.0");  
        builder.addHeader("Accept","text/html,application/xhtml+xml,application/xml,application/json;q=0.9,*/*;q=0.8");  
        builder.addHeader("Accept-Language", "zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3");//"en-US,en;q=0.5");  
        builder.addHeader("Accept-Charset", "ISO-8859-1,utf-8,gbk,gb2312;q=0.7,*;q=0.7");  
        builder.addHeader("Connection", "close");
        builder.addHeader("secretkey", secretkey);
        builder.addHeader("name", name);
    }

    /**
     *httpGet
     * Description:get请求 
     * Copyright: jdyun 2019年1月30日
     * Company:  
     * @author jdyun-ceo
     * @date 2019年1月30日 下午7:39:44
     * @version 1.0
     * @param strurl
     * @return
     */
    public  String httpGet(Map paramurl,String url) throws MalformedURLException, UnsupportedEncodingException, NoSuchAlgorithmException{
        String strUrl=backurl+url;
        String addres = "";
        int i = 0;
        for (Map.Entry entry : paramurl.entrySet()) { 
            if(i == 0){
                addres += "?"+entry.getKey() +"="+entry.getValue();
            }else{
                addres += "&"+entry.getKey() +"="+entry.getValue();
            }
            i++;
        }
        strUrl += addres;
        URL u=new URL(strUrl);

        Request.Builder builder =new Request.Builder();
        config(builder);

        String rtn="{\"status\":\"fail\"}";

        try {
            Request request = builder.url(u).get()
                    .build();
            Response response = httpClient.newCall(request).execute();
            if(response.isSuccessful()){
                rtn = response.body().string();
                interfaceLog.info("系统"+url+"接口result===============>>"+rtn);
            }
        } catch (Exception e) {
            logger.error("系统"+url+"error===============>>"+e);
        }finally{
        }
        return rtn;
    }

    /**
     * 
    * httpPost
    * Description: post提交表单
    * Copyright:  2018年1月30日
    * Company:  
    * @author email:bleach.song@.cn
    * @date 2018年1月30日 下午7:39:29
    * @version 1.0
    * @param map
    * @param strurl
    * @return
     */
    public  String httpPost(Map map,String strurl) {  
        // 获取配置文件验证参数
        strurl=backurl+strurl;
        String result = null;  
        Request.Builder builder =new Request.Builder();
        config(builder);

        Builder body = new FormBody.Builder();

        for (Map.Entry entry : map.entrySet()) {  
            body.add(entry.getKey(), entry.getValue()==null?"":entry.getValue().toString());
        }

        FormBody formbody = body.build();
        try {
            Request request = builder.url(strurl).post(formbody)
                    .build();
            Response response = httpClient.newCall(request).execute();
            if(response.isSuccessful()){
                result = response.body().string();
                interfaceLog.info("系统"+strurl+"接口result===============>>"+result);
            }
        } catch (IllegalArgumentException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
        }
        return result;
    }  


    /**
     * 
    * httpGetForWechat
    * Description:微信用 
    * Copyright:  2018年8月29日
    * Company:  
    * @author jdyun
    * @date 2019年8月29日 下午3:56:02
    * @version 1.0
    * @param paramurl
    * @param url
    * @return
    * @throws MalformedURLException
    * @throws UnsupportedEncodingException
    * @throws NoSuchAlgorithmException
     */
    public  String httpGetForJSTicket(String paramurl,String url) throws MalformedURLException, UnsupportedEncodingException, NoSuchAlgorithmException{
        url += paramurl;
        URL u=new URL(url);
        Request.Builder builder =new Request.Builder();
        config(builder);

        String rtn="{\"status\":\"fail\"}";

        try {
            Request request = builder.url(u).get()
                    .build();
            Response response = httpClient.newCall(request).execute();
            if(response.isSuccessful()){
                rtn = response.body().string();
                interfaceLog.info("httpGetForJSTicketrtn===============>>"+rtn);
            }
        } catch (Exception e) {
        logger.error("httpGetForJSTicketerror===============>>"+e);
        }

        return rtn;
    }


    public  String httpGetWebtoken(String paramurl,String url) throws MalformedURLException, UnsupportedEncodingException, NoSuchAlgorithmException{
        url += paramurl;
        URL u=new URL(url);
        Request.Builder builder =new Request.Builder();
        config(builder);

        String rtn="{\"status\":\"fail\"}";
        try {
            Request request = builder.url(u).get().build();
            Response response = httpClient.newCall(request).execute();
            Boolean para = response.isSuccessful();
            interfaceLog.info("para===============>>"+para);
            if(para){
                rtn = response.body().string();
                interfaceLog.info("httpGetWebtokenrtn===============>>"+rtn);
            }
        } catch (Exception e) {
            logger.error("httpGetWebtokenerror===============>>"+e);
        }
        return rtn;
    }

    /**
     * 
    * gettoken
    * Copyright:  2018年9月12日
    * Company:  
    * @author jdyun
    * @date 2018年9月12日 上午10:48:23
    * @version 1.0
    * @param url
    * @return
    * @throws MalformedURLException
    * @throws UnsupportedEncodingException
    * @throws NoSuchAlgorithmException
     */
    public  String gettoken(String url) throws MalformedURLException, UnsupportedEncodingException, NoSuchAlgorithmException{
        URL u=new URL(url);
        Request.Builder builder =new Request.Builder();
        config(builder);

        String rtn="{\"status\":\"fail\"}";

        try {
            Request request = builder.url(u).get()
                    .build();
            Response response = httpClient.newCall(request).execute();
            if(response.isSuccessful()){
                rtn = response.body().string();
                interfaceLog.info("本地token===============>>"+rtn);
            }
        } catch (Exception e) {
            logger.error("gettokenerror===============>>"+e);
        }finally{
        }
        return rtn;
    }
}