Explicación detallada de los pasos de Spring Integrating OKHTTP3

前言

okhttp 介绍

HTTP es la forma en que se establecen aplicaciones modernas. Así es como intercambiamos datos y medios. > Hacer HTTP de manera eficiente hace que sus cosas se carguen más rápido y guarde el ancho de banda.

OKHTTP es un cliente HTTP que es eficiente de forma predeterminada:

El soporte HTTP/2 permite que todas las solicitudes al mismo host compartan un socket.
La agrupación de conexión reduce la latencia de solicitud (si HTTP/2 no está disponible).
Tamaños de descarga transparentes de descarga de GZIP.
El almacenamiento en caché de respuesta evita la red por completo para las solicitudes repetidas.
OKHTTP Persevere cuando la red es problemática: se recuperará silenciosamente de >> problemas de conexión comunes. Si su servicio tiene múltiples direcciones IP, OKHTTP> intentará direcciones alternativas si la primera conexión falla. Esto es necesario para IPv4+IPv6> y para los servicios alojados en centros de datos redundantes. OKHTTP inicia nuevas conexiones> con las características modernas de TLS (SNI, ALPN), y vuelve a TLS 1.0 si el apretón de manos falla.

Usar OKHTTP es fácil. Su API de solicitud/respuesta está diseñada con constructores con fluidez e inmutabilidad. Admite ambas llamadas de bloqueo sincrónico y llamadas de async con devoluciones de llamada.

OKHTTP admite Android 2.3 y superior. Para Java, el requisito mínimo es 1.7. - 摘自 https://square.github.io/okhttp/

特点

1. 支持 http 和 https 协议, API 相同, 易用;

2.http 使用线程池, https 使用多路复用;

3.OKHTTP 支持同步和异步调用;

4. 支持普通 Forma 和文件上传 Forma;

5. 提供了拦截器, 操作请求和响应 (日志, 请求头, cuerpo 等);

6.OKHTTP 可以设置缓存;

准备工作

在 pom.xml 文件中增加以下依赖

<Spendency> <MoupRid> com.squareup.OKHTTP3 </groupid> <artifactId> okhttp </artifactid> <versión> 3.6.0 </versión> </pendency>

书写配置类

用 @configuration 注解该类 ， 等价与 xml 中配置 frijoles ；用 @bean 标注方法等价于 xml 中配置 bean。

 @ConfigurationPublic Class OKHTTPConfiguration {@Bean public X509TrustManager x509TrustManager () {return new x509TrustManager () {@Override public void checkClientTrusted (x509Certificate [] x509Certificates, string s) lanza certificadas de certificación {} @override pública VanCride CheckServerTrusted (x509Certificate [] x509Certificates, String s) arroja certificateException {} @Override public x509Certificate [] getacceptedissuers () {return new x509Certificate [0]; }}; } @Bean public sslSocketFactory sslSocketFactory () {try {// 信任任何链接 sslContext sslContext = sslContext.getInstance ("tls"); sslContext.init (null, new TrustManager [] {x509TrustManager ()}, new SecureRandom ()); return sslContext.getSocketFactory (); } Catch (nosuchalgorithMexception e) {E.PrintStackTrace (); } Catch (KeyManagementException e) {E.PrintStackTrace (); } return null; } /*** Cree un nuevo grupo de conexión con parámetros de ajuste apropiados para una aplicación de usuario único. * Los parámetros de ajuste en este grupo están sujetos a cambios en futuras versiones de OKTTP. Actualmente */ @Bean Public ConnectionPool Pool () {return New ConnectionPool (200, 5, TimeUnit.Minutes); } @Bean public okhttpClient okhttpClient () {return new okhttpClient.Builder () .sslsocketFactory (sslsocketfactory (), x509TrustManager ()) .retryonConnectionFailure (falso) // 是否开启缓存 .connectionpool (grupo ()) //. .ReadTimeOut (10L, TimeUnit.Seconds) .Build (); }}

工具类

自己写的工具类 ， 比较简单 不是 不是 descanso 风格

@ComponentPublic Class OKHTTPutil {private static final logger logger = loggerFactory.getLogger (okhtttputil.class); @Resource privado okhttpclient okhttpclient; / ** * Get * * @param url 请求的 url * @param consultas 请求的参数 ， 在浏览器？后面的数据 ， 没有可以传 null * @return */ public string get (string url, map <string, string> consulties) {String ResponseBody = ""; StringBuffer sb = new StringBuffer (URL); if (QUERIES! = NULL && QUERIES.KEYSET (). Size ()> 0) {boolean FirstFlag = true; Iterator iterator = Queries.EntrySet (). Iterator (); while (iterator.hasnext ()) {map.entry entry = (map.entry <string, string>) iterator.next (); if (FirstFlag) {sb.append ("?" + Entry.getKey () + "=" + Entry.getValue ()); FirstFlag = false; } else {sb.append ("&" + entry.getKey () + "=" + entry.getValue ()); }}} Solicitud de solicitud = nueva solicitud .Builder () .URL (SB.ToString ()) .Build (); Respuesta respuesta = nulo; intente {respuesta = okhttpclient.newcall (request) .execute (); int status = respuesta.code (); if (status == 200) {return respuesta.body (). String (); }} Catch (Exception e) {logger.error ("okhttp Put Error >> EX = {}", ExceptionUtils.getStackTrace (e)); } finalmente {if (respuesta! = null) {respuesta.close (); }} return ResponseBody; } / ** * post * * @param url 请求的 url * @param params formulario post 提交的参数 * @return * / public string post (string url, map <string, string> params) {string respuestas) FormBody.Builder Builder = new FormBody.Builder (); // 添加参数 if (params! = Null && params.keySet (). Size ()> 0) {for (string key: params.KeySet ()) {builder.add (key, params.get (key)); }} Solicitud de solicitud = nueva solicitud .Builder () .Url (url) .post (builder.build ()) .Build (); Respuesta respuesta = nulo; intente {respuesta = okhttpclient.newcall (request) .execute (); int status = respuesta.code (); if (status == 200) {return respuesta.body (). String (); }} Catch (Exception e) {logger.error ("Okhttp Post Error >> ex = {}", ExceptionUtils.getStackTrace (e)); } finalmente {if (respuesta! = null) {respuesta.close (); }} return ResponseBody; } / ** * Post 上传文件 * * @param url * @param params * @param filetype * @return * / public string postfile (string url, map <string, object> params, string fileType) {string respuestas = "" "; Multipartbody.builder builder = new MultipartBody.Builder (); // 添加参数 if (params! = Null && params.keySet (). Size ()> 0) {for (string key: params.KeySet ()) {if (params.get (key) instanceof file) {file = (file) params.get (key); builder.addformdataPart (key, file.getName (), requestbody.create (mediatype.parse (filete de filete), archivo)); continuar; } builder.addformdataPart (key, params.get (key) .ToString ()); }} Solicitud de solicitud = nueva solicitud .Builder () .Url (url) .post (builder.build ()) .Build (); Respuesta respuesta = nulo; intente {respuesta = okhttpclient.newcall (request) .execute (); int status = respuesta.code (); if (status == 200) {return respuesta.body (). String (); }} Catch (Exception e) {logger.error ("Okhttp Postfile Error >> ex = {}", ExceptionUtils.getStackTrace (e)); } finalmente {if (respuesta! = null) {respuesta.close (); }} return ResponseBody; }}

使用方法

@ResourcePrivate okhttputil okhttputil;

总结

以上就是这篇文章的全部内容了 ， 希望本文的内容对大家的学习或者工作具有一定的参考学习价值 如果有疑问大家可以留言交流 如果有疑问大家可以留言交流 谢谢大家对武林网的支持。