package com.qianwen.core.http;
|
|
import java.net.InetSocketAddress;
|
import java.net.Proxy;
|
import java.net.ProxySelector;
|
import java.net.URI;
|
import java.security.KeyManagementException;
|
import java.security.NoSuchAlgorithmException;
|
import java.time.Duration;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
import java.util.function.Predicate;
|
import javax.annotation.Nonnull;
|
import javax.annotation.Nullable;
|
import javax.net.ssl.HostnameVerifier;
|
import javax.net.ssl.SSLContext;
|
import javax.net.ssl.SSLSocketFactory;
|
import javax.net.ssl.TrustManager;
|
import javax.net.ssl.X509TrustManager;
|
import okhttp3.Authenticator;
|
import okhttp3.CacheControl;
|
import okhttp3.Call;
|
import okhttp3.Cookie;
|
import okhttp3.CookieJar;
|
import okhttp3.EventListener;
|
import okhttp3.FormBody;
|
import okhttp3.Headers;
|
import okhttp3.HttpUrl;
|
import okhttp3.Interceptor;
|
import okhttp3.MediaType;
|
import okhttp3.MultipartBody;
|
import okhttp3.OkHttpClient;
|
import okhttp3.Request;
|
import okhttp3.RequestBody;
|
import okhttp3.internal.Util;
|
import okhttp3.internal.http.HttpMethod;
|
import okhttp3.logging.HttpLoggingInterceptor;
|
import com.qianwen.core.tool.jackson.JsonUtil;
|
import com.qianwen.core.tool.ssl.DisableValidationTrustManager;
|
import com.qianwen.core.tool.ssl.TrustAllHostNames;
|
import com.qianwen.core.tool.utils.Exceptions;
|
import com.qianwen.core.tool.utils.Holder;
|
|
/* loaded from: blade-starter-http-9.3.0.0-SNAPSHOT.jar:org/springblade/core/http/HttpRequest.class */
|
public class HttpRequest {
|
private static final String DEFAULT_USER_AGENT = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.36";
|
private static final MediaType APPLICATION_JSON = MediaType.parse("application/json;charset=UTF-8");
|
private static volatile OkHttpClient httpClient = new OkHttpClient();
|
@Nullable
|
private static HttpLoggingInterceptor globalLoggingInterceptor = null;
|
private final Request.Builder requestBuilder;
|
private final HttpUrl.Builder uriBuilder;
|
private final String httpMethod;
|
private String userAgent;
|
@Nullable
|
private RequestBody requestBody;
|
@Nullable
|
private Boolean followRedirects;
|
@Nullable
|
private Boolean followSslRedirects;
|
@Nullable
|
private HttpLoggingInterceptor.Level level;
|
@Nullable
|
private CookieJar cookieJar;
|
@Nullable
|
private EventListener eventListener;
|
private final List<Interceptor> interceptors = new ArrayList();
|
@Nullable
|
private Authenticator authenticator;
|
@Nullable
|
private Duration connectTimeout;
|
@Nullable
|
private Duration readTimeout;
|
@Nullable
|
private Duration writeTimeout;
|
@Nullable
|
private Proxy proxy;
|
@Nullable
|
private ProxySelector proxySelector;
|
@Nullable
|
private Authenticator proxyAuthenticator;
|
@Nullable
|
private RetryPolicy retryPolicy;
|
@Nullable
|
private Boolean disableSslValidation;
|
@Nullable
|
private HostnameVerifier hostnameVerifier;
|
@Nullable
|
private SSLSocketFactory sslSocketFactory;
|
@Nullable
|
private X509TrustManager trustManager;
|
|
public static HttpRequest get(final String url) {
|
return new HttpRequest(new Request.Builder(), url, Method.GET);
|
}
|
|
public static HttpRequest get(final URI uri) {
|
return get(uri.toString());
|
}
|
|
public static HttpRequest post(final String url) {
|
return new HttpRequest(new Request.Builder(), url, Method.POST);
|
}
|
|
public static HttpRequest post(final URI uri) {
|
return post(uri.toString());
|
}
|
|
public static HttpRequest patch(final String url) {
|
return new HttpRequest(new Request.Builder(), url, Method.PATCH);
|
}
|
|
public static HttpRequest patch(final URI uri) {
|
return patch(uri.toString());
|
}
|
|
public static HttpRequest put(final String url) {
|
return new HttpRequest(new Request.Builder(), url, Method.PUT);
|
}
|
|
public static HttpRequest put(final URI uri) {
|
return put(uri.toString());
|
}
|
|
public static HttpRequest delete(final String url) {
|
return new HttpRequest(new Request.Builder(), url, Method.DELETE);
|
}
|
|
public static HttpRequest delete(final URI uri) {
|
return delete(uri.toString());
|
}
|
|
public HttpRequest query(String query) {
|
this.uriBuilder.query(query);
|
return this;
|
}
|
|
public HttpRequest queryEncoded(String encodedQuery) {
|
this.uriBuilder.encodedQuery(encodedQuery);
|
return this;
|
}
|
|
public HttpRequest queryMap(@Nullable Map<String, Object> queryMap) {
|
if (queryMap != null && !queryMap.isEmpty()) {
|
queryMap.forEach(this::query);
|
}
|
return this;
|
}
|
|
public HttpRequest query(String name, @Nullable Object value) {
|
this.uriBuilder.addQueryParameter(name, value == null ? null : String.valueOf(value));
|
return this;
|
}
|
|
public HttpRequest queryEncoded(String encodedName, @Nullable Object encodedValue) {
|
this.uriBuilder.addEncodedQueryParameter(encodedName, encodedValue == null ? null : String.valueOf(encodedValue));
|
return this;
|
}
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
public HttpRequest form(FormBody formBody) {
|
this.requestBody = formBody;
|
return this;
|
}
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
public HttpRequest multipartForm(MultipartBody multipartBody) {
|
this.requestBody = multipartBody;
|
return this;
|
}
|
|
public FormBuilder formBuilder() {
|
return new FormBuilder(this);
|
}
|
|
public MultipartFormBuilder multipartFormBuilder() {
|
return new MultipartFormBuilder(this);
|
}
|
|
public HttpRequest body(RequestBody requestBody) {
|
this.requestBody = requestBody;
|
return this;
|
}
|
|
public HttpRequest bodyString(String body) {
|
this.requestBody = RequestBody.create(APPLICATION_JSON, body);
|
return this;
|
}
|
|
public HttpRequest bodyString(MediaType contentType, String body) {
|
this.requestBody = RequestBody.create(contentType, body);
|
return this;
|
}
|
|
public HttpRequest bodyJson(@Nonnull Object body) {
|
return bodyString(JsonUtil.toJson(body));
|
}
|
|
private HttpRequest(final Request.Builder requestBuilder, String url, String httpMethod) {
|
HttpUrl httpUrl = HttpUrl.parse(url);
|
if (httpUrl == null) {
|
throw new IllegalArgumentException(String.format("Url 不能解析: %s: [%s]。", httpMethod.toLowerCase(), url));
|
}
|
this.requestBuilder = requestBuilder;
|
this.uriBuilder = httpUrl.newBuilder();
|
this.httpMethod = httpMethod;
|
this.userAgent = DEFAULT_USER_AGENT;
|
}
|
|
private Call internalCall(final OkHttpClient client) {
|
Request request;
|
OkHttpClient.Builder builder = client.newBuilder();
|
if (this.connectTimeout != null) {
|
builder.connectTimeout(this.connectTimeout.toMillis(), TimeUnit.MILLISECONDS);
|
}
|
if (this.readTimeout != null) {
|
builder.readTimeout(this.readTimeout.toMillis(), TimeUnit.MILLISECONDS);
|
}
|
if (this.writeTimeout != null) {
|
builder.writeTimeout(this.writeTimeout.toMillis(), TimeUnit.MILLISECONDS);
|
}
|
if (this.proxy != null) {
|
builder.proxy(this.proxy);
|
}
|
if (this.proxySelector != null) {
|
builder.proxySelector(this.proxySelector);
|
}
|
if (this.proxyAuthenticator != null) {
|
builder.proxyAuthenticator(this.proxyAuthenticator);
|
}
|
if (this.hostnameVerifier != null) {
|
builder.hostnameVerifier(this.hostnameVerifier);
|
}
|
if (this.sslSocketFactory != null && this.trustManager != null) {
|
builder.sslSocketFactory(this.sslSocketFactory, this.trustManager);
|
}
|
if (Boolean.TRUE.equals(this.disableSslValidation)) {
|
disableSslValidation(builder);
|
}
|
if (this.authenticator != null) {
|
builder.authenticator(this.authenticator);
|
}
|
if (!this.interceptors.isEmpty()) {
|
builder.interceptors().addAll(this.interceptors);
|
}
|
if (this.cookieJar != null) {
|
builder.cookieJar(this.cookieJar);
|
}
|
if (this.eventListener != null) {
|
builder.eventListener(this.eventListener);
|
}
|
if (this.followRedirects != null) {
|
builder.followRedirects(this.followRedirects.booleanValue());
|
}
|
if (this.followSslRedirects != null) {
|
builder.followSslRedirects(this.followSslRedirects.booleanValue());
|
}
|
if (this.retryPolicy != null) {
|
builder.addInterceptor(new RetryInterceptor(this.retryPolicy));
|
}
|
if (this.level != null && HttpLoggingInterceptor.Level.NONE != this.level) {
|
builder.addInterceptor(getLoggingInterceptor(this.level));
|
} else if (globalLoggingInterceptor != null) {
|
builder.addInterceptor(globalLoggingInterceptor);
|
}
|
this.requestBuilder.header("User-Agent", this.userAgent);
|
this.requestBuilder.url(this.uriBuilder.build());
|
String method = this.httpMethod;
|
if (HttpMethod.requiresRequestBody(method) && this.requestBody == null) {
|
request = this.requestBuilder.method(method, Util.EMPTY_REQUEST).build();
|
} else {
|
request = this.requestBuilder.method(method, this.requestBody).build();
|
}
|
return builder.build().newCall(request);
|
}
|
|
public Exchange execute() {
|
return new Exchange(internalCall(httpClient));
|
}
|
|
public AsyncCall async() {
|
return new AsyncCall(internalCall(httpClient));
|
}
|
|
public HttpRequest baseAuth(String userName, String password) {
|
this.authenticator = new BaseAuthenticator(userName, password);
|
return this;
|
}
|
|
public HttpRequest addHeader(final Map<String, String> headers) {
|
this.requestBuilder.headers(Headers.of(headers));
|
return this;
|
}
|
|
public HttpRequest addHeader(final String... namesAndValues) {
|
Headers headers = Headers.of(namesAndValues);
|
this.requestBuilder.headers(headers);
|
return this;
|
}
|
|
public HttpRequest addHeader(final String name, final String value) {
|
this.requestBuilder.addHeader(name, value);
|
return this;
|
}
|
|
public HttpRequest setHeader(final String name, final String value) {
|
this.requestBuilder.header(name, value);
|
return this;
|
}
|
|
public HttpRequest removeHeader(final String name) {
|
this.requestBuilder.removeHeader(name);
|
return this;
|
}
|
|
public HttpRequest addCookie(final Cookie cookie) {
|
addHeader("Cookie", cookie.toString());
|
return this;
|
}
|
|
public HttpRequest cacheControl(final CacheControl cacheControl) {
|
this.requestBuilder.cacheControl(cacheControl);
|
return this;
|
}
|
|
public HttpRequest userAgent(final String userAgent) {
|
this.userAgent = userAgent;
|
return this;
|
}
|
|
public HttpRequest followRedirects(boolean followRedirects) {
|
this.followRedirects = Boolean.valueOf(followRedirects);
|
return this;
|
}
|
|
public HttpRequest followSslRedirects(boolean followSslRedirects) {
|
this.followSslRedirects = Boolean.valueOf(followSslRedirects);
|
return this;
|
}
|
|
private static HttpLoggingInterceptor getLoggingInterceptor(HttpLoggingInterceptor.Level level) {
|
HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor(Slf4jLogger.INSTANCE);
|
loggingInterceptor.setLevel(level);
|
return loggingInterceptor;
|
}
|
|
public HttpRequest log() {
|
this.level = HttpLoggingInterceptor.Level.BODY;
|
return this;
|
}
|
|
public HttpRequest log(LogLevel logLevel) {
|
this.level = logLevel.getLevel();
|
return this;
|
}
|
|
public HttpRequest authenticator(Authenticator authenticator) {
|
this.authenticator = authenticator;
|
return this;
|
}
|
|
public HttpRequest interceptor(Interceptor interceptor) {
|
this.interceptors.add(interceptor);
|
return this;
|
}
|
|
public HttpRequest cookieManager(CookieJar cookieJar) {
|
this.cookieJar = cookieJar;
|
return this;
|
}
|
|
public HttpRequest eventListener(EventListener eventListener) {
|
this.eventListener = eventListener;
|
return this;
|
}
|
|
public HttpRequest connectTimeout(final Duration timeout) {
|
this.connectTimeout = timeout;
|
return this;
|
}
|
|
public HttpRequest readTimeout(Duration readTimeout) {
|
this.readTimeout = readTimeout;
|
return this;
|
}
|
|
public HttpRequest writeTimeout(Duration writeTimeout) {
|
this.writeTimeout = writeTimeout;
|
return this;
|
}
|
|
public HttpRequest proxy(final InetSocketAddress address) {
|
this.proxy = new Proxy(Proxy.Type.HTTP, address);
|
return this;
|
}
|
|
public HttpRequest proxySelector(final ProxySelector proxySelector) {
|
this.proxySelector = proxySelector;
|
return this;
|
}
|
|
public HttpRequest proxyAuthenticator(final Authenticator proxyAuthenticator) {
|
this.proxyAuthenticator = proxyAuthenticator;
|
return this;
|
}
|
|
public HttpRequest retry() {
|
this.retryPolicy = RetryPolicy.INSTANCE;
|
return this;
|
}
|
|
public HttpRequest retryOn(Predicate<ResponseSpec> respPredicate) {
|
this.retryPolicy = new RetryPolicy(respPredicate);
|
return this;
|
}
|
|
public HttpRequest retry(int maxAttempts, long sleepMillis) {
|
this.retryPolicy = new RetryPolicy(maxAttempts, sleepMillis);
|
return this;
|
}
|
|
public HttpRequest retry(int maxAttempts, long sleepMillis, Predicate<ResponseSpec> respPredicate) {
|
this.retryPolicy = new RetryPolicy(maxAttempts, sleepMillis);
|
return this;
|
}
|
|
public HttpRequest disableSslValidation() {
|
this.disableSslValidation = Boolean.TRUE;
|
return this;
|
}
|
|
public HttpRequest hostnameVerifier(HostnameVerifier hostnameVerifier) {
|
this.hostnameVerifier = hostnameVerifier;
|
return this;
|
}
|
|
public HttpRequest sslSocketFactory(SSLSocketFactory sslSocketFactory, X509TrustManager trustManager) {
|
this.sslSocketFactory = sslSocketFactory;
|
this.trustManager = trustManager;
|
return this;
|
}
|
|
public String toString() {
|
return this.requestBuilder.toString();
|
}
|
|
public static void setHttpClient(OkHttpClient httpClient2) {
|
httpClient = httpClient2;
|
}
|
|
public static void setGlobalLog(LogLevel logLevel) {
|
globalLoggingInterceptor = getLoggingInterceptor(logLevel.getLevel());
|
}
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
public static String handleValue(@Nullable Object value) {
|
if (value == null) {
|
return "";
|
}
|
if (value instanceof String) {
|
return (String) value;
|
}
|
return String.valueOf(value);
|
}
|
|
private static void disableSslValidation(OkHttpClient.Builder builder) {
|
try {
|
X509TrustManager disabledTrustManager = DisableValidationTrustManager.INSTANCE;
|
TrustManager[] trustManagers = {disabledTrustManager};
|
SSLContext sslContext = SSLContext.getInstance("SSL");
|
sslContext.init(null, trustManagers, Holder.SECURE_RANDOM);
|
SSLSocketFactory disabledSslSocketFactory = sslContext.getSocketFactory();
|
builder.sslSocketFactory(disabledSslSocketFactory, disabledTrustManager);
|
builder.hostnameVerifier(TrustAllHostNames.INSTANCE);
|
} catch (KeyManagementException | NoSuchAlgorithmException e) {
|
throw Exceptions.unchecked(e);
|
}
|
}
|
}
|
