java http token请求代码实例_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;

									    }

									}