java http token请求代码实例
程序员文章站
2024-02-24 15:44:22
本文实例为大家分享了java http token的具体代码，供大家参考，具体内容如下
package com.monitoring.common.util;...
本文实例为大家分享了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;
}
}
以上所述是小编给大家介绍的java http token请求详解整合，希望对大家有所帮助