package com.mandi.common;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.IOException;
|
import java.nio.charset.Charset;
|
import java.security.KeyStore;
|
import java.security.cert.CertificateException;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Map.Entry;
|
|
import javax.net.ssl.SSLContext;
|
|
import org.apache.http.HttpEntity;
|
import org.apache.http.NameValuePair;
|
import org.apache.http.client.CookieStore;
|
import org.apache.http.client.config.CookieSpecs;
|
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.client.protocol.HttpClientContext;
|
import org.apache.http.config.Registry;
|
import org.apache.http.config.RegistryBuilder;
|
import org.apache.http.conn.ssl.NoopHostnameVerifier;
|
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
|
import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
|
import org.apache.http.conn.util.PublicSuffixMatcher;
|
import org.apache.http.conn.util.PublicSuffixMatcherLoader;
|
import org.apache.http.cookie.CookieSpecProvider;
|
import org.apache.http.entity.ContentType;
|
import org.apache.http.entity.StringEntity;
|
import org.apache.http.entity.mime.MultipartEntityBuilder;
|
import org.apache.http.entity.mime.content.FileBody;
|
import org.apache.http.entity.mime.content.StringBody;
|
import org.apache.http.impl.client.BasicCookieStore;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.impl.cookie.BasicClientCookie;
|
import org.apache.http.impl.cookie.DefaultCookieSpecProvider;
|
import org.apache.http.impl.cookie.RFC6265CookieSpecProvider;
|
import org.apache.http.message.BasicNameValuePair;
|
import org.apache.http.ssl.SSLContexts;
|
import org.apache.http.util.EntityUtils;
|
import org.apache.log4j.Logger;
|
import org.springframework.context.annotation.Scope;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* @author mengly
|
* @version 创建时间：2015年9月18日 下午7:53:25
|
* 类说明 :包依赖:httpclient,之所以采用singleton，是因为有hcontext
|
*/
|
@Service
|
@Scope("singleton")
|
public class Httpmethod {
|
private Logger log=Logger.getLogger(Httpmethod.class);
|
private HttpClientContext hcontext=null;
|
private CookieStore cookiestore=null;
|
public String keyfile="f:\\tomcat.keystore";
|
public String key="123456";
|
public CloseableHttpClient ssl() {
|
CloseableHttpClient httpclient = null;
|
try {
|
KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
|
FileInputStream instream = new FileInputStream(new File(keyfile));
|
try {
|
// 加载keyStore d:\\tomcat.keystore
|
trustStore.load(instream, key.toCharArray());
|
} catch (CertificateException e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
instream.close();
|
} catch (Exception ignore) {
|
}
|
}
|
// 相信自己的CA和所有自签名的证书
|
SSLContext sslcontext = SSLContexts.custom().loadTrustMaterial(trustStore, new TrustSelfSignedStrategy()).build();
|
// 只允许使用TLSv1协议
|
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[] { "TLSv1" }, null,
|
SSLConnectionSocketFactory.getDefaultHostnameVerifier());
|
httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
|
}catch(Exception ee){
|
ee.printStackTrace();
|
}
|
return httpclient;
|
}
|
/**
|
* new ssl();
|
* @return
|
* @author mengly
|
* @version 创建时间：2015年10月13日 上午11:21:15
|
*/
|
public CloseableHttpClient nssl() {
|
CloseableHttpClient httpclient = null;
|
try {
|
SSLContext sslcontext = SSLContexts.createDefault();
|
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, NoopHostnameVerifier.INSTANCE);
|
httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
|
}catch(Exception ee){
|
ee.printStackTrace();
|
}
|
return httpclient;
|
}
|
public String post(String url,Map<String, String> params)
|
{
|
CloseableHttpClient httpclient = HttpClients.createDefault();
|
HttpPost hp=new HttpPost(url);
|
String re=null;
|
List<NameValuePair> fps=new ArrayList<NameValuePair>();
|
UrlEncodedFormEntity entity=null;
|
if(params!=null)
|
{
|
for (Entry<String, String> en : params.entrySet()) {
|
fps.add(new BasicNameValuePair(en.getKey(), en.getValue()));
|
}
|
}
|
try {
|
entity=new UrlEncodedFormEntity(fps,"UTF-8");
|
hp.setEntity(entity);
|
CloseableHttpResponse cr=null;
|
if(hcontext!=null)
|
cr= httpclient.execute(hp, hcontext);
|
else
|
cr= httpclient.execute(hp);
|
try{
|
HttpEntity he=cr.getEntity();
|
if(he!=null)
|
re=EntityUtils.toString(he,"UTF-8");
|
}catch(Exception ee)
|
{}finally{
|
cr.close();
|
}
|
} catch (Exception e) {
|
log.info("error");
|
}finally{
|
try {
|
httpclient.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return re;
|
}
|
|
public String ssl_post(String url,Map<String, String> params)
|
{
|
CloseableHttpClient httpclient=nssl();
|
// CloseableHttpClient httpclient = HttpClients.createDefault();
|
HttpPost hp=new HttpPost(url);
|
String re=null;
|
List<NameValuePair> fps=new ArrayList<NameValuePair>();
|
UrlEncodedFormEntity entity=null;
|
if(params!=null)
|
{
|
for (Entry<String, String> en : params.entrySet()) {
|
fps.add(new BasicNameValuePair(en.getKey(), en.getValue()));
|
}
|
}
|
try {
|
entity=new UrlEncodedFormEntity(fps,"UTF-8");
|
hp.setEntity(entity);
|
CloseableHttpResponse cr=null;
|
if(hcontext==null)
|
cr=httpclient.execute(hp);
|
else
|
cr=httpclient.execute(hp, hcontext);
|
try{
|
HttpEntity he=cr.getEntity();
|
if(he!=null)
|
re=EntityUtils.toString(he,"UTF-8");
|
}catch(Exception ee)
|
{}finally{
|
cr.close();
|
}
|
} catch (Exception e) {
|
log.info("error");
|
}finally{
|
try {
|
httpclient.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return re;
|
}
|
|
public String ssl_postbody(String url,String body)
|
{
|
CloseableHttpClient httpclient=nssl();
|
HttpPost hp=new HttpPost(url);
|
StringEntity se=new StringEntity(body, Charset.forName("utf-8"));
|
hp.setEntity(se);
|
String re=null;
|
try {
|
CloseableHttpResponse cr=null;
|
if(hcontext==null)
|
cr=httpclient.execute(hp);
|
else
|
cr=httpclient.execute(hp, hcontext);
|
try{
|
HttpEntity he=cr.getEntity();
|
if(he!=null)
|
re=EntityUtils.toString(he,"UTF-8");
|
}catch(Exception ee)
|
{}finally{
|
cr.close();
|
}
|
} catch (Exception e) {
|
log.info("error");
|
}finally{
|
try {
|
httpclient.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return re;
|
}
|
|
|
public String get(String url)
|
{
|
CloseableHttpClient httpclient = HttpClients.createDefault();
|
HttpGet hp=new HttpGet(url);
|
String re=null;
|
try {
|
CloseableHttpResponse cr=null;
|
if(hcontext==null)
|
cr=httpclient.execute(hp);
|
else
|
cr=httpclient.execute(hp, hcontext);
|
try{
|
HttpEntity he=cr.getEntity();
|
if(he!=null)
|
re=EntityUtils.toString(he,"UTF-8");
|
}catch(Exception ee)
|
{}finally{
|
cr.close();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.info("error");
|
}finally{
|
try {
|
httpclient.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return re;
|
}
|
public String ssl_get(String url)
|
{
|
CloseableHttpClient httpclient =nssl();
|
HttpGet hp=new HttpGet(url);
|
String re=null;
|
try {
|
CloseableHttpResponse cr=null;
|
if(hcontext==null)
|
cr=httpclient.execute(hp);
|
else
|
cr=httpclient.execute(hp, hcontext);
|
try{
|
HttpEntity he=cr.getEntity();
|
if(he!=null)
|
re=EntityUtils.toString(he,"UTF-8");
|
}catch(Exception ee)
|
{}finally{
|
cr.close();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.info("error");
|
}finally{
|
try {
|
httpclient.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return re;
|
}
|
public String upload(String url,String file)
|
{
|
CloseableHttpClient httpclient = HttpClients.createDefault();
|
HttpPost hp=new HttpPost(url);
|
String re=null;
|
FileBody fb=new FileBody(new File(file));
|
StringBody comment=new StringBody("A binary file of some kind", ContentType.TEXT_PLAIN);
|
HttpEntity reqEntity = MultipartEntityBuilder.create().addPart("bin", fb).addPart("comment", comment).build();
|
try {
|
hp.setEntity(reqEntity);
|
CloseableHttpResponse cr= httpclient.execute(hp);
|
try{
|
HttpEntity he=cr.getEntity();
|
if(he!=null)
|
re=EntityUtils.toString(he,"UTF-8");
|
EntityUtils.consume(he);
|
}catch(Exception ee)
|
{}finally{
|
cr.close();
|
}
|
} catch (Exception e) {
|
log.info("error");
|
}finally{
|
try {
|
httpclient.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return re;
|
}
|
public boolean clearcontext()
|
{
|
this.cookiestore.clear();
|
this.cookiestore=null;
|
this.hcontext=null;
|
System.gc();
|
return true;
|
}
|
public boolean createcontext()
|
{
|
hcontext = HttpClientContext.create();
|
cookiestore=new BasicCookieStore();
|
PublicSuffixMatcher publicSuffixMatcher = PublicSuffixMatcherLoader.getDefault();
|
Registry<CookieSpecProvider> registry = RegistryBuilder
|
.<CookieSpecProvider> create()
|
.register(CookieSpecs.DEFAULT, new DefaultCookieSpecProvider(publicSuffixMatcher))
|
.register(CookieSpecs.STANDARD,
|
new RFC6265CookieSpecProvider(publicSuffixMatcher)).build();
|
hcontext.setCookieSpecRegistry(registry);
|
hcontext.setCookieStore(cookiestore);
|
return true;
|
}
|
|
public boolean addcookie(String name,String value)
|
{
|
if(this.hcontext==null||this.cookiestore==null)
|
return false;
|
BasicClientCookie bc=new BasicClientCookie(name, value);
|
this.cookiestore.addCookie(bc);
|
return true;
|
}
|
public boolean clearcooike()
|
{
|
if(this.hcontext==null||this.cookiestore==null)
|
return false;
|
cookiestore.clear();
|
return true;
|
}
|
|
|
}
|
