java http token请求代码实例
本文实例为大家分享了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请求详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对我们网站的支持!
赞 (0)