备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

http通信类的封装

2016-05-29 801
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： package sec.crm.sns.util; import java.io.BufferedInputStream; import java.io.

package sec.crm.sns.util;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.InetAddress;
import java.net.URL;
import java.net.URLEncoder;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.NoSuchProviderException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Map;
import java.util.Map.Entry;

import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
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 javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;

import sec.crm.sns.wechat.vo.Attachment;

/**
 * https 请求 微信为https的请求
 */
public class HttpKit {
 private static final String DEFAULT_CHARSET = "UTF-8";
 private static final String _GET = "GET"; // GET
 private static final String _POST = "POST";// POST

 private static final Logger LOGGER = Logger.getLogger(HttpKit.class);

 public static String getIpAddr(HttpServletRequest request) {
  String ip = request.getHeader("x-forwarded-for");
  if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
   ip = request.getHeader("Proxy-Client-IP");
  }
  if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
   ip = request.getHeader("WL-Proxy-Client-IP");
  }
  if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
   ip = request.getRemoteAddr();
  }
  if (ip.equals("127.0.0.1")) {
   // 根据网卡取本机配置的IP
   InetAddress inet = null;
   try {
    inet = InetAddress.getLocalHost();
   } catch (Exception e) {
    return "*.*.*.*";
   }
   ip = inet.getHostAddress();
  }
  // 对于通过多个代理的情况，第一个IP为客户端真实IP,多个IP按照','分割
  if (ip != null && ip.length() > 15) { // "***.***.***.***".length()
   // = 15
   if (ip.indexOf(",") > 0) {
    ip = ip.substring(0, ip.indexOf(","));
   }
  }
  return ip;
 }

 /**
  * 初始化http请求参数
  *
  * @param url
  * @param method
  * @param headers
  * @return
  * @throws IOException
  */
 private static HttpURLConnection initHttp(String url, String method,
   Map<String, String> headers) throws IOException {
  URL _url = new URL(url);
  HttpURLConnection http = (HttpURLConnection) _url.openConnection();
  // 连接超时
  http.setConnectTimeout(25000);
  // 读取超时 --服务器响应比较慢，增大时间
  http.setReadTimeout(25000);
  http.setRequestMethod(method);
  http.setRequestProperty("Content-Type",
    "application/x-www-form-urlencoded");
  http.setRequestProperty(
    "User-Agent",
    "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.146 Safari/537.36");
  if (null != headers && !headers.isEmpty()) {
   for (Entry<String, String> entry : headers.entrySet()) {
    http.setRequestProperty(entry.getKey(), entry.getValue());
   }
  }
  http.setDoOutput(true);
  http.setDoInput(true);
  http.connect();
  return http;
 }

 /**
  * 初始化http请求参数
  *
  * @param url
  * @param method
  * @return
  * @throws IOException
  * @throws NoSuchAlgorithmException
  * @throws NoSuchProviderException
  * @throws KeyManagementException
  */
 private static HttpsURLConnection initHttps(String url, String method,
   Map<String, String> headers) throws IOException,
   NoSuchAlgorithmException, NoSuchProviderException,
   KeyManagementException {
  TrustManager[] tm = { new MyX509TrustManager() };
  SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
  sslContext.init(null, tm, new java.security.SecureRandom());
  // 从上述SSLContext对象中得到SSLSocketFactory对象
  SSLSocketFactory ssf = sslContext.getSocketFactory();
  URL _url = new URL(url);
  HttpsURLConnection http = (HttpsURLConnection) _url.openConnection();
  // 设置域名校验
  http.setHostnameVerifier(new HttpKit().new TrustAnyHostnameVerifier());
  // 连接超时
  http.setConnectTimeout(25000);
  // 读取超时 --服务器响应比较慢，增大时间
  http.setReadTimeout(25000);
  http.setRequestMethod(method);
  http.setRequestProperty("Content-Type",
    "application/x-www-form-urlencoded");
  http.setRequestProperty(
    "User-Agent",
    "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.146 Safari/537.36");
  if (null != headers && !headers.isEmpty()) {
   for (Entry<String, String> entry : headers.entrySet()) {
    http.setRequestProperty(entry.getKey(), entry.getValue());
   }
  }
  http.setSSLSocketFactory(ssf);
  http.setDoOutput(true);
  http.setDoInput(true);
  http.connect();
  return http;
 }

 /**
  *
  * @description 功能描述: get 请求
  * @return 返回类型:
  * @throws IOException
  * @throws UnsupportedEncodingException
  * @throws NoSuchProviderException
  * @throws NoSuchAlgorithmException
  * @throws KeyManagementException
  */
 public static String get(String url, Map<String, String> params,
   Map<String, String> headers) throws KeyManagementException,
   NoSuchAlgorithmException, NoSuchProviderException,
   UnsupportedEncodingException, IOException {
  HttpURLConnection http = null;
  if (isHttps(url)) {
   http = initHttps(initParams(url, params), _GET, headers);
  } else {
   http = initHttp(initParams(url, params), _GET, headers);
  }
  InputStream in = http.getInputStream();
  BufferedReader read = new BufferedReader(new InputStreamReader(in,
    DEFAULT_CHARSET));
  String valueString = null;
  StringBuffer bufferRes = new StringBuffer();
  while ((valueString = read.readLine()) != null) {
   bufferRes.append(valueString);
  }
  in.close();
  if (http != null) {
   http.disconnect();// 关闭连接
  }
  return bufferRes.toString();
 }

 /**
  *
  * @description 功能描述: get 请求
  * @return 返回类型:
  * @throws IOException
  * @throws UnsupportedEncodingException
  * @throws NoSuchProviderException
  * @throws NoSuchAlgorithmException
  * @throws KeyManagementException
  */
 public static String get(String url) throws KeyManagementException,
   NoSuchAlgorithmException, NoSuchProviderException,
   UnsupportedEncodingException, IOException {
  return get(url, null);
 }

 /**
  *
  * @description 功能描述: get 请求
  * @return 返回类型:
  * @throws IOException
  * @throws NoSuchProviderException
  * @throws NoSuchAlgorithmException
  * @throws KeyManagementException
  * @throws UnsupportedEncodingException
  */
 public static String get(String url, Map<String, String> params)
   throws KeyManagementException, NoSuchAlgorithmException,
   NoSuchProviderException, UnsupportedEncodingException, IOException {
  return get(url, params, null);
 }

 /**
  * @description 功能描述: POST 请求
  * @return 返回类型:
  * @throws IOException
  * @throws NoSuchProviderException
  * @throws NoSuchAlgorithmException
  * @throws KeyManagementException
  */
 public static String post(String url, String params)
   throws KeyManagementException, NoSuchAlgorithmException,
   NoSuchProviderException, IOException {
  HttpURLConnection http = null;
  if (isHttps(url)) {
   http = initHttps(url, _POST, null);
  } else {
   http = initHttp(url, _POST, null);
  }
  OutputStream out = http.getOutputStream();
  out.write(params.getBytes(DEFAULT_CHARSET));
  out.flush();
  out.close();
  InputStream in = http.getInputStream();
  BufferedReader read = new BufferedReader(new InputStreamReader(in,
    DEFAULT_CHARSET));
  String valueString = null;
  StringBuffer bufferRes = new StringBuffer();
  while ((valueString = read.readLine()) != null) {
   bufferRes.append(valueString);
  }
  in.close();
  if (http != null) {
   http.disconnect();// 关闭连接
  }
  return bufferRes.toString();
 }

 /**
  * 上传媒体文件
  *
  * @param url
  * @param params
  * @param file
  * @return
  * @throws IOException
  * @throws NoSuchAlgorithmException
  * @throws NoSuchProviderException
  * @throws KeyManagementException
  */
 public static String upload(String url, File file) throws IOException,
   NoSuchAlgorithmException, NoSuchProviderException,
   KeyManagementException {
  String BOUNDARY = "----WebKitFormBoundaryiDGnV9zdZA1eM1yL"; // 定义数据分隔线
  StringBuffer bufferRes = null;
  URL urlGet = new URL(url);
  HttpURLConnection conn = (HttpURLConnection) urlGet.openConnection();
  conn.setDoOutput(true);
  conn.setDoInput(true);
  conn.setUseCaches(false);
  conn.setRequestMethod("POST");
  conn.setRequestProperty("connection", "Keep-Alive");
  conn.setRequestProperty(
    "user-agent",
    "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/32.0.1700.107 Safari/537.36");
  conn.setRequestProperty("Charsert", "UTF-8");
  conn.setRequestProperty("Content-Type",
    "multipart/form-data; boundary=" + BOUNDARY);
  OutputStream out = new DataOutputStream(conn.getOutputStream());
  byte[] end_data = ("\r\n--" + BOUNDARY + "--\r\n").getBytes();// 定义最后数据分隔线
  StringBuilder sb = new StringBuilder();
  sb.append("--");
  sb.append(BOUNDARY);
  sb.append("\r\n");
  sb.append("Content-Disposition: form-data;name=\"media\";filename=\""
    + file.getName() + "\"\r\n");
  sb.append("Content-Type:application/octet-stream\r\n\r\n");
  byte[] data = sb.toString().getBytes();
  out.write(data);
  DataInputStream fs = new DataInputStream(new FileInputStream(file));
  int bytes = 0;
  byte[] bufferOut = new byte[1024];
  while ((bytes = fs.read(bufferOut)) != -1) {
   out.write(bufferOut, 0, bytes);
  }
  out.write("\r\n".getBytes()); // 多个文件时，二个文件之间加入这个
  fs.close();
  out.write(end_data);
  out.flush();
  out.close();
  // 定义BufferedReader输入流来读取URL的响应
  InputStream in = conn.getInputStream();
  BufferedReader read = new BufferedReader(new InputStreamReader(in,
    DEFAULT_CHARSET));
  String valueString = null;
  bufferRes = new StringBuffer();
  while ((valueString = read.readLine()) != null) {
   bufferRes.append(valueString);
  }
  in.close();
  if (conn != null) {
   // 关闭连接
   conn.disconnect();
  }
  return bufferRes.toString();
 }

 /**
  * 下载资源
  *
  * @param url
  * @return
  * @throws IOException
  */
 public static Attachment download(String url) throws IOException {
  Attachment att = new Attachment();
  HttpURLConnection conn = initHttp(url, _GET, null);
  if (conn.getContentType().equalsIgnoreCase("text/plain")) {
   // 定义BufferedReader输入流来读取URL的响应
   InputStream in = conn.getInputStream();
   BufferedReader read = new BufferedReader(new InputStreamReader(in,
     DEFAULT_CHARSET));
   String valueString = null;
   StringBuffer bufferRes = new StringBuffer();
   while ((valueString = read.readLine()) != null) {
    bufferRes.append(valueString);
   }
   in.close();
   att.setError(bufferRes.toString());
  } else {
   BufferedInputStream bis = new BufferedInputStream(
     conn.getInputStream());
   String ds = conn.getHeaderField("Content-disposition");
   String fullName = ds.substring(ds.indexOf("filename=\"") + 10,
     ds.length() - 1);
   String relName = fullName.substring(0, fullName.lastIndexOf("."));
   String suffix = fullName.substring(relName.length() + 1);
   att.setFullName(fullName);
   att.setFileName(relName);
   att.setSuffix(suffix);
   att.setContentLength(conn.getHeaderField("Content-Length"));
   att.setContentType(conn.getHeaderField("Content-Type"));
   att.setFileStream(bis);
  }
  return att;
 }

 /**
  * 功能描述: 构造请求参数
  *
  * @return 返回类型:
  * @throws UnsupportedEncodingException
  */
 public static String initParams(String url, Map<String, String> params)
   throws UnsupportedEncodingException {
  if (null == params || params.isEmpty()) {
   return url;
  }
  StringBuilder sb = new StringBuilder(url);
  if (url.indexOf("?") == -1) {
   sb.append("?");
  }
  sb.append(map2Url(params));
  return sb.toString();
 }

 /**
  * map构造url
  *
  * @return 返回类型:
  * @throws UnsupportedEncodingException
  */
 public static String map2Url(Map<String, String> paramToMap)
   throws UnsupportedEncodingException {
  if (null == paramToMap || paramToMap.isEmpty()) {
   return null;
  }
  StringBuffer url = new StringBuffer();
  boolean isfist = true;
  for (Entry<String, String> entry : paramToMap.entrySet()) {
   if (isfist) {
    isfist = false;
   } else {
    url.append("&");
   }
   url.append(entry.getKey()).append("=");
   String value = entry.getValue();
   if (StringUtils.isNotEmpty(value)) {
    url.append(URLEncoder.encode(value, DEFAULT_CHARSET));
   }
  }
  return url.toString();
 }

 /**
  * 检测是否https
  *
  * @param url
  */
 private static boolean isHttps(String url) {
  return url.startsWith("https");
 }

 /**
  * https 域名校验
  *
  * @param url
  * @param params
  * @return
  */
 public class TrustAnyHostnameVerifier implements HostnameVerifier {
  public boolean verify(String hostname, SSLSession session) {
   return true;// 直接返回true
  }
 }

 public static void main(String[] args) {
  String fname = "dsasdas.mp4";
  String s = fname.substring(0, fname.lastIndexOf("."));
  String f = fname.substring(s.length() + 1);
  System.out.println(f);
 }
}

/**
 * 证书管理
 */
class MyX509TrustManager implements X509TrustManager {
 public X509Certificate[] getAcceptedIssuers() {
  return null;
 }

 @Override
 public void checkClientTrusted(X509Certificate[] chain, String authType)
   throws CertificateException {
 }

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

文章标签：
Java
Windows
移动开发
Web App开发
iOS开发
关键词：
HTTP通信
HTTP封装
HTTPS封装
flzhang
目录
相关文章
w风雨无阻w
|
6月前
|
Android开发
Android Http 请求封装及使用
Android Http 请求封装及使用
w风雨无阻w
134 0
wljslmz
|
2月前
|
资源调度 JavaScript API
如何封装axios，并展示一个可重用的HTTP请求模块？
【2月更文挑战第8天】
wljslmz
34 3
高二的笔记
|
3月前
【web server】HTTP协议如何解析or封装
【web server】HTTP协议如何解析or封装
高二的笔记
30 0
全栈若城
|
8月前
|
Web App开发 网络协议 前端开发
【从零学习python 】86. 深入了解HTTP协议及其在浏览器和服务器通信中的作用
【从零学习python 】86. 深入了解HTTP协议及其在浏览器和服务器通信中的作用
全栈若城
87 0
CHJBL
|
8月前
|
编解码 移动开发 C++
初识http协议，简单实现浏览器和服务器通信
初识http协议，简单实现浏览器和服务器通信
CHJBL
730 0
beloved000
|
8月前
|
Java API Apache
Java HTTP请求封装的方法及实现
在Java开发中，我们经常需要与服务器进行数据交互，发送HTTP请求是其中常见的一种方式。为了简化开发过程，我们可以封装HTTP请求的方法，让调用者只需要关注业务逻辑而不用关心底层的细节实现。本文将介绍一种基于Java的HTTP请求封装方法及其实现。
beloved000
187 2
beloved000
|
8月前
|
Java API Apache
Java HTTP请求封装的方法及实现
在Java开发中，我们经常需要与服务器进行数据交互，发送HTTP请求是其中常见的一种方式。为了简化开发过程，我们可以封装HTTP请求的方法，让调用者只需要关注业务逻辑而不用关心底层的细节实现。本文将介绍一种基于Java的HTTP请求封装方法及其实现。
beloved000
74 0
硕风和炜
|
9月前
|
存储 域名解析 安全
计算机网络面试专题:HTTP协议基本概念以及通信过程
计算机网络面试专题:HTTP协议基本概念以及通信过程、HTTPS基本概念、SSL加密原理、通信过程、中间人攻击问题、HTTP协议和HTTPS协议区别
硕风和炜
66 1
长沙红胖子Qt
|
11月前
|
Ubuntu IDE Java
Qt+QtWebApp开发笔记（一）：QtWebApp介绍、下载和搭建基础封装http轻量级服务器Demo
在arm上做了Qt的应用程序，为了在局域网实现web页的访问方式来配置arm上Qt的程序，局域网轻量级http服务器是很好的实现方式之一，有机会做国产麒麟上Qt的http服务器，正好接触到了QtWebApp可以实现。   本篇实战解说QtWebApp的轻量级Demo。   本篇篇幅较长，为了保持基础的完整性将必要的东西都放在本篇。
长沙红胖子Qt
2338 0
熊的猫
|
前端开发 JavaScript 容器
如何封装一个可取消的 HTTP 请求？
如何封装一个可取消的 HTTP 请求？
熊的猫
109 0

热门文章

最新文章

  • 1
    SpringBoot项目调用HTTP接口5种方式你了解多少？
  • 2
    推荐：实现RTSP/RTMP/HLS/HTTP协议的轻量级流媒体框架，支持大并发连接请求
  • 3
    推荐一个比较好用的c++版本http协议库-cpp-httplib
  • 4
    TCP/IP、Http、Socket之间的区别
  • 5
    网络原理(4)HTTP协议（下）
  • 6
    slb监听协议http
  • 7
    HTTP-FLV详解及分析（二）
  • 8
    对象存储oss使用问题之flutter使用http库进行post请求文件上传返回400如何解决
  • 9
    深入解析：HTTP和HTTPS的三次握手与四次挥手
  • 10
    java原生发送http请求
  • 1
    http和https的区别！
    6
  • 2
    Internal error. Please report to https://jb.gg/ide/critical-startup-errors
    6
  • 3
    解决跨域和https不能访问的问题
    23
  • 4
    Tomcat详解（七）——Tomcat使用https配置实战
    16
  • 5
    Android网络和数据交互： 什么是HTTP和HTTPS？在Android中如何进行网络请求？
    8
  • 6
    【面试必备】HTTP和HTTPS是什么？有什么差异？
    15
  • 7
    阿里云服务器配置免费https服务
    91
  • 8
    网络原理(5)--HTTPS是如何进行加密的
    7
  • 9
    阿里云SSL证书配置（HTTPS证书配置）
    77
  • 10
    nginx配置https访问
    26

    • 相关课程

    更多
  • Java Web开发-Web应用、Tomcat、HTTP请求与响应
  • 云安全基础课- HTTP协议基础

    • 相关电子书

    更多
  • 阿里巴巴HTTP 2.0实践及无线通信协议的演进之路
  • CDN助力企业网站进入HTTPS时代
  • 低代码开发师（初级）实战教程

    • 相关实验场景

    更多
  • 通过HTTPS加速网关快速部署网站加密
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）