Https通信工具类

  记录一个在微信开发中用到的https通信工具类,以后会用到的。

  

  用于https通信的证书信任管理器

import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;

import javax.net.ssl.X509TrustManager;

/**
 * 证书信任管理器(用于https请求)
 */
public class MyX509TrustManager implements X509TrustManager {  
    /**
     * create by yyc 2017年6月27日上午10:24:49
     */
    @Override
    public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {
        // TODO Auto-generated method stub
        
    }

    /**
     * create by yyc 2017年6月27日上午10:24:49
     */
    @Override
    public void checkServerTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {
        // TODO Auto-generated method stub
        
    }

    /**
     * create by yyc 2017年6月27日上午10:24:49
     */
    @Override
    public X509Certificate[] getAcceptedIssuers() {
        // TODO Auto-generated method stub
        return null;
    }  
} 

   httpRequest方法,就是用于https通信的,方法传入请求的url,请求的方式(如:GET,POST),请求发送的数据等

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ConnectException;
import java.net.URL;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.TrustManager;
import org.apache.commons.httpclient.HttpStatus;


/**
 * 编写一个用于发起https请求的工具类WeiXinNetWorkUtil 访问网络用到的工具类
 */
public class WeiXinNetWorkUtil {
    /**
     * 发起Https请求
     * 
     * @param reqUrl
     *            请求的URL地址
     * @param requestMethod
     *            请求的方法
     * @param outputStr
     *            提交的数据
     * @return 响应后的字符串(可能是json、xml或其它,但都是String型的) httpRequest方法是请求一个https地址,
     *         参数requestMethod为字符串“GET”或者“POST”,传null或者“”默认为get方式,
     *         参数outputStr为一个要提交的字符串,不为""或null时,requestMethod为“POST”。
     */
    public static String httpRequest(String reqUrlString, String requestMethod, String outputStr) {
        URL url;
        HttpsURLConnection conn = null;
        InputStream inputStream = null;
        InputStreamReader inputStreamReader = null;
        BufferedReader bufferReader = null;
        StringBuffer resultData = new StringBuffer();
        try {
            // 创建url资源
            url = new URL(reqUrlString);
            // 建立http连接
            conn = (HttpsURLConnection) url.openConnection();

            // 创建SSLContext对象,并使用我们指定的信任管理器初始化
            TrustManager[] tm = { new MyX509TrustManager() };

            SSLContext ctx = SSLContext.getInstance("SSL", "SunJSSE");
            ctx.init(null, tm, new java.security.SecureRandom());

            conn.setSSLSocketFactory(ctx.getSocketFactory());
            conn.setHostnameVerifier(new HostnameVerifier() {
                @Override
                public boolean verify(String arg0, SSLSession arg1) {
                    return true;
                }
            });

            conn.setDoInput(true); // 允许输入流,即允许下载

            conn.setDoOutput(true); // 允许输出流,即允许上传
            conn.setUseCaches(false); // 是否使用缓冲
            if (null != requestMethod && !"".equals(requestMethod)) {
                conn.setRequestMethod(requestMethod); // 使用指定的方式
            } else {
                conn.setRequestMethod("GET"); // 使用get请求
            }

            // 当有数据需要提交时
            if (null != outputStr && !"".equals(outputStr)) {
                OutputStream outputStream = conn.getOutputStream();
                // 注意编码格式,防止中文乱码
                outputStream.write(outputStr.getBytes("UTF-8"));
                outputStream.flush();
                // 释放资源
                if (outputStream != null) {
                    outputStream.close();
                    outputStream = null;
                }
            }

            conn.connect();// 开始连接请求

            // 请求返回的状态
            if (conn.getResponseCode() == HttpStatus.SC_OK) {

                System.out.println("https网络连接成功,返回码:"+conn.getResponseCode());
                inputStream = conn.getInputStream(); // 获取输入流
                inputStreamReader = new InputStreamReader(inputStream);
                bufferReader = new BufferedReader(inputStreamReader);
                String inputLine;
                while ((inputLine = bufferReader.readLine()) != null) {// 将返回的输入流转换成字符串
                    resultData.append(inputLine + "\n");
                }

                // 释放资源
                if (bufferReader != null) {
                    bufferReader.close();
                    bufferReader = null;
                }
                if (inputStreamReader != null) {
                    inputStreamReader.close();
                    inputStreamReader = null;
                }
                if (inputStream != null) {
                    inputStream.close();
                    inputStream = null;
                }
            }else{
                System.out.println("https网络连接错误,错误码:"+conn.getResponseCode());
            }
        } catch (ConnectException ce) {
            System.err.println("Weixin server connection timed out.");
            ce.printStackTrace();
        } catch (Exception e) {
            System.err.println("https request error.");
            e.printStackTrace();
        } finally {
            // 断开网络连接
            conn.disconnect();
        }
        
        return resultData.toString();
    }

}

 20170822发现通过上述方式发送数据,对方在通过如下方式不能接收

    byte[] bytes = null;
        try {
            final ServletInputStream inputStream = request.getInputStream();
            ServletInputStream iii = request.getInputStream();
            int len = request.getContentLength();
            bytes = new byte[len];
            iii.read(bytes, 0, len);
        } catch (IOException e) {
            e.printStackTrace();
        }
        String string = new String (bytes);
        System.out.println(string);

解决方法:发送数据时,不用OutputStream来将数据放到输出流中 ,用它的一个子类(DataOutputStream)就可以。

如下:

OutputStream outputStream = conn.getOutputStream();
                // 注意编码格式,防止中文乱码
                DataOutputStream out=new DataOutputStream(outputStream);
                out.write(outputStr.getBytes("UTF-8"));
//                outputStream.write(outputStr.getBytes("UTF-8"));
                outputStream.flush();
                out.flush();
                // 释放资源
                if (null != outputStream){
                    outputStream.close();
                }
                if (null != out){
                    out.close();
                }

 

 

全部评论

相关推荐

点赞 收藏 评论
分享
正在热议
# 牛客帮帮团来啦!有问必答 #
1151650次浏览 17149人参与
# 通信和硬件还有转码的必要吗 #
11203次浏览 101人参与
# OPPO开奖 #
19201次浏览 267人参与
# 和牛牛一起刷题打卡 #
18978次浏览 1635人参与
# 实习与准备秋招该如何平衡 #
203386次浏览 3627人参与
# 大厂无回复,继续等待还是奔赴小厂 #
4972次浏览 30人参与
# 不去互联网可以去金融科技 #
20385次浏览 255人参与
# 通信硬件薪资爆料 #
265913次浏览 2484人参与
# 国企是理工四大天坑的最好选择吗 #
2223次浏览 34人参与
# 互联网公司评价 #
97687次浏览 1280人参与
# 简历无回复,你会继续海投还是优化再投? #
25037次浏览 354人参与
# 0offer是寒冬太冷还是我太菜 #
454868次浏览 5124人参与
# 国企和大厂硬件兄弟怎么选? #
53903次浏览 1012人参与
# 参加过提前批的机械人,你们还参加秋招么 #
14644次浏览 349人参与
# 硬件人的简历怎么写 #
82286次浏览 852人参与
# 面试被问第一学历差时该怎么回答 #
19398次浏览 213人参与
# 你见过最离谱的招聘要求是什么? #
28097次浏览 248人参与
# 学历对求职的影响 #
161239次浏览 1804人参与
# 你收到了团子的OC了吗 #
538722次浏览 6386人参与
# 你已经投递多少份简历了 #
344226次浏览 4963人参与
# 实习生应该准时下班吗 #
96977次浏览 722人参与
# 听劝,我这个简历该怎么改? #
63524次浏览 622人参与
牛客网
牛客企业服务