资讯专栏INFORMATION COLUMN

springboot RestTemplate,访问https实现SSL请求

bitkylin / 773人阅读

一、RestTemplate 简介
Spring RestTemplate是Spring提供的用于访问Rest服务的客户端,RestTemplate 提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率.

RestTemplate包含以下几个部分:

HttpMessageConverter 对象转换器:将请求对象转换为具体的数据格式输出,例
入:Jaxb2RootElementHttpMessageConverterket提供对xml格式的输入输出支持

ClientHttpRequestFactory HTTP请求工厂,默认是JDK的HttpURLConnection,
可以通过使用ClientHttpRequestFactory指定不同的HTTP请求方式

ResponseErrorHandler 异常错误处理

ClientHttpRequestInterceptor 请求拦截器

RestTemplate通过HttpEntity添加消息headers

二、springboot 通过RestTemplate实现https访问

</>复制代码

  1. import java.io.InputStream;
  2. import java.security.KeyStore;
  3. import java.util.ArrayList;
  4. import java.util.Collections;
  5. import java.util.List;
  6. import javax.net.ssl.HostnameVerifier;
  7. import javax.net.ssl.HttpsURLConnection;
  8. import javax.net.ssl.KeyManagerFactory;
  9. import javax.net.ssl.SSLContext;
  10. import javax.net.ssl.SSLSession;
  11. import javax.net.ssl.TrustManager;
  12. import org.apache.commons.lang3.StringUtils;
  13. import org.apache.http.HttpHost;
  14. import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
  15. import org.apache.http.impl.client.HttpClientBuilder;
  16. import org.apache.http.impl.client.HttpClients;
  17. import org.apache.http.ssl.SSLContexts;
  18. import org.springframework.beans.factory.annotation.Autowired;
  19. import org.springframework.boot.context.properties.ConfigurationProperties;
  20. import org.springframework.context.annotation.Bean;
  21. import org.springframework.context.annotation.Conditional;
  22. import org.springframework.context.annotation.Configuration;
  23. import org.springframework.http.MediaType;
  24. import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
  25. import org.springframework.http.converter.json.GsonHttpMessageConverter;
  26. import org.springframework.http.converter.xml.Jaxb2RootElementHttpMessageConverter;
  27. import org.springframework.web.client.RestTemplate;
  28. /**
  29. * service相关配置
  30. *
  31. * @date 201731
  32. * @since 1.0.0
  33. */
  34. @Configuration
  35. public class ServiceConfigConfiguration {
  36. @Autowired
  37. sslProperties sslProperties ;
  38. /**
  39. * 访问SSL的Template
  40. *
  41. * @throws Exception
  42. */
  43. @Bean("sslRestTemplate")
  44. @Conditional(sslCondition.class)
  45. public RestTemplate tmsRestTemplate() throws Exception {
  46. //新建RestTemplate对象
  47. RestTemplate restTemplate = new RestTemplate();
  48. //判断证书文件地址是否存在
  49. if (StringUtils.isNotEmpty(sslProperties.getKeyfile())) {
  50. //在握手期间,如果URL的主机名和服务器的标识主机名不匹配,则验证机制可以回调此接口的实现
  51. 程序来确定是否应该允许此连接
  52. HostnameVerifier hv = new HostnameVerifier() {
  53. @Override
  54. public boolean verify(String urlHostName, SSLSession session) {
  55. return true;
  56. }
  57. };
  58. HttpsURLConnection.setDefaultHostnameVerifier(hv);
  59. //构建SSL-Socket链接工厂
  60. SSLConnectionSocketFactory ssLSocketFactory = buildSSLSocketFactory("PKCS12",
  61. sslProperties.getKeyfile(),sslProperties.getPassword(),
  62. Lists.newArrayList("TLSv1"), true);
  63. //Spring提供HttpComponentsClientHttpRequestFactory指定使用HttpClient作为底层实现创建 HTTP请求
  64. HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory(
  65. HttpClients.custom().setSSLSocketFactory(ssLSocketFactory).build()
  66. );
  67. //设置传递数据超时时长
  68. httpRequestFactory.setReadTimeout(sslProperties.getTimeout());
  69. //设置建立连接超时时长
  70. httpRequestFactory.setConnectTimeout(sslProperties.getTimeout());
  71. //设置获取连接超时时长
  72. httpRequestFactory.setConnectionRequestTimeout(tmsProperties.getTimeout());
  73. restTemplate.setRequestFactory(httpRequestFactory);
  74. // 返回消息头也是text_html,消息格式是XML,添加新的message converter
  75. Jaxb2RootElementHttpMessageConverter messageConverter = new Jaxb2RootElementHttpMessageConverter();
  76. //设置message Converter支持的媒体类型
  77. List finalMediaTypes = new ArrayList<>();
  78. finalMediaTypes.addAll(messageConverter.getSupportedMediaTypes());
  79. finalMediaTypes.add(MediaType.TEXT_HTML);
  80. messageConverter.setSupportedMediaTypes(finalMediaTypes);
  81. restTemplate.setMessageConverters(Lists.newArrayList(messageConverter));
  82. }
  83. return restTemplate;
  84. }
  85. /**
  86. * 构建SSLSocketFactory
  87. *
  88. * @param keyStoreType
  89. * @param keyFilePath
  90. * @param keyPassword
  91. * @param sslProtocols
  92. * @param auth 是否需要client默认相信不安全证书
  93. * @return
  94. * @throws Exception
  95. */
  96. private SSLConnectionSocketFactory buildSSLSocketFactory(String keyStoreType, String keyFilePath,
  97. String keyPassword, List sslProtocols, boolean auth) throws Exception {
  98. //证书管理器,指定证书及证书类型
  99. KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
  100. //KeyStore用于存放证书,创建对象时 指定交换数字证书的加密标准
  101. KeyStore keyStore = KeyStore.getInstance(keyStoreType);
  102. InputStream inputStream = resourcePatternResolver.getResource(keyFilePath).getInputStream();
  103. try {
  104. //添加证书
  105. keyStore.load(inputStream, keyPassword.toCharArray());
  106. } finally {
  107. inputStream.close();
  108. }
  109. keyManagerFactory.init(keyStore, keyPassword.toCharArray());
  110. SSLContext sslContext = SSLContext.getInstance("SSL");
  111. if (auth) {
  112. // 设置信任证书(绕过TrustStore验证)
  113. TrustManager[] trustAllCerts = new TrustManager[1];
  114. TrustManager trustManager = new AuthX509TrustManager();
  115. trustAllCerts[0] = trustManager;
  116. sslContext.init(keyManagerFactory.getKeyManagers(), trustAllCerts, null);
  117. HttpsURLConnection.setDefaultSSLSocketFactory(sslContext.getSocketFactory());
  118. } else {
  119. //加载证书材料,构建sslContext
  120. sslContext = SSLContexts.custom().loadKeyMaterial(keyStore, keyPassword.toCharArray()).build();
  121. }
  122. SSLConnectionSocketFactory sslConnectionSocketFactory =
  123. new SSLConnectionSocketFactory(sslContext, sslProtocols.toArray(new String[sslProtocols.size()]),
  124. null,
  125. new HostnameVerifier() {
  126. // 这里不校验hostname
  127. @Override
  128. public boolean verify(String urlHostName, SSLSession session) {
  129. return true;
  130. }
  131. });
  132. return sslConnectionSocketFactory;
  133. }
  134. }

AuthX509TrustManager 证书信任管理器类就是实现了接口X509TrustManager的类。可以自己实现该接口,信任我们指定的证书

</>复制代码

  1. public class AuthX509TrustManager implements javax.net.ssl.TrustManager, javax.net.ssl.X509TrustManager {
  2. public java.security.cert.X509Certificate[] getAcceptedIssuers() {
  3. return null;
  4. }
  5. public void checkServerTrusted(java.security.cert.X509Certificate[] certs, String authType)
  6. throws java.security.cert.CertificateException {
  7. return;
  8. }
  9. public void checkClientTrusted(java.security.cert.X509Certificate[] certs, String authType)
  10. throws java.security.cert.CertificateException {
  11. return;
  12. }
  13. }

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/69126.html

相关文章

  • SpringBoot 2.X Kotlin系列之RestTemplate配置及使用

    摘要:调用的默认构造函数,对象在底层通过使用包下的实现创建请求,可以通过使用指定不同的请求方式。接口主要提供了两种实现方式一种是,使用提供的方式既包提供的方式创建底层的请求连接。 showImg(http://download.qfeoo.com/kotlin_springboot_logo.png); 自从RESTFul API兴起后,Spring就给开发者提供了一个访问Rest的客服端,...

    wdzgege 评论0 收藏0
  • RestTemplate 详解

    摘要:也是提交新资源,提交成功之后,返回新资源的,的参数和前面两种的参数基本一致,只不过该方法的返回值为,这个只需要服务提供者返回一个即可,该表示新资源的位置。用于操作请求头和,在请求发出前执行。 showImg(https://segmentfault.com/img/remote/1460000012261105?w=1873&h=1080); 背景 这段时间自己做的项目中需要调用服务提...

    xiaodao 评论0 收藏0
  • SpringBoot非官方教程 | 第二十三篇: 异步方法

    摘要:如果去掉,你会发现,执行这三个方法都在线程中执行。耗时总结,如下耗时通过这一个小的栗子,你应该对异步任务有了一定的了解。 这篇文章主要介绍在springboot 使用异步方法,去请求github api. 创建工程 在pom文件引入相关依赖: org.springframework.boot spring-boot-starter ...

    jackwang 评论0 收藏0
  • 分布式-SpringBoot-SpringCloud-Eureka

    摘要:环境搭建注册中心依赖如下所示配置应用启动端口注册中心管理中的应用名称登陆注册管理中的的账号密码是否把自己注册到注册中心是否从上来获取服务的注册信息启动注册中心启动后访问登陆界面输入设置的账号密码进 环境 Java version 1.8 SpringBoot version 2.1.7 搭建注册中心 Eureka-server pom.xml 依赖如下所示: ...

    Olivia 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<