[Java] java http token请求代码实例

package com.monitoring.common.util;
 
import java.io.bufferedinputstream;
import java.io.bufferedreader;
import java.io.bytearrayoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.io.inputstreamreader;
import java.io.outputstream;
import java.net.httpurlconnection;
import java.net.url;
import java.net.urlencoder;
import java.util.hashmap;
import java.util.iterator;
import java.util.list;
import java.util.map;
import java.util.set;
import java.util.regex.matcher;
import java.util.regex.pattern;
 
import org.apache.commons.httpclient.httpclient;
import org.apache.commons.httpclient.multithreadedhttpconnectionmanager;
import org.apache.commons.httpclient.namevaluepair;
import org.apache.commons.httpclient.methods.getmethod;
import org.apache.commons.httpclient.methods.postmethod;
import org.apache.commons.lang.stringutils;
import org.apache.log4j.logger;
import org.codehaus.jackson.jsonparseexception;
import org.codehaus.jackson.map.jsonmappingexception;
 
/**
 * 和http相关的操作
 * 
 * @author
 * 
 */
public class httputils {
 
  private static final logger logger = logger.getlogger(httputils.class);
  private final static multithreadedhttpconnectionmanager manager = new multithreadedhttpconnectionmanager();
  // 支持重复连接
  private static httpclient client = new httpclient(manager);
 
  /**
   * 
   * @title: dopost
   * @description: post请求
   * @param requrl
   * @param parameters
   * @return string
   */
  public static string dopost(string requrl, map<string, string> parameters, string token) {
    httpurlconnection urlconn = null;
    try {
      urlconn = _sendpost(requrl, parameters, token);
      string responsecontent = _getcontent(urlconn);
      return responsecontent.trim();
    } finally {
      if (urlconn != null) {
        urlconn.disconnect();
      }
    }
  }
 
  /**
   * 
   * @title: douploadfile
   * @description: 从网络上下载文件
   * @param requrl
   * @param parameters
   * @param fileparamname
   * @param filename
   * @param contenttype
   * @param data
   * @return string
   */
  public static string douploadfile(string requrl, map<string, string> parameters, string fileparamname,
      string filename, string contenttype, byte[] data) {
    httpurlconnection urlconn = null;
    try {
      urlconn = _sendformdata(requrl, parameters, fileparamname, filename, contenttype, data);
      string responsecontent = new string(_getbytes(urlconn));
      return responsecontent.trim();
    } catch (exception e) {
      throw new runtimeexception(e.getmessage(), e);
    } finally {
      if (urlconn != null) {
        urlconn.disconnect();
      }
    }
  }
 
  private static httpurlconnection _sendformdata(string requrl, map<string, string> parameters, string fileparamname,
      string filename, string contenttype, byte[] data) {
    httpurlconnection urlconn = null;
    try {
      url url = new url(requrl);
      urlconn = (httpurlconnection) url.openconnection();
      urlconn.setrequestmethod("post");
      urlconn.setconnecttimeout(5000);// （单位：毫秒）jdk
      urlconn.setreadtimeout(5000);// （单位：毫秒）jdk 1.5换成这个,读操作超时
      urlconn.setdooutput(true);
 
      urlconn.setrequestproperty("connection", "keep-alive");
 
      string boundary = "-----------------------------114975832116442893661388290519"; // 分隔符
      urlconn.setrequestproperty("content-type", "multipart/form-data; boundary=" + boundary);
 
      boundary = "--" + boundary;
      stringbuffer params = new stringbuffer();
      if (parameters != null) {
        for (iterator<string> iter = parameters.keyset().iterator(); iter.hasnext();) {
          string name = iter.next();
          string value = parameters.get(name);
          params.append(boundary + "\r\n");
          params.append("content-disposition: form-data; name="" + name + ""\r\n\r\n");
          // params.append(urlencoder.encode(value, "utf-8"));
          params.append(value);
          params.append("\r\n");
        }
      }
 
      stringbuilder sb = new stringbuilder();
      // sb.append("\r\n");
      sb.append(boundary);
      sb.append("\r\n");
      sb.append("content-disposition: form-data; name="" + fileparamname + ""; filename="" + filename
          + ""\r\n");
      sb.append("content-type: " + contenttype + "\r\n\r\n");
      byte[] filediv = sb.tostring().getbytes();
      byte[] enddata = ("\r\n" + boundary + "--\r\n").getbytes();
      byte[] ps = params.tostring().getbytes();
 
      outputstream os = urlconn.getoutputstream();
      os.write(ps);
      os.write(filediv);
      os.write(data);
      os.write(enddata);
 
      os.flush();
      os.close();
    } catch (exception e) {
      throw new runtimeexception(e.getmessage(), e);
    }
    return urlconn;
  }
 
  private static string _getcontent(httpurlconnection urlconn) {
    try {
      string responsecontent = null;
      inputstream in = urlconn.getinputstream();
      bufferedreader rd = new bufferedreader(new inputstreamreader(in, "utf-8"));
      string templine = rd.readline();
      stringbuffer tempstr = new stringbuffer();
      string crlf = system.getproperty("line.separator");
      while (templine != null) {
        tempstr.append(templine);
        tempstr.append(crlf);
        templine = rd.readline();
      }
      responsecontent = tempstr.tostring();
      rd.close();
      in.close();
      return responsecontent;
    } catch (exception e) {
      throw new runtimeexception(e.getmessage(), e);
    }
  }
 
  private static byte[] _getbytes(httpurlconnection urlconn) {
    try {
      inputstream in = urlconn.getinputstream();
      bytearrayoutputstream os = new bytearrayoutputstream();
      byte[] buf = new byte[1024];
      for (int i = 0; (i = in.read(buf)) > 0;)
        os.write(buf, 0, i);
      in.close();
      return os.tobytearray();
    } catch (exception e) {
      throw new runtimeexception(e.getmessage(), e);
    }
  }
 
  private static httpurlconnection _sendpost(string requrl, map<string, string> parameters, string token) {
    httpurlconnection urlconn = null;
    try {
      stringbuffer params = new stringbuffer();
      if (parameters != null) {
        for (iterator<string> iter = parameters.keyset().iterator(); iter.hasnext();) {
          string name = iter.next();
          string value = parameters.get(name);
          params.append(name + "=");
          params.append(urlencoder.encode(value, "utf-8"));
          if (iter.hasnext())
            params.append("&");
        }
      }
 
      url url = new url(requrl);
      urlconn = (httpurlconnection) url.openconnection();
      
      if(stringutils.isnotblank(token)) {
        urlconn.addrequestproperty("token", token);
      }
      
      urlconn.setrequestmethod("post");
      urlconn.setconnecttimeout(5000);// （单位：毫秒）jdk
      urlconn.setreadtimeout(5000);// （单位：毫秒）jdk 1.5换成这个,读操作超时
      urlconn.setdooutput(true);
      byte[] b = params.tostring().getbytes();
      urlconn.getoutputstream().write(b, 0, b.length);
      urlconn.getoutputstream().flush();
      urlconn.getoutputstream().close();
    } catch (exception e) {
      throw new runtimeexception(e.getmessage(), e);
    }
    return urlconn;
  }
 
  /**
   * 发送get请求
   * 
   * @param link
   * @param charset
   * @return
   */
  public static string doget(string link, string charset, string token) {
    httpurlconnection conn = null;
    try {
      url url = new url(link);
      conn = (httpurlconnection) url.openconnection();
      
      
      conn.setrequestmethod("get");
      
      conn.setrequestproperty("user-agent", "mozilla/5.0");
      
      if(stringutils.isnotempty(token)) {
        conn.addrequestproperty("token", token);
      }
      
      bufferedinputstream in = new bufferedinputstream(conn.getinputstream());
      bytearrayoutputstream out = new bytearrayoutputstream();
      byte[] buf = new byte[1024];
      for (int i = 0; (i = in.read(buf)) > 0;) {
        out.write(buf, 0, i);
      }
      out.flush();
      out.close();
      string s = new string(out.tobytearray(), charset);
      return s;
    } catch (exception e) {
      throw new runtimeexception(e.getmessage(), e);
    } finally {
      if (conn != null) {
        conn.disconnect();
      }
    }
  }
 
  /**
   * utf-8编码
   * 
   * @param link
   * @return
   */
  public static string doget(string link, string token) {
    return doget(link, "utf-8", token);
  }
 
  /**
   * 
   * @title: getintresponse
   * @description: 发送get请求
   * @param link
   * @return int
   */
  public static int getintresponse(string link, string token) {
    string str = doget(link, token);
    return integer.parseint(str.trim());
  }
 
  public static long ip2long(string strip) {
    long[] ip = new long[4];
    // 先找到ip地址字符串中.的位置
    int position1 = strip.indexof(".");
    int position2 = strip.indexof(".", position1 + 1);
    int position3 = strip.indexof(".", position2 + 1);
    // 将每个.之间的字符串转换成整型
    ip[0] = long.parselong(strip.substring(0, position1));
    ip[1] = long.parselong(strip.substring(position1 + 1, position2));
    ip[2] = long.parselong(strip.substring(position2 + 1, position3));
    ip[3] = long.parselong(strip.substring(position3 + 1));
    return (ip[0] << 24) + (ip[1] << 16) + (ip[2] << 8) + ip[3];
  }
 
  // 将10进制整数形式转换成127.0.0.1形式的ip地址
  public static string long2ip(long longip) {
    stringbuffer sb = new stringbuffer("");
    // 直接右移24位
    sb.append(string.valueof(longip >>> 24));
    sb.append(".");
    // 将高8位置0，然后右移16位
    sb.append(string.valueof((longip & 0x00ffffff) >>> 16));
    sb.append(".");
    sb.append(string.valueof((longip & 0x0000ffff) >>> 8));
    sb.append(".");
    sb.append(string.valueof(longip & 0x000000ff));
    return sb.tostring();
  }
 
  /**
   * 
   * urlparse:url解析. <br/>
   * 
   * @author majun
   * @param arrlist
   * @param url
   * @return
   * @since jdk 1.6
   */
  public static map<string, string> urlparse(list<string> arrlist, string url) {
 
    map<string, string> vaulesmap = new hashmap<string, string>();
    for (string s : arrlist) {
      pattern pattern = pattern.compile(s + "=([^&]*)(&|$)");
      matcher matcher = pattern.matcher(url);
      if (matcher.find()) {
        string[] arr = matcher.group(1).split("'");
        vaulesmap.put(s, arr[1]);
      }
    }
    return vaulesmap;
 
  }
 
  /***
   * 
   * http_dopost: httpclient发送post 请求. <br/>
   *
   * @author majun
   * @version 创建时间：2016年6月22日 下午6:15:59
   * @since jdk 1.6
   */
  public static string http_dopost(string requrl, map<string, string> parameters, string usertoken) {
 
    try {
 
      // multithreadedhttpconnectionmanager manager = new multithreadedhttpconnectionmanager();
      // 支持重复连接
      // httpclient client = new httpclient(manager);
 
      postmethod post = new postmethod(requrl);
      post.setrequestheader("connection", "keep-alive");
      post.setrequestheader("content-type", "application/x-www-form-urlencoded");
 
      namevaluepair[] params = new namevaluepair[parameters.size()];
      set<string> keys = parameters.keyset();
      int index = 0;
      for (string key : keys) {
 
        params[index] = new namevaluepair(key, parameters.get(key));
        index++;
      }
 
      post.setquerystring(params);
 
      if (stringutils.isnotblank(usertoken)) {
        post.setrequestheader("usertoken", usertoken);
      }
 
      integer status = client.executemethod(post);
      logger.info("loginstatus:" + status);
 
      string body = post.getresponsebodyasstring();
 
      return body;
 
    } catch (jsonparseexception e) {
      e.printstacktrace();
    } catch (jsonmappingexception e) {
      e.printstacktrace();
    } catch (ioexception e) {
      e.printstacktrace();
    }
    return null;
  }
 
  /***
   * 
   * http_doget: httpclient发送get请求. <br/>
   *
   * @author majun
   * @version 创建时间：2016年6月22日 下午6:25:10
   * @since jdk 1.6
   */
  public static string http_doget(string requrl, map<string, string> parameters, string usertoken) {
 
    try {
 
      // multithreadedhttpconnectionmanager manager = new multithreadedhttpconnectionmanager();
      // 支持重复连接
      // httpclient client = new httpclient(manager);
      getmethod get = new getmethod(requrl);
 
      namevaluepair[] params = new namevaluepair[parameters.size()];
      set<string> keys = parameters.keyset();
      int index = 0;
      for (string key : keys) {
 
        params[index] = new namevaluepair(key, parameters.get(key));
        index++;
      }
 
      get.setquerystring(params);
 
      if (stringutils.isnotblank(usertoken)) {
        get.setrequestheader("usertoken", usertoken);
      }
 
      integer status = client.executemethod(get);
      logger.info("http_doget==>status:" + status);
      string body = get.getresponsebodyasstring();
      return body;
 
    } catch (exception e) {
      e.printstacktrace();
    }
 
    return null;
  }
}