java http token请求代码实例

package com.monitoring测试数据mon.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测试数据mons.httpclient.httpclient;

import org.apache测试数据mons.httpclient.multithreadedhttpconnectionmanager;

import org.apache测试数据mons.httpclient.namevaluepair;

import org.apache测试数据mons.httpclient.methods.getmethod;

import org.apache测试数据mons.httpclient.methods.postmethod;

import org.apache测试数据mons.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测试数据pile(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 ;

     }

}