package com.dsh.app.util.pay.wechat;
|
|
import com.dsh.app.util.pay.config.Config;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
|
import org.apache.http.conn.ssl.SSLContexts;
|
import org.apache.http.entity.StringEntity;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.util.EntityUtils;
|
|
import javax.net.ssl.SSLContext;
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.security.KeyStore;
|
import java.util.Map;
|
|
/**
|
* This example demonstrates how to create secure connections with a custom SSL
|
* context.
|
*/
|
public class ClientCustomSSL {
|
public Map<String, String> doRefund(String url, String data, HttpServletRequest request) throws Exception {
|
/**
|
* 注意PKCS12证书 是从微信商户平台-》账户设置-》 API安全 中下载的
|
*/
|
String pathStr= "C:/cert/apiclient_cert.p12";
|
System.out.println("pathstr-->"+pathStr);
|
KeyStore keyStore = KeyStore.getInstance("PKCS12");
|
FileInputStream instream = new FileInputStream(new File(pathStr));//P12文件目录
|
try {
|
/**
|
* 此处要改
|
* */
|
keyStore.load(instream, Config.WX_PAY_MCH_ID.toCharArray());//这里写密码..默认是你的MCHID
|
} finally {
|
instream.close();
|
}
|
// Trust own CA and all self-signed certs
|
/**
|
* 此处要改
|
* */
|
SSLContext sslcontext = SSLContexts.custom()
|
.loadKeyMaterial(keyStore, Config.WX_PAY_MCH_ID.toCharArray())//这里也是写密码的
|
.build();
|
// Allow TLSv1 protocol only
|
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
|
sslcontext,
|
new String[] { "TLSv1" },
|
null,
|
SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
|
CloseableHttpClient httpclient = HttpClients.custom()
|
.setSSLSocketFactory(sslsf)
|
.build();
|
try {
|
HttpPost httpost = new HttpPost(url); // 设置响应头信息
|
httpost.addHeader("Connection", "keep-alive");
|
httpost.addHeader("Accept", "*/*");
|
httpost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
|
httpost.addHeader("Host", "api.mch.weixin.qq.com");
|
httpost.addHeader("X-Requested-With", "XMLHttpRequest");
|
httpost.addHeader("Cache-Control", "max-age=0");
|
httpost.addHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0) ");
|
httpost.setEntity(new StringEntity(data, "UTF-8"));
|
CloseableHttpResponse response = httpclient.execute(httpost);
|
try {
|
HttpEntity entity = response.getEntity();
|
String jsonStr = EntityUtils.toString(response.getEntity(), "UTF-8");
|
|
Map<String,String> map=WXXMLUtil.doXMLParse(jsonStr);
|
EntityUtils.consume(entity);
|
return map;
|
} finally {
|
response.close();
|
}
|
} finally {
|
httpclient.close();
|
}
|
}
|
|
}
|
