首页 > 编程语言 > 详细

java的HTTP工具类

时间:2017-12-15 13:57:05      阅读:271      评论:0      收藏:0      [点我收藏+]

import java.io.IOException; 

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import flexjson.JSON;

/**
* HTTP工具类
*
* @author yaonian
*
*/
public class HttpUtils {

  private static Log log = LogFactory.getLog(HttpUtils.class);

/**
* 定义编码格式 UTF-8
*/
  public static final String URL_PARAM_DECODECHARSET_UTF8 = "UTF-8";

/**
* 定义编码格式 GBK
*/
  public static final String URL_PARAM_DECODECHARSET_GBK = "GBK";

  private static final String URL_PARAM_CONNECT_FLAG = "&";

  private static final String EMPTY = "";

  private static MultiThreadedHttpConnectionManager connectionManager = null;

  private static int connectionTimeOut = 25000;

  private static int socketTimeOut = 25000;

  private static int maxConnectionPerHost = 20;

  private static int maxTotalConnections = 20;

  private static HttpClient client;

static{
  connectionManager = new MultiThreadedHttpConnectionManager();
  connectionManager.getParams().setConnectionTimeout(connectionTimeOut);
  connectionManager.getParams().setSoTimeout(socketTimeOut);
  connectionManager.getParams().setDefaultMaxConnectionsPerHost(maxConnectionPerHost);
  connectionManager.getParams().setMaxTotalConnections(maxTotalConnections);
  client = new HttpClient(connectionManager);
}

/**
* POST方式提交数据
* @param url
* 待请求的URL
* @param params
* 要提交的数据
* @param enc
* 编码
* @return
* 响应结果
* @throws IOException
* IO异常
*/
public static String URLPost(String url, Map<String, String> params, String enc){

  String response = EMPTY;
  PostMethod postMethod = null;
  try {
    postMethod = new PostMethod(url);
    postMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=" + enc);
    //将表单的值放入postMethod中
    Set<String> keySet = params.keySet();
    for(String key : keySet){
      String value = params.get(key);
      postMethod.addParameter(key, value);
    }
    //执行postMethod
    int statusCode = client.executeMethod(postMethod);
    if(statusCode == HttpStatus.SC_OK) {
      response = postMethod.getResponseBodyAsString();
    }else{
      log.error("响应状态码 = " + postMethod.getStatusCode());
    }
  }catch(HttpException e){
    log.error("发生致命的异常,可能是协议不对或者返回的内容有问题", e);
    e.printStackTrace();
  }catch(IOException e){
    log.error("发生网络异常", e);
    e.printStackTrace();
  }finally{
    if(postMethod != null){
      postMethod.releaseConnection();
      postMethod = null;
  }
  }

  return response;
  }

/**
* GET方式提交数据
* @param url
* 待请求的URL
* @param params
* 要提交的数据
* @param enc
* 编码
* @return
* 响应结果
* @throws IOException
* IO异常
*/
public static String URLGet(String url, Map<String, String> params, String enc){

  String response = EMPTY;
  GetMethod getMethod = null;
  StringBuffer strtTotalURL = new StringBuffer(EMPTY);

  if(strtTotalURL.indexOf("?") == -1) {
    strtTotalURL.append(url).append("?").append(getUrl(params, enc));
  } else {
    strtTotalURL.append(url).append("&").append(getUrl(params, enc));
  }
  log.debug("GET请求URL = \n" + strtTotalURL.toString());

  try {
    getMethod = new GetMethod(strtTotalURL.toString());
    getMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=" + enc);
    //执行getMethod
    int statusCode = client.executeMethod(getMethod);
    if(statusCode == HttpStatus.SC_OK) {
      response = getMethod.getResponseBodyAsString();
    }else{
      log.debug("响应状态码 = " + getMethod.getStatusCode());
    }
  }catch(HttpException e){
    log.error("发生致命的异常,可能是协议不对或者返回的内容有问题", e);
    e.printStackTrace();
  }catch(IOException e){
    log.error("发生网络异常", e);
    e.printStackTrace();
  }finally{
    if(getMethod != null){
    getMethod.releaseConnection();
    getMethod = null;
  }
  }

  return response;
  }

/**
* 据Map生成URL字符串
* @param map
* Map
* @param valueEnc
* URL编码
* @return
* URL
*/
private static String getUrl(Map<String, String> map, String valueEnc) {

  if (null == map || map.keySet().size() == 0) {
    return (EMPTY);
  }
  StringBuffer url = new StringBuffer();
  Set<String> keys = map.keySet();
  for (Iterator<String> it = keys.iterator(); it.hasNext();) {
      String key = it.next();
      if (map.containsKey(key)) {
        String val = map.get(key);
        String str = val != null ? val : EMPTY;
      try {
        str = URLEncoder.encode(str, valueEnc);
      } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
      }
      url.append(key).append("=").append(str).append(URL_PARAM_CONNECT_FLAG);
    }
  }
  String strURL = EMPTY;
  strURL = url.toString();
  if (URL_PARAM_CONNECT_FLAG.equals(EMPTY + strURL.charAt(strURL.length() - 1))) {
    strURL = strURL.substring(0, strURL.length() - 1);
  }

  return (strURL);
  }


public static void main(String[] args) {

  String url = "http://192.168.1.7:9909/";//项目路径
  String charset = "utf-8"; //编码格式
  String httpOrgCreateTest = url + "send"; //全路径
  Map<String,String> createMap = new HashMap<String,String>(); //参数   键值对

  //如
  createMap.put("shebeihao","01111");
  createMap.put("startTime","2017-12-14 14:25:00");
  createMap.put("endTime","2017-12-15 14:25:00");

  //GET方式调用
  String urlGet = URLGet(httpOrgCreateTest, createMap, charset);
  System.out.println("xxx"+urlGet);
}

/*

  Maven 导入架包

  <dependency>
    <groupId>commons-httpclient</groupId>
    <artifactId>commons-httpclient</artifactId>
    <version>3.1</version>
  </dependency>

*/


}

java的HTTP工具类

原文:http://www.cnblogs.com/niannianbuwang/p/8042646.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!