opensource
/
fine-third
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity
Browse Source

Pull request #8962: REPORT-98773 fix: 编译失败 

Merge in CORE/base-third from ~CLOUD.LIU/base-third:final/11.0 to final/11.0

* commit '1ea36a23f8b53a5177686d5e2ec7579ff0bd62bc':
  REPORT-98773 fix: 编译失败
final/11.0
Cloud.Liu-刘学真 1 year ago
parent
50a84c60b6 1ea36a23f8
commit
f9833e83b2
3 changed files with 464 additions and 464 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 336
      fine-spring/src/main/java/com/fr/third/springframework/http/client/HttpComponentsAsyncClientHttpRequest.java
  2. 422
      fine-spring/src/main/java/com/fr/third/springframework/http/client/HttpComponentsAsyncClientHttpRequestFactory.java
  3. 170
      fine-spring/src/main/java/com/fr/third/springframework/http/client/HttpComponentsAsyncClientHttpResponse.java

336
fine-spring/src/main/java/com/fr/third/springframework/http/client/HttpComponentsAsyncClientHttpRequest.java
Unescape View File

@ -1,168 +1,168 @@
/* ///*
* Copyright 2002-2016 the original author or authors. // * Copyright 2002-2016 the original author or authors.
* // *
* Licensed under the Apache License, Version 2.0 (the "License"); // * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. // * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at // * You may obtain a copy of the License at
* // *
* https://www.apache.org/licenses/LICENSE-2.0 // * https://www.apache.org/licenses/LICENSE-2.0
* // *
* Unless required by applicable law or agreed to in writing, software // * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, // * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and // * See the License for the specific language governing permissions and
* limitations under the License. // * limitations under the License.
*/ // */
//
package com.fr.third.springframework.http.client; //package com.fr.third.springframework.http.client;
//
import java.io.IOException; //import java.io.IOException;
import java.net.URI; //import java.net.URI;
import java.util.concurrent.Future; //import java.util.concurrent.Future;
//
import org.apache.http.HttpEntity; //import org.apache.http.HttpEntity;
import org.apache.http.HttpEntityEnclosingRequest; //import org.apache.http.HttpEntityEnclosingRequest;
import org.apache.http.HttpResponse; //import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpUriRequest; //import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.concurrent.FutureCallback; //import org.apache.http.concurrent.FutureCallback;
import org.apache.http.nio.client.HttpAsyncClient; //import org.apache.http.nio.client.HttpAsyncClient;
import org.apache.http.nio.entity.NByteArrayEntity; //import org.apache.http.nio.entity.NByteArrayEntity;
import org.apache.http.protocol.HttpContext; //import org.apache.http.protocol.HttpContext;
//
import com.fr.third.springframework.http.HttpHeaders; //import com.fr.third.springframework.http.HttpHeaders;
import com.fr.third.springframework.http.HttpMethod; //import com.fr.third.springframework.http.HttpMethod;
import com.fr.third.springframework.util.concurrent.FailureCallback; //import com.fr.third.springframework.util.concurrent.FailureCallback;
import com.fr.third.springframework.util.concurrent.FutureAdapter; //import com.fr.third.springframework.util.concurrent.FutureAdapter;
import com.fr.third.springframework.util.concurrent.ListenableFuture; //import com.fr.third.springframework.util.concurrent.ListenableFuture;
import com.fr.third.springframework.util.concurrent.ListenableFutureCallback; //import com.fr.third.springframework.util.concurrent.ListenableFutureCallback;
import com.fr.third.springframework.util.concurrent.ListenableFutureCallbackRegistry; //import com.fr.third.springframework.util.concurrent.ListenableFutureCallbackRegistry;
import com.fr.third.springframework.util.concurrent.SuccessCallback; //import com.fr.third.springframework.util.concurrent.SuccessCallback;
//
//
/** ///**
* {@link ClientHttpRequest} implementation based on // * {@link ClientHttpRequest} implementation based on
* Apache HttpComponents HttpAsyncClient. // * Apache HttpComponents HttpAsyncClient.
* // *
* <p>Created via the {@link HttpComponentsClientHttpRequestFactory}. // * <p>Created via the {@link HttpComponentsClientHttpRequestFactory}.
* // *
* @author Oleg Kalnichevski // * @author Oleg Kalnichevski
* @author Arjen Poutsma // * @author Arjen Poutsma
* @since 4.0 // * @since 4.0
* @see HttpComponentsClientHttpRequestFactory#createRequest // * @see HttpComponentsClientHttpRequestFactory#createRequest
*/ // */
final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncClientHttpRequest { //final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncClientHttpRequest {
//
private final HttpAsyncClient httpClient; // private final HttpAsyncClient httpClient;
//
private final HttpUriRequest httpRequest; // private final HttpUriRequest httpRequest;
//
private final HttpContext httpContext; // private final HttpContext httpContext;
//
//
HttpComponentsAsyncClientHttpRequest(HttpAsyncClient client, HttpUriRequest request, HttpContext context) { // HttpComponentsAsyncClientHttpRequest(HttpAsyncClient client, HttpUriRequest request, HttpContext context) {
this.httpClient = client; // this.httpClient = client;
this.httpRequest = request; // this.httpRequest = request;
this.httpContext = context; // this.httpContext = context;
} // }
//
//
@Override // @Override
public HttpMethod getMethod() { // public HttpMethod getMethod() {
return HttpMethod.resolve(this.httpRequest.getMethod()); // return HttpMethod.resolve(this.httpRequest.getMethod());
} // }
//
@Override // @Override
public URI getURI() { // public URI getURI() {
return this.httpRequest.getURI(); // return this.httpRequest.getURI();
} // }
//
HttpContext getHttpContext() { // HttpContext getHttpContext() {
return this.httpContext; // return this.httpContext;
} // }
//
@Override // @Override
protected ListenableFuture<ClientHttpResponse> executeInternal(HttpHeaders headers, byte[] bufferedOutput) // protected ListenableFuture<ClientHttpResponse> executeInternal(HttpHeaders headers, byte[] bufferedOutput)
throws IOException { // throws IOException {
//
HttpComponentsClientHttpRequest.addHeaders(this.httpRequest, headers); // HttpComponentsClientHttpRequest.addHeaders(this.httpRequest, headers);
//
if (this.httpRequest instanceof HttpEntityEnclosingRequest) { // if (this.httpRequest instanceof HttpEntityEnclosingRequest) {
HttpEntityEnclosingRequest entityEnclosingRequest = (HttpEntityEnclosingRequest) this.httpRequest; // HttpEntityEnclosingRequest entityEnclosingRequest = (HttpEntityEnclosingRequest) this.httpRequest;
HttpEntity requestEntity = new NByteArrayEntity(bufferedOutput); // HttpEntity requestEntity = new NByteArrayEntity(bufferedOutput);
entityEnclosingRequest.setEntity(requestEntity); // entityEnclosingRequest.setEntity(requestEntity);
} // }
//
HttpResponseFutureCallback callback = new HttpResponseFutureCallback(this.httpRequest); // HttpResponseFutureCallback callback = new HttpResponseFutureCallback(this.httpRequest);
Future<HttpResponse> futureResponse = this.httpClient.execute(this.httpRequest, this.httpContext, callback); // Future<HttpResponse> futureResponse = this.httpClient.execute(this.httpRequest, this.httpContext, callback);
return new ClientHttpResponseFuture(futureResponse, callback); // return new ClientHttpResponseFuture(futureResponse, callback);
} // }
//
//
private static class HttpResponseFutureCallback implements FutureCallback<HttpResponse> { // private static class HttpResponseFutureCallback implements FutureCallback<HttpResponse> {
//
private final HttpUriRequest request; // private final HttpUriRequest request;
//
private final ListenableFutureCallbackRegistry<ClientHttpResponse> callbacks = // private final ListenableFutureCallbackRegistry<ClientHttpResponse> callbacks =
new ListenableFutureCallbackRegistry<ClientHttpResponse>(); // new ListenableFutureCallbackRegistry<ClientHttpResponse>();
//
public HttpResponseFutureCallback(HttpUriRequest request) { // public HttpResponseFutureCallback(HttpUriRequest request) {
this.request = request; // this.request = request;
} // }
//
public void addCallback(ListenableFutureCallback<? super ClientHttpResponse> callback) { // public void addCallback(ListenableFutureCallback<? super ClientHttpResponse> callback) {
this.callbacks.addCallback(callback); // this.callbacks.addCallback(callback);
} // }
//
public void addSuccessCallback(SuccessCallback<? super ClientHttpResponse> callback) { // public void addSuccessCallback(SuccessCallback<? super ClientHttpResponse> callback) {
this.callbacks.addSuccessCallback(callback); // this.callbacks.addSuccessCallback(callback);
} // }
//
public void addFailureCallback(FailureCallback callback) { // public void addFailureCallback(FailureCallback callback) {
this.callbacks.addFailureCallback(callback); // this.callbacks.addFailureCallback(callback);
} // }
//
@Override // @Override
public void completed(HttpResponse result) { // public void completed(HttpResponse result) {
this.callbacks.success(new HttpComponentsAsyncClientHttpResponse(result)); // this.callbacks.success(new HttpComponentsAsyncClientHttpResponse(result));
} // }
//
@Override // @Override
public void failed(Exception ex) { // public void failed(Exception ex) {
this.callbacks.failure(ex); // this.callbacks.failure(ex);
} // }
//
@Override // @Override
public void cancelled() { // public void cancelled() {
this.request.abort(); // this.request.abort();
} // }
} // }
//
//
private static class ClientHttpResponseFuture extends FutureAdapter<ClientHttpResponse, HttpResponse> // private static class ClientHttpResponseFuture extends FutureAdapter<ClientHttpResponse, HttpResponse>
implements ListenableFuture<ClientHttpResponse> { // implements ListenableFuture<ClientHttpResponse> {
//
private final HttpResponseFutureCallback callback; // private final HttpResponseFutureCallback callback;
//
public ClientHttpResponseFuture(Future<HttpResponse> response, HttpResponseFutureCallback callback) { // public ClientHttpResponseFuture(Future<HttpResponse> response, HttpResponseFutureCallback callback) {
super(response); // super(response);
this.callback = callback; // this.callback = callback;
} // }
//
@Override // @Override
protected ClientHttpResponse adapt(HttpResponse response) { // protected ClientHttpResponse adapt(HttpResponse response) {
return new HttpComponentsAsyncClientHttpResponse(response); // return new HttpComponentsAsyncClientHttpResponse(response);
} // }
//
@Override // @Override
public void addCallback(ListenableFutureCallback<? super ClientHttpResponse> callback) { // public void addCallback(ListenableFutureCallback<? super ClientHttpResponse> callback) {
this.callback.addCallback(callback); // this.callback.addCallback(callback);
} // }
//
@Override // @Override
public void addCallback(SuccessCallback<? super ClientHttpResponse> successCallback, FailureCallback failureCallback) { // public void addCallback(SuccessCallback<? super ClientHttpResponse> successCallback, FailureCallback failureCallback) {
this.callback.addSuccessCallback(successCallback); // this.callback.addSuccessCallback(successCallback);
this.callback.addFailureCallback(failureCallback); // this.callback.addFailureCallback(failureCallback);
} // }
} // }
//
} //}

422
fine-spring/src/main/java/com/fr/third/springframework/http/client/HttpComponentsAsyncClientHttpRequestFactory.java
Unescape View File

@ -1,211 +1,211 @@
/* ///*
* Copyright 2002-2017 the original author or authors. // * Copyright 2002-2017 the original author or authors.
* // *
* Licensed under the Apache License, Version 2.0 (the "License"); // * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. // * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at // * You may obtain a copy of the License at
* // *
* https://www.apache.org/licenses/LICENSE-2.0 // * https://www.apache.org/licenses/LICENSE-2.0
* // *
* Unless required by applicable law or agreed to in writing, software // * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, // * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and // * See the License for the specific language governing permissions and
* limitations under the License. // * limitations under the License.
*/ // */
//
package com.fr.third.springframework.http.client; //package com.fr.third.springframework.http.client;
//
import java.io.Closeable; //import java.io.Closeable;
import java.io.IOException; //import java.io.IOException;
import java.net.URI; //import java.net.URI;
//
import org.apache.http.client.HttpClient; //import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig; //import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.Configurable; //import org.apache.http.client.methods.Configurable;
import org.apache.http.client.methods.HttpUriRequest; //import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.client.protocol.HttpClientContext; //import org.apache.http.client.protocol.HttpClientContext;
import org.apache.http.impl.client.CloseableHttpClient; //import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.nio.client.CloseableHttpAsyncClient; //import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
import org.apache.http.impl.nio.client.HttpAsyncClients; //import org.apache.http.impl.nio.client.HttpAsyncClients;
import org.apache.http.nio.client.HttpAsyncClient; //import org.apache.http.nio.client.HttpAsyncClient;
import org.apache.http.protocol.HttpContext; //import org.apache.http.protocol.HttpContext;
//
import com.fr.third.springframework.beans.factory.InitializingBean; //import com.fr.third.springframework.beans.factory.InitializingBean;
import com.fr.third.springframework.http.HttpMethod; //import com.fr.third.springframework.http.HttpMethod;
import com.fr.third.springframework.util.Assert; //import com.fr.third.springframework.util.Assert;
//
/** ///**
* Asynchronous extension of the {@link HttpComponentsClientHttpRequestFactory}. Uses // * Asynchronous extension of the {@link HttpComponentsClientHttpRequestFactory}. Uses
* <a href="https://hc.apache.org/httpcomponents-asyncclient-dev/">Apache HttpComponents // * <a href="https://hc.apache.org/httpcomponents-asyncclient-dev/">Apache HttpComponents
* HttpAsyncClient 4.0</a> to create requests. // * HttpAsyncClient 4.0</a> to create requests.
* // *
* @author Arjen Poutsma // * @author Arjen Poutsma
* @author Stephane Nicoll // * @author Stephane Nicoll
* @since 4.0 // * @since 4.0
* @see HttpAsyncClient // * @see HttpAsyncClient
*/ // */
public class HttpComponentsAsyncClientHttpRequestFactory extends HttpComponentsClientHttpRequestFactory //public class HttpComponentsAsyncClientHttpRequestFactory extends HttpComponentsClientHttpRequestFactory
implements AsyncClientHttpRequestFactory, InitializingBean { // implements AsyncClientHttpRequestFactory, InitializingBean {
//
private HttpAsyncClient asyncClient; // private HttpAsyncClient asyncClient;
//
//
/** // /**
* Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory} // * Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory}
* with a default {@link HttpAsyncClient} and {@link HttpClient}. // * with a default {@link HttpAsyncClient} and {@link HttpClient}.
*/ // */
public HttpComponentsAsyncClientHttpRequestFactory() { // public HttpComponentsAsyncClientHttpRequestFactory() {
super(); // super();
this.asyncClient = HttpAsyncClients.createSystem(); // this.asyncClient = HttpAsyncClients.createSystem();
} // }
//
/** // /**
* Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory} // * Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory}
* with the given {@link HttpAsyncClient} instance and a default {@link HttpClient}. // * with the given {@link HttpAsyncClient} instance and a default {@link HttpClient}.
* @param asyncClient the HttpAsyncClient instance to use for this request factory // * @param asyncClient the HttpAsyncClient instance to use for this request factory
* @since 4.3.10 // * @since 4.3.10
*/ // */
public HttpComponentsAsyncClientHttpRequestFactory(HttpAsyncClient asyncClient) { // public HttpComponentsAsyncClientHttpRequestFactory(HttpAsyncClient asyncClient) {
super(); // super();
setAsyncClient(asyncClient); // setAsyncClient(asyncClient);
} // }
//
/** // /**
* Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory} // * Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory}
* with the given {@link CloseableHttpAsyncClient} instance and a default {@link HttpClient}. // * with the given {@link CloseableHttpAsyncClient} instance and a default {@link HttpClient}.
* @param asyncClient the CloseableHttpAsyncClient instance to use for this request factory // * @param asyncClient the CloseableHttpAsyncClient instance to use for this request factory
*/ // */
public HttpComponentsAsyncClientHttpRequestFactory(CloseableHttpAsyncClient asyncClient) { // public HttpComponentsAsyncClientHttpRequestFactory(CloseableHttpAsyncClient asyncClient) {
super(); // super();
setAsyncClient(asyncClient); // setAsyncClient(asyncClient);
} // }
//
/** // /**
* Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory} // * Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory}
* with the given {@link HttpClient} and {@link HttpAsyncClient} instances. // * with the given {@link HttpClient} and {@link HttpAsyncClient} instances.
* @param httpClient the HttpClient instance to use for this request factory // * @param httpClient the HttpClient instance to use for this request factory
* @param asyncClient the HttpAsyncClient instance to use for this request factory // * @param asyncClient the HttpAsyncClient instance to use for this request factory
* @since 4.3.10 // * @since 4.3.10
*/ // */
public HttpComponentsAsyncClientHttpRequestFactory(HttpClient httpClient, HttpAsyncClient asyncClient) { // public HttpComponentsAsyncClientHttpRequestFactory(HttpClient httpClient, HttpAsyncClient asyncClient) {
super(httpClient); // super(httpClient);
setAsyncClient(asyncClient); // setAsyncClient(asyncClient);
} // }
//
/** // /**
* Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory} // * Create a new instance of the {@code HttpComponentsAsyncClientHttpRequestFactory}
* with the given {@link CloseableHttpClient} and {@link CloseableHttpAsyncClient} instances. // * with the given {@link CloseableHttpClient} and {@link CloseableHttpAsyncClient} instances.
* @param httpClient the CloseableHttpClient instance to use for this request factory // * @param httpClient the CloseableHttpClient instance to use for this request factory
* @param asyncClient the CloseableHttpAsyncClient instance to use for this request factory // * @param asyncClient the CloseableHttpAsyncClient instance to use for this request factory
*/ // */
public HttpComponentsAsyncClientHttpRequestFactory( // public HttpComponentsAsyncClientHttpRequestFactory(
CloseableHttpClient httpClient, CloseableHttpAsyncClient asyncClient) { // CloseableHttpClient httpClient, CloseableHttpAsyncClient asyncClient) {
//
super(httpClient); // super(httpClient);
setAsyncClient(asyncClient); // setAsyncClient(asyncClient);
} // }
//
//
/** // /**
* Set the {@code HttpAsyncClient} used for // * Set the {@code HttpAsyncClient} used for
* {@linkplain #createAsyncRequest(URI, HttpMethod) synchronous execution}. // * {@linkplain #createAsyncRequest(URI, HttpMethod) synchronous execution}.
* @since 4.3.10 // * @since 4.3.10
* @see #setHttpClient(HttpClient) // * @see #setHttpClient(HttpClient)
*/ // */
public void setAsyncClient(HttpAsyncClient asyncClient) { // public void setAsyncClient(HttpAsyncClient asyncClient) {
Assert.notNull(asyncClient, "HttpAsyncClient must not be null"); // Assert.notNull(asyncClient, "HttpAsyncClient must not be null");
this.asyncClient = asyncClient; // this.asyncClient = asyncClient;
} // }
//
/** // /**
* Return the {@code HttpAsyncClient} used for // * Return the {@code HttpAsyncClient} used for
* {@linkplain #createAsyncRequest(URI, HttpMethod) synchronous execution}. // * {@linkplain #createAsyncRequest(URI, HttpMethod) synchronous execution}.
* @since 4.3.10 // * @since 4.3.10
* @see #getHttpClient() // * @see #getHttpClient()
*/ // */
public HttpAsyncClient getAsyncClient() { // public HttpAsyncClient getAsyncClient() {
return this.asyncClient; // return this.asyncClient;
} // }
//
/** // /**
* Set the {@code CloseableHttpAsyncClient} used for // * Set the {@code CloseableHttpAsyncClient} used for
* {@linkplain #createAsyncRequest(URI, HttpMethod) asynchronous execution}. // * {@linkplain #createAsyncRequest(URI, HttpMethod) asynchronous execution}.
* @deprecated as of 4.3.10, in favor of {@link #setAsyncClient(HttpAsyncClient)} // * @deprecated as of 4.3.10, in favor of {@link #setAsyncClient(HttpAsyncClient)}
*/ // */
@Deprecated // @Deprecated
public void setHttpAsyncClient(CloseableHttpAsyncClient asyncClient) { // public void setHttpAsyncClient(CloseableHttpAsyncClient asyncClient) {
this.asyncClient = asyncClient; // this.asyncClient = asyncClient;
} // }
//
/** // /**
* Return the {@code CloseableHttpAsyncClient} used for // * Return the {@code CloseableHttpAsyncClient} used for
* {@linkplain #createAsyncRequest(URI, HttpMethod) asynchronous execution}. // * {@linkplain #createAsyncRequest(URI, HttpMethod) asynchronous execution}.
* @deprecated as of 4.3.10, in favor of {@link #getAsyncClient()} // * @deprecated as of 4.3.10, in favor of {@link #getAsyncClient()}
*/ // */
@Deprecated // @Deprecated
public CloseableHttpAsyncClient getHttpAsyncClient() { // public CloseableHttpAsyncClient getHttpAsyncClient() {
Assert.state(this.asyncClient == null || this.asyncClient instanceof CloseableHttpAsyncClient, // Assert.state(this.asyncClient == null || this.asyncClient instanceof CloseableHttpAsyncClient,
"No CloseableHttpAsyncClient - use getAsyncClient() instead"); // "No CloseableHttpAsyncClient - use getAsyncClient() instead");
return (CloseableHttpAsyncClient) this.asyncClient; // return (CloseableHttpAsyncClient) this.asyncClient;
} // }
//
//
@Override // @Override
public void afterPropertiesSet() { // public void afterPropertiesSet() {
startAsyncClient(); // startAsyncClient();
} // }
//
private void startAsyncClient() { // private void startAsyncClient() {
HttpAsyncClient asyncClient = getAsyncClient(); // HttpAsyncClient asyncClient = getAsyncClient();
if (asyncClient instanceof CloseableHttpAsyncClient) { // if (asyncClient instanceof CloseableHttpAsyncClient) {
CloseableHttpAsyncClient closeableAsyncClient = (CloseableHttpAsyncClient) asyncClient; // CloseableHttpAsyncClient closeableAsyncClient = (CloseableHttpAsyncClient) asyncClient;
if (!closeableAsyncClient.isRunning()) { // if (!closeableAsyncClient.isRunning()) {
closeableAsyncClient.start(); // closeableAsyncClient.start();
} // }
} // }
} // }
//
@Override // @Override
public AsyncClientHttpRequest createAsyncRequest(URI uri, HttpMethod httpMethod) throws IOException { // public AsyncClientHttpRequest createAsyncRequest(URI uri, HttpMethod httpMethod) throws IOException {
startAsyncClient(); // startAsyncClient();
//
HttpUriRequest httpRequest = createHttpUriRequest(httpMethod, uri); // HttpUriRequest httpRequest = createHttpUriRequest(httpMethod, uri);
postProcessHttpRequest(httpRequest); // postProcessHttpRequest(httpRequest);
HttpContext context = createHttpContext(httpMethod, uri); // HttpContext context = createHttpContext(httpMethod, uri);
if (context == null) { // if (context == null) {
context = HttpClientContext.create(); // context = HttpClientContext.create();
} // }
//
// Request configuration not set in the context // // Request configuration not set in the context
if (context.getAttribute(HttpClientContext.REQUEST_CONFIG) == null) { // if (context.getAttribute(HttpClientContext.REQUEST_CONFIG) == null) {
// Use request configuration given by the user, when available // // Use request configuration given by the user, when available
RequestConfig config = null; // RequestConfig config = null;
if (httpRequest instanceof Configurable) { // if (httpRequest instanceof Configurable) {
config = ((Configurable) httpRequest).getConfig(); // config = ((Configurable) httpRequest).getConfig();
} // }
if (config == null) { // if (config == null) {
config = createRequestConfig(getAsyncClient()); // config = createRequestConfig(getAsyncClient());
} // }
if (config != null) { // if (config != null) {
context.setAttribute(HttpClientContext.REQUEST_CONFIG, config); // context.setAttribute(HttpClientContext.REQUEST_CONFIG, config);
} // }
} // }
//
return new HttpComponentsAsyncClientHttpRequest(getAsyncClient(), httpRequest, context); // return new HttpComponentsAsyncClientHttpRequest(getAsyncClient(), httpRequest, context);
} // }
//
@Override // @Override
public void destroy() throws Exception { // public void destroy() throws Exception {
try { // try {
super.destroy(); // super.destroy();
} // }
finally { // finally {
HttpAsyncClient asyncClient = getAsyncClient(); // HttpAsyncClient asyncClient = getAsyncClient();
if (asyncClient instanceof Closeable) { // if (asyncClient instanceof Closeable) {
((Closeable) asyncClient).close(); // ((Closeable) asyncClient).close();
} // }
} // }
} // }
//
} //}

170
fine-spring/src/main/java/com/fr/third/springframework/http/client/HttpComponentsAsyncClientHttpResponse.java
Unescape View File

@ -1,85 +1,85 @@
/* ///*
* Copyright 2002-2016 the original author or authors. // * Copyright 2002-2016 the original author or authors.
* // *
* Licensed under the Apache License, Version 2.0 (the "License"); // * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. // * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at // * You may obtain a copy of the License at
* // *
* https://www.apache.org/licenses/LICENSE-2.0 // * https://www.apache.org/licenses/LICENSE-2.0
* // *
* Unless required by applicable law or agreed to in writing, software // * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, // * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and // * See the License for the specific language governing permissions and
* limitations under the License. // * limitations under the License.
*/ // */
//
package com.fr.third.springframework.http.client; //package com.fr.third.springframework.http.client;
//
import java.io.IOException; //import java.io.IOException;
import java.io.InputStream; //import java.io.InputStream;
//
import org.apache.http.Header; //import org.apache.http.Header;
import org.apache.http.HttpEntity; //import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse; //import org.apache.http.HttpResponse;
//
import com.fr.third.springframework.http.HttpHeaders; //import com.fr.third.springframework.http.HttpHeaders;
import com.fr.third.springframework.util.StreamUtils; //import com.fr.third.springframework.util.StreamUtils;
//
/** ///**
* {@link ClientHttpResponse} implementation based on // * {@link ClientHttpResponse} implementation based on
* Apache HttpComponents HttpAsyncClient. // * Apache HttpComponents HttpAsyncClient.
* // *
* <p>Created via the {@link HttpComponentsAsyncClientHttpRequest}. // * <p>Created via the {@link HttpComponentsAsyncClientHttpRequest}.
* // *
* @author Oleg Kalnichevski // * @author Oleg Kalnichevski
* @author Arjen Poutsma // * @author Arjen Poutsma
* @since 4.0 // * @since 4.0
* @see HttpComponentsAsyncClientHttpRequest#executeAsync() // * @see HttpComponentsAsyncClientHttpRequest#executeAsync()
*/ // */
final class HttpComponentsAsyncClientHttpResponse extends AbstractClientHttpResponse { //final class HttpComponentsAsyncClientHttpResponse extends AbstractClientHttpResponse {
//
private final HttpResponse httpResponse; // private final HttpResponse httpResponse;
//
private HttpHeaders headers; // private HttpHeaders headers;
//
//
HttpComponentsAsyncClientHttpResponse(HttpResponse httpResponse) { // HttpComponentsAsyncClientHttpResponse(HttpResponse httpResponse) {
this.httpResponse = httpResponse; // this.httpResponse = httpResponse;
} // }
//
//
@Override // @Override
public int getRawStatusCode() throws IOException { // public int getRawStatusCode() throws IOException {
return this.httpResponse.getStatusLine().getStatusCode(); // return this.httpResponse.getStatusLine().getStatusCode();
} // }
//
@Override // @Override
public String getStatusText() throws IOException { // public String getStatusText() throws IOException {
return this.httpResponse.getStatusLine().getReasonPhrase(); // return this.httpResponse.getStatusLine().getReasonPhrase();
} // }
//
@Override // @Override
public HttpHeaders getHeaders() { // public HttpHeaders getHeaders() {
if (this.headers == null) { // if (this.headers == null) {
this.headers = new HttpHeaders(); // this.headers = new HttpHeaders();
for (Header header : this.httpResponse.getAllHeaders()) { // for (Header header : this.httpResponse.getAllHeaders()) {
this.headers.add(header.getName(), header.getValue()); // this.headers.add(header.getName(), header.getValue());
} // }
} // }
return this.headers; // return this.headers;
} // }
//
@Override // @Override
public InputStream getBody() throws IOException { // public InputStream getBody() throws IOException {
HttpEntity entity = this.httpResponse.getEntity(); // HttpEntity entity = this.httpResponse.getEntity();
return (entity != null ? entity.getContent() : StreamUtils.emptyInput()); // return (entity != null ? entity.getContent() : StreamUtils.emptyInput());
} // }
//
@Override // @Override
public void close() { // public void close() {
// HTTP responses returned by async HTTP client are not bound to an // // HTTP responses returned by async HTTP client are not bound to an
// active connection and do not have to deallocate any resources... // // active connection and do not have to deallocate any resources...
} // }
//
} //}

Write Preview
Loading…
Cancel
Save