java http token请求

太过爱你忘了你带给我的痛 2022-05-31 00:40 204阅读 0赞

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;
    	}
    }