mirror of
https://gitee.com/chinabugotech/hutool.git
synced 2025-05-09 23:51:34 +08:00
fix code
This commit is contained in:
parent
1516bd289c
commit
49a05b6908
@ -85,7 +85,7 @@ public class HttpUtil {
|
|||||||
@SuppressWarnings("resource")
|
@SuppressWarnings("resource")
|
||||||
public static String get(final String urlString, final int timeout) {
|
public static String get(final String urlString, final int timeout) {
|
||||||
return ClientEngineFactory.getEngine()
|
return ClientEngineFactory.getEngine()
|
||||||
.setConfig(ClientConfig.of().setConnectionTimeout(timeout).setReadTimeout(timeout))
|
.init(ClientConfig.of().setConnectionTimeout(timeout).setReadTimeout(timeout))
|
||||||
.send(Request.of(urlString)).bodyStr();
|
.send(Request.of(urlString)).bodyStr();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -135,7 +135,7 @@ public class HttpDownloader {
|
|||||||
Assert.notBlank(url, "[url] is blank !");
|
Assert.notBlank(url, "[url] is blank !");
|
||||||
|
|
||||||
final Response response = ClientEngineFactory.getEngine()
|
final Response response = ClientEngineFactory.getEngine()
|
||||||
.setConfig(ClientConfig.of().setConnectionTimeout(timeout).setReadTimeout(timeout))
|
.init(ClientConfig.of().setConnectionTimeout(timeout).setReadTimeout(timeout))
|
||||||
.send(Request.of(url));
|
.send(Request.of(url));
|
||||||
|
|
||||||
if (response.isOk()) {
|
if (response.isOk()) {
|
||||||
|
@ -32,7 +32,7 @@ public interface ClientEngine extends Closeable {
|
|||||||
* @param config 客户端设置
|
* @param config 客户端设置
|
||||||
* @return this
|
* @return this
|
||||||
*/
|
*/
|
||||||
ClientEngine setConfig(ClientConfig config);
|
ClientEngine init(ClientConfig config);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 发送HTTP请求
|
* 发送HTTP请求
|
||||||
|
@ -45,7 +45,7 @@ public class ClientEngineFactory {
|
|||||||
*/
|
*/
|
||||||
@SuppressWarnings("resource")
|
@SuppressWarnings("resource")
|
||||||
public static ClientEngine createEngine(final ClientConfig config) {
|
public static ClientEngine createEngine(final ClientConfig config) {
|
||||||
return createEngine().setConfig(config);
|
return createEngine().init(config);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -65,7 +65,7 @@ public class HttpClient4Engine implements ClientEngine {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public HttpClient4Engine setConfig(final ClientConfig config) {
|
public HttpClient4Engine init(final ClientConfig config) {
|
||||||
this.config = config;
|
this.config = config;
|
||||||
// 重置客户端
|
// 重置客户端
|
||||||
IoUtil.closeQuietly(this.engine);
|
IoUtil.closeQuietly(this.engine);
|
||||||
|
@ -70,7 +70,7 @@ public class HttpClient5Engine implements ClientEngine {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public HttpClient5Engine setConfig(final ClientConfig config) {
|
public HttpClient5Engine init(final ClientConfig config) {
|
||||||
this.config = config;
|
this.config = config;
|
||||||
// 重置客户端
|
// 重置客户端
|
||||||
IoUtil.closeQuietly(this.engine);
|
IoUtil.closeQuietly(this.engine);
|
||||||
|
@ -51,7 +51,7 @@ public class JdkClientEngine implements ClientEngine {
|
|||||||
public JdkClientEngine() {}
|
public JdkClientEngine() {}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public JdkClientEngine setConfig(final ClientConfig config) {
|
public JdkClientEngine init(final ClientConfig config) {
|
||||||
this.config = config;
|
this.config = config;
|
||||||
if(null != this.conn){
|
if(null != this.conn){
|
||||||
this.conn.disconnectQuietly();
|
this.conn.disconnectQuietly();
|
||||||
|
@ -45,7 +45,7 @@ public class OkHttpEngine implements ClientEngine {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public OkHttpEngine setConfig(final ClientConfig config) {
|
public OkHttpEngine init(final ClientConfig config) {
|
||||||
this.config = config;
|
this.config = config;
|
||||||
// 重置客户端
|
// 重置客户端
|
||||||
this.client = null;
|
this.client = null;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user