package com.dy.pipirrWebChat.config;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.http.converter.HttpMessageConverter;
|
import org.springframework.http.converter.StringHttpMessageConverter;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.nio.charset.StandardCharsets;
|
import java.util.List;
|
//import org.apache.http.client.HttpClient;
|
|
/**
|
* @author ZhuBaoMin
|
* @date 2024-02-23 15:42
|
* @LastEditTime 2024-02-23 15:42
|
* @Description
|
*/
|
|
@Configuration
|
public class RestTemplateConfig {
|
@Autowired
|
private RestTemplateWechatCertConfig restTemplateWechatCertConfig;
|
|
//@Bean
|
//public RestTemplate restTemplate() {
|
// return new RestTemplate();
|
//}
|
|
//@Bean
|
//public RestTemplate restTemplate() {
|
// String mchid = PayInfo.mchid;
|
// RestTemplate restTemplate = null;
|
// try {
|
// KeyStore keyStore = KeyStore.getInstance("PKCS12");
|
// //InputStream cp = this.getClass().getResourceAsStream("apiclient_cert.p12");
|
// FileInputStream instream = new FileInputStream(new File("C:\\webchat\\apiclient_cert.p12"));
|
// keyStore.load(instream, mchid.toCharArray());
|
// // Trust own CA and all self-signed certs
|
// SSLContext sslcontext = SSLContextBuilder.create()
|
// .loadKeyMaterial(keyStore, mchid.toCharArray())
|
// .build();
|
// //Allow TLSv1 protocol only
|
// SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[]{"TLSv1"}, null, NoopHostnameVerifier.INSTANCE);
|
// CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
|
// HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
|
//
|
// restTemplate = new RestTemplate(factory);
|
// //将转换器的编码换成utf-8
|
// restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(Charset.forName("utf-8")));
|
// //System.out.println("restTemplate.hashCode():" + restTemplate.hashCode());
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// return restTemplate;
|
//}
|
|
//@Bean(name = "wechatRestTemplate")
|
@Bean()
|
public RestTemplate restTemplate() throws Exception {
|
RestTemplate restTemplate = new RestTemplate(restTemplateWechatCertConfig.wechatHttpRequestFactory());
|
// 添加拦截器
|
//List<ClientHttpRequestInterceptor> interceptors = new ArrayList<>();
|
//RestTemplateWechatCertConfig.MyRequestInterceptor myRequestInterceptor = new RestTemplateWechatCertConfig.MyRequestInterceptor();
|
//interceptors.add(myRequestInterceptor);
|
//restTemplate.setInterceptors(interceptors);
|
|
// 中文乱码，主要是 StringHttpMessageConverter的默认编码为ISO导致的
|
List<HttpMessageConverter<?>> list = restTemplate.getMessageConverters();
|
for (HttpMessageConverter converter : list) {
|
if (converter instanceof StringHttpMessageConverter) {
|
((StringHttpMessageConverter) converter).setDefaultCharset(StandardCharsets.UTF_8);
|
break;
|
}
|
}
|
|
return restTemplate;
|
}
|
}
|
