|
|
|
package com.xkl;
|
|
|
|
|
|
|
|
import java.io.BufferedReader;
|
|
|
|
import java.io.DataOutputStream;
|
|
|
|
import java.io.IOException;
|
|
|
|
import java.io.InputStreamReader;
|
|
|
|
import java.net.HttpURLConnection;
|
|
|
|
import java.net.URL;
|
|
|
|
import java.net.URLEncoder;
|
|
|
|
import java.util.*;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Created by win7 on 2016/12/25.
|
|
|
|
*/
|
|
|
|
public class HttpTools {
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 获取当前时间，10位
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public static String getNow(){
|
|
|
|
Calendar c = Calendar.getInstance();//可以对每个时间域单独修改
|
|
|
|
return String.valueOf(c.getTimeInMillis()/1000);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 获取签名
|
|
|
|
*
|
|
|
|
* 加密算法: sign=md5(str + t + key)，32位小写md5
|
|
|
|
* t: 北京时间距离1970年1月1日的秒数，10位
|
|
|
|
* key：平台对应的key，此值喜开路管理员授予
|
|
|
|
* str：业务参数数组，按参数名递增排序排列拼接，例如用户登陆接口，coid+password+username
|
|
|
|
*
|
|
|
|
* 需要验证：
|
|
|
|
* sign：是否正确
|
|
|
|
* t：是否过期，客户端与服务器时间必须为±300s以内，否则时间验证过期。
|
|
|
|
* @param params
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public static String getSign(Map<String, String> params){
|
|
|
|
String sign = "";
|
|
|
|
String paramStr = "";
|
|
|
|
List<String> keys = new ArrayList<String>();
|
|
|
|
for(Map.Entry<String, String> entry : params.entrySet()) {
|
|
|
|
keys.add(entry.getKey());
|
|
|
|
}
|
|
|
|
Collections.sort(keys);
|
|
|
|
for(String para:keys){
|
|
|
|
if(!para.equals("sign")&&!para.equals("t")&&!para.equals("type"))
|
|
|
|
paramStr += params.get(para);
|
|
|
|
}
|
|
|
|
sign = EncodeTools.encode("MD5",paramStr + params.get("t") + Constants.KEY);
|
|
|
|
|
|
|
|
return sign;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 发送http请求
|
|
|
|
* @param url 请求url
|
|
|
|
* @param type 请求类型：GET,POST,DELETE
|
|
|
|
* @param params 请求参数：map类型
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public static String requestByMapWithToken(String url, String type, Map<String, String> params, String authorization){
|
|
|
|
String reqbody = getRequestData(params,"UTF-8").toString();
|
|
|
|
String result = requestByString(url + "?" + reqbody,type,authorization,null);
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
|
|
|
public static String requestByMap(String url, String type,Map<String, String> params){
|
|
|
|
return requestByMapWithToken(url,type,params,"");
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 发送http请求
|
|
|
|
* @param url 请求url
|
|
|
|
* @param type 请求类型：GET,POST,DELETE
|
|
|
|
* @param reqbody 请求参数：String类型
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public static String requestByString(String url, String type, String authorization,String reqbody){
|
|
|
|
HttpURLConnection con = null;
|
|
|
|
String result = null;
|
|
|
|
try {
|
|
|
|
con = getHttpConnection( url , type, authorization);
|
|
|
|
//you can add any request body here if you want to post
|
|
|
|
if( reqbody != null){
|
|
|
|
DataOutputStream out = new DataOutputStream(con.getOutputStream());
|
|
|
|
out.writeBytes(reqbody);
|
|
|
|
out.flush();
|
|
|
|
out.close();
|
|
|
|
}
|
|
|
|
con.connect();
|
|
|
|
BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
|
|
|
|
String temp = null;
|
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
|
while((temp = in.readLine()) != null){
|
|
|
|
sb.append(temp).append(" ");
|
|
|
|
}
|
|
|
|
result = sb.toString();
|
|
|
|
in.close();
|
|
|
|
} catch (IOException e) {
|
|
|
|
System.out.println(e);
|
|
|
|
}
|
|
|
|
return result;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
private static HttpURLConnection getHttpConnection(String url, String type, String authorization){
|
|
|
|
URL uri = null;
|
|
|
|
HttpURLConnection con = null;
|
|
|
|
try{
|
|
|
|
uri = new URL(url);
|
|
|
|
con = (HttpURLConnection) uri.openConnection();
|
|
|
|
con.setRequestMethod(type); //type: POST, PUT, DELETE, GET
|
|
|
|
if(type.equals("POST"))
|
|
|
|
con.setDoOutput(true);
|
|
|
|
con.setConnectTimeout(60000); //60 secs
|
|
|
|
con.setReadTimeout(60000); //60 secs
|
|
|
|
con.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
|
|
|
con.setRequestProperty("authorization",authorization);
|
|
|
|
}catch(Exception e){
|
|
|
|
System.out.println( "connection i/o failed" );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return con;
|
|
|
|
}
|
|
|
|
|
|
|
|
private static StringBuffer getRequestData(Map<String, String> params, String encode) {
|
|
|
|
StringBuffer stringBuffer = new StringBuffer(); //存储封装好的请求体信息
|
|
|
|
try {
|
|
|
|
for(Map.Entry<String, String> entry : params.entrySet()) {
|
|
|
|
stringBuffer.append(entry.getKey())
|
|
|
|
.append("=")
|
|
|
|
.append(URLEncoder.encode(entry.getValue(), encode))
|
|
|
|
.append("&");
|
|
|
|
}
|
|
|
|
stringBuffer.deleteCharAt(stringBuffer.length() - 1); //删除最后的一个"&"
|
|
|
|
} catch (Exception e) {
|
|
|
|
e.printStackTrace();
|
|
|
|
}
|
|
|
|
return stringBuffer;
|
|
|
|
}
|
|
|
|
|
|
|
|
} |
...
|
...
|
|
