java http token请求代码实例
作者:指尖飘落的程序 发布时间:2022-09-28 18:23:19
标签: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请求详解整合网站的支持!
来源:https://blog.csdn.net/qq_33212500/article/details/79229897
0
投稿
猜你喜欢
- 一、通过程序看现象在开始为大家讲解Java 多线程缓存模型之前,我们先看下面的这一段代码。这段代码的逻辑很简单:主线程启动了两个子线程,一个
- 为什么使用logback记得前几年工作的时候,公司使用的日志框架还是log4j,大约从16年中到现在,不管是我参与的别人已经搭建好的项目还是
- 本篇分享的是springboot多数据源配置,在从springboot v1.5版本升级到v2.0.3时,发现之前写的多数据源的方式不可用了
- 本文实例讲述了Java对象数组定义与用法。分享给大家供大家参考,具体如下:所谓的对象数组,就是指包含了一组相关的对象,但是在对象数组的使用中
- 在Java编程中,使用private关键字修饰了某个成员,只有这个成员所在的类和这个类的方法可以使用,其他的类都无法访问到这个private
- 背景在一些业务场景, 往往需要自定义异常来满足特定的业务, 主流用法是在catch里抛出异常, 例如:public void deal()
- 目录获取程序下面的文件获取临时目录下的文件获取程序下面的文件首先我们创建了实例解决方案:其中调用链是:Main.Shell->FooA
- 一、创建springboot项目(采用骨架方式)创建完成;我们分析下pom文件中内容:所使用到的关键依赖: <!--springBoo
- 1. 线程的5种状态从操作系统层面上,任何线程一般都具有五种状态,即创建、就绪、运行、阻塞、终止。(1) 新建状态(NEW)在程序中用构造方
- 我们做项目实际中经常会遇到这样的情况,创建一个common项目(Maven项目)作为公用项目,common中有很多工具类可以供其它多个项目调
- 作为开发人员,掌握开发环境下的调试技巧十分有必要。我们在编写java程序的过程中,经常会遇到各种莫名其妙的问题,为了检测程序是哪里出现问题,
- 我们在C#编程中常见的信息提示框(MessageBox)是微软NET自带的一个用于弹出警告、错误或者讯息一类的“模式”对话框。此类对话框一旦
- 我们知道多线程因为同时处理子线程的能力,对于程序运行来说,能够达到很高的效率。不过很多人对于多线程的执行方法还没有尝试过,本篇我们将为大家介
- java 遍历listpackage com.tiandy.core.rest;import java.util.ArrayList;imp
- 1.拉取centos镜像docker pull centos:72.基于拉取到的镜像运行一个容器docker run -it --name
- 同步代码块基本语句synchronized (任意对象) {操作共享代码}代码示例public class SellTicket imple
- zenDiscovery实现机制ping是集群发现的基本手段,通过在网络上广播或者指定ping某些节点获取集群信息,从而可以找到
- 本文实例讲述了Android编程之手机壁纸WallPaper设置方法。分享给大家供大家参考,具体如下:/** * Andorid设置手机屏幕
- 一、XSSFpackage com.yy.demo01;import java.io.FileInputStream;import java
- Java中IO的模型分为三种,同步阻塞的BIO、同步非阻塞的NIO、异步非阻塞的AIO。BIO【同步阻塞】在JDK1.4出来之前,我们建立网