package org.fanli.facade.system.util.taobao;
|
|
import java.io.BufferedReader;
|
import java.io.File;
|
import java.io.FileNotFoundException;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.httpclient.HttpClient;
|
import org.apache.commons.httpclient.HttpException;
|
import org.apache.commons.httpclient.NameValuePair;
|
import org.apache.commons.httpclient.methods.GetMethod;
|
import org.apache.commons.httpclient.methods.PostMethod;
|
import org.apache.commons.httpclient.methods.multipart.FilePart;
|
import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;
|
import org.apache.commons.httpclient.methods.multipart.Part;
|
import org.apache.commons.httpclient.methods.multipart.StringPart;
|
import org.apache.commons.httpclient.params.HttpConnectionManagerParams;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.impl.client.DefaultHttpClient;
|
import org.apache.http.message.BasicNameValuePair;
|
import org.apache.http.util.EntityUtils;
|
|
import com.yeshi.fanli.entity.address.Address;
|
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
|
|
import net.sf.json.JSONArray;
|
|
public class TaoBaoHttpUtil {
|
|
public static String getShortLink(String url) {
|
String totalUrl = String.format("http://api.t.sina.com.cn/short_url/shorten.json?source=3271760578&url_long=%s",
|
URLEncoder.encode(url));
|
String result = get(totalUrl);
|
JSONArray rtesultArray = JSONArray.fromObject(result);
|
if (rtesultArray.size() > 0) {
|
return rtesultArray.optJSONObject(0).optString("url_short");
|
}
|
return null;
|
}
|
|
public static String proxyGet(String url, String cookie) {
|
HttpClient client = new HttpClient();
|
// Address address = ProxyUtil.getAddressProxy();
|
// if(address != null){
|
// client.getHostConfiguration().setProxy(address.getIp(),
|
// address.getPort());
|
// }
|
try {
|
GetMethod method = new GetMethod(url);
|
if (cookie != null) {
|
method.addRequestHeader("cookie", cookie);
|
}
|
client.executeMethod(method);
|
return method.getResponseBodyAsString();
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String proxyGet(String url, Map<String, String> headers) {
|
HttpClient client = new HttpClient();
|
// Address address = ProxyUtil.getAddressProxy();
|
// if(address != null){
|
// client.getHostConfiguration().setProxy(address.getIp(),
|
// address.getPort());
|
// }
|
try {
|
GetMethod method = new GetMethod(url);
|
if (headers != null) {
|
Iterator<String> keys = headers.keySet().iterator();
|
while (keys.hasNext()) {
|
String key = keys.next();
|
method.addRequestHeader(key, headers.get(key));
|
}
|
}
|
client.executeMethod(method);
|
return method.getResponseBodyAsString();
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String get(String url) {
|
return get(url, true);
|
}
|
|
public static String get(String url, boolean isProxy) {
|
HttpClient client = new HttpClient();
|
GetMethod method = new GetMethod(url);
|
if (isProxy) {
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
}
|
try {
|
client.executeMethod(method);
|
return convertInputStreamToString(method.getResponseBodyAsStream());
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String getAsString(String url, boolean isProxy) {
|
HttpClient client = new HttpClient();
|
GetMethod method = new GetMethod(url);
|
if (isProxy) {
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
}
|
try {
|
client.executeMethod(method);
|
String response = method.getResponseBodyAsString();
|
String s1 = new String(response.getBytes("ISO-8859-1"), "UTF-8");
|
return s1;
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String tbGet(String url, Map<String, String> params, String tbAccount) {
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
// if(address != null){
|
// client.getHostConfiguration().setProxy(address.getIp(),
|
// address.getPort());
|
// }
|
Iterator<String> keys = params.keySet().iterator();
|
url += "?";
|
while (keys.hasNext()) {
|
String key = keys.next();
|
try {
|
url += String.format("%s=%s&", key, URLEncoder.encode(params.get(key), "UTF-8"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
GetMethod method = new GetMethod(url);
|
try {
|
method.setRequestHeader("User-Agent",
|
"Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/61.0.3163.100 Safari/537.36");
|
method.setRequestHeader("Upgrade-Insecure-Requests", "1");
|
method.setRequestHeader("Accept",
|
"text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8");
|
method.setRequestHeader("Accept-Language", "zh-CN,zh;q=0.8");
|
method.setRequestHeader("Cache-Control", "max-age=0");
|
String taoBaoCookie = TaoBaoOrderUtil.getTaoBaoCookie(tbAccount);
|
method.setRequestHeader("cookie", taoBaoCookie);
|
// HttpConnectionManagerParams params2 = new
|
// HttpConnectionManagerParams();
|
// params2.setConnectionTimeout(3500);
|
// client.getHttpConnectionManager().setParams(params2);
|
client.executeMethod(method);
|
// InputStream inputStream = method.getResponseBodyAsStream();
|
// String result = convertInputStreamToString(inputStream);
|
return method.getResponseBodyAsString();// convertInputStreamToString(method.getResponseBodyAsStream());
|
} catch (Exception e) {
|
try {
|
address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
client.executeMethod(method);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
return "";
|
}
|
|
public static String get(String url, Map<String, String> params, boolean proxy) {
|
HttpClient client = new HttpClient();
|
// client.getHostConfiguration().setProxy("192.168.1.122", 8888);
|
try {
|
Iterator<String> keys = params.keySet().iterator();
|
url += "?";
|
while (keys.hasNext()) {
|
String key = keys.next();
|
url += String.format("%s=%s&", key, URLEncoder.encode(params.get(key), "UTF-8"));
|
}
|
|
// System.out.println("url"+url);
|
GetMethod method = new GetMethod(url);
|
// 3S的响应超时
|
HttpConnectionManagerParams hparams = new HttpConnectionManagerParams();
|
hparams.setConnectionTimeout(3000);
|
client.getHttpConnectionManager().setParams(hparams);
|
|
/*
|
* if(proxy){ Address address = ProxyUtil.getAddressProxy();
|
* if(address != null){ HttpConnectionManagerParams hparams = new
|
* HttpConnectionManagerParams();
|
* hparams.setConnectionTimeout(3500);
|
* client.getHttpConnectionManager().setParams(hparams);
|
* client.getHostConfiguration().setProxy(address.getIp(),address.
|
* getPort()); } }
|
*/
|
// client.getHostConfiguration().setProxy("192.168.1.122",8888);
|
client.executeMethod(method);
|
String result = method.getResponseBodyAsString();
|
return result;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String get(String url, Map<String, String> params, Map<String, String> headers, boolean proxy) {
|
HttpClient client = new HttpClient();
|
try {
|
Iterator<String> keys = params.keySet().iterator();
|
url += "?";
|
while (keys.hasNext()) {
|
String key = keys.next();
|
url += String.format("%s=%s&", key, URLEncoder.encode(params.get(key), "UTF-8"));
|
}
|
|
System.out.println(url);
|
|
GetMethod method = new GetMethod(url);
|
if (headers != null) {
|
keys = headers.keySet().iterator();
|
while (keys.hasNext()) {
|
String key = keys.next();
|
headers.get(key);
|
method.setRequestHeader(key, headers.get(key));
|
}
|
}
|
|
/*
|
* if(proxy){ Address address = ProxyUtil.getAddressProxy();
|
* if(address != null){ HttpConnectionManagerParams hparams = new
|
* HttpConnectionManagerParams();
|
* hparams.setConnectionTimeout(3500);
|
* client.getHttpConnectionManager().setParams(hparams);
|
* client.getHostConfiguration().setProxy(address.getIp(),address.
|
* getPort()); } }
|
*/
|
// client.getHostConfiguration().setProxy("120.92.118.64", 10000);
|
|
client.executeMethod(method);
|
String result = method.getResponseBodyAsString();
|
return result;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String taoKeGet(Map<String, String> params) {
|
// 聚石塔服务器环境 118.178.179.189
|
|
// result = get("http://118.178.179.189/taoke/", params, false);
|
// if (StringUtil.isNullOrEmpty(result))
|
//https://eco.taobao.com/router/rest
|
//http://gw.api.taobao.com/router/rest
|
String result = get("https://eco.taobao.com/router/rest", params, false);
|
return result;
|
}
|
|
public static String get(String url, Map<String, String> params) {
|
// TODO 淘宝的所有请求需要走聚石塔
|
// http://118.178.179.189/taoke/
|
return get(url, params, false);
|
}
|
|
public static String get(String url, String charset) {
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
GetMethod method = new GetMethod(url);
|
try {
|
client.executeMethod(method);
|
BufferedReader reader = new BufferedReader(
|
new InputStreamReader(method.getResponseBodyAsStream(), "ISO-8859-1"));
|
String tmp = null;
|
String htmlRet = "";
|
while ((tmp = reader.readLine()) != null) {
|
htmlRet += tmp + "\r\n";
|
}
|
return new String(htmlRet.getBytes(charset), "UTF-8");
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
|
}
|
|
public static InputStream getAsInputStream(String url) {
|
HttpClient client = new HttpClient();
|
GetMethod method = new GetMethod(url);
|
try {
|
client.executeMethod(method);
|
return method.getResponseBodyAsStream();
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
public static InputStream getImage(String url) {
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
GetMethod method = new GetMethod(url);
|
try {
|
method.setRequestHeader("Content-Type", "image/jpeg");
|
client.executeMethod(method);
|
return method.getResponseBodyAsStream();
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
public static String post(String url) {
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
PostMethod method = new PostMethod(url);
|
method.addRequestHeader("Content-Type", "text/html;charset=UTF-8");
|
method.setRequestHeader("Content-Type", "text/html;charset=UTF-8");
|
try {
|
client.executeMethod(method);
|
return convertInputStreamToString(method.getResponseBodyAsStream());
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String post(String url, Map<String, String> map) {
|
Iterator<String> its = map.keySet().iterator();
|
NameValuePair[] params = new NameValuePair[map.keySet().size()];
|
int p = 0;
|
while (its.hasNext()) {
|
String key = its.next();
|
NameValuePair np = new NameValuePair(key, map.get(key));
|
params[p] = np;
|
p++;
|
}
|
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
PostMethod method = new PostMethod(url);
|
method.addRequestHeader("Content-Type", "text/html;charset=UTF-8");
|
method.setRequestHeader("Content-Type", "text/html;charset=UTF-8");
|
method.setRequestBody(params);
|
try {
|
client.executeMethod(method);
|
return convertInputStreamToString(method.getResponseBodyAsStream());
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String post(String url, Map<String, String> map, Map<String, String> headers) {
|
org.apache.http.client.HttpClient client = new DefaultHttpClient();
|
|
HttpPost httpRequst = new HttpPost(url);// 创建HttpPost对象
|
List<org.apache.http.NameValuePair> params = new ArrayList<org.apache.http.NameValuePair>();
|
Iterator<String> its = map.keySet().iterator();
|
while (its.hasNext()) {
|
String key = its.next();
|
params.add(new BasicNameValuePair(key, map.get(key)));
|
}
|
try {
|
HttpEntity entity = new UrlEncodedFormEntity(params, "UTF-8");
|
httpRequst.setEntity(entity);
|
HttpResponse httpResponse = client.execute(httpRequst);
|
if (httpResponse.getStatusLine().getStatusCode() == 200) {
|
HttpEntity httpEntity = httpResponse.getEntity();
|
String result = EntityUtils.toString(httpEntity, "UTF-8");// 取出应答字符�?
|
return result;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
return "";
|
|
// Iterator<String> its = map.keySet().iterator();
|
}
|
|
private static String convertInputStreamToString(InputStream inputStream) {
|
BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));
|
StringBuffer stringBuffer = new StringBuffer();
|
String str = "";
|
try {
|
while ((str = br.readLine()) != null) {
|
stringBuffer.append(str);
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return stringBuffer.toString();
|
}
|
|
@SuppressWarnings("deprecation")
|
public static String post(String url, String entity) {
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
PostMethod method = new PostMethod(url);
|
method.addRequestHeader("Content-Type", "text/html;charset=UTF-8");
|
method.setRequestHeader("Content-Type", "text/html;charset=UTF-8");
|
method.setRequestBody(entity);
|
try {
|
client.executeMethod(method);
|
return convertInputStreamToString(method.getResponseBodyAsStream());
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
public static String postInputStream(String url, File file) throws FileNotFoundException {
|
HttpClient client = new HttpClient();
|
Address address = ProxyUtil.getAddressProxy();
|
if (address != null) {
|
client.getHostConfiguration().setProxy(address.getIp(), address.getPort());
|
}
|
PostMethod postMethod = new PostMethod(url);
|
/*
|
* postMethod.addRequestHeader("Content-Type",
|
* "text/html;charset=UTF-8");
|
* postMethod.setRequestHeader("Content-Type",
|
* "text/html;charset=UTF-8");
|
*/
|
Part[] parts = { new StringPart("filename", file.getName()), new StringPart("filelength", file.length() + ""),
|
new StringPart("content-type", "image/jpg"), new FilePart("file", file) };
|
postMethod.setRequestEntity(new MultipartRequestEntity(parts, postMethod.getParams()));
|
|
try {
|
client.executeMethod(postMethod);
|
return convertInputStreamToString(postMethod.getResponseBodyAsStream());
|
} catch (HttpException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
}
|
