本文整理了Java中com.ning.http.client.AsyncHttpClientConfig.getRequestFilters()方法的一些代码示例，展示了AsyncHttpClientConfig.getRequestFilters()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AsyncHttpClientConfig.getRequestFilters()方法的具体详情如下：
包路径：com.ning.http.client.AsyncHttpClientConfig
类名称：AsyncHttpClientConfig
方法名：getRequestFilters

AsyncHttpClientConfig.getRequestFilters介绍

[英]Return the list of RequestFilter
[中]返回RequestFilter的列表

代码示例

代码示例来源：origin: com.ning/async-http-client

/**
 * Configure and execute the associated {@link RequestFilter}. This class may decorate the {@link Request} and {@link AsyncHandler}
 *
 * @param fc {@link FilterContext}
 * @return {@link FilterContext}
 */
private <T> FilterContext<T> preProcessRequest(FilterContext<T> fc) throws FilterException {
  for (RequestFilter asyncFilter : config.getRequestFilters()) {
    fc = asyncFilter.filter(fc);
    if (fc == null) {
      throw new NullPointerException("FilterContext is null");
    }
  }
  Request request = fc.getRequest();
  if (fc.getAsyncHandler() instanceof ResumableAsyncHandler) {
    request = ResumableAsyncHandler.class.cast(fc.getAsyncHandler()).adjustRequestRange(request);
  }
  if (request.getRangeOffset() != 0) {
    RequestBuilder builder = new RequestBuilder(request);
    builder.setHeader("Range", "bytes=" + request.getRangeOffset() + "-");
    request = builder.build();
  }
  fc = new FilterContext.FilterContextBuilder<T>(fc).request(request).build();
  return fc;
}

代码示例来源：origin: com.ning/async-http-client

/**
 * Execute an HTTP request.
 *
 * @param request {@link Request}
 * @param handler an instance of {@link AsyncHandler}
 * @param <T>     Type of the value that will be returned by the associated {@link java.util.concurrent.Future}
 * @return a {@link Future} of type T
 */
public <T> ListenableFuture<T> executeRequest(Request request, AsyncHandler<T> handler) {
  if (config.getRequestFilters().isEmpty()) {
    return httpProvider.execute(request, handler);
  } else {
    FilterContext<T> fc = new FilterContext.FilterContextBuilder<T>().asyncHandler(handler).request(request).build();
    try {
      fc = preProcessRequest(fc);
    } catch (Exception e) {
      handler.onThrowable(e);
      return new ListenableFuture.CompletedFailure<T>("preProcessRequest failed", e);
    }
    
    return httpProvider.execute(fc.getRequest(), fc.getAsyncHandler());
  }
}

代码示例来源：origin: com.ning/async-http-client

ioExceptionFilters.clear();
requestFilters.addAll(prototype.getRequestFilters());
responseFilters.addAll(prototype.getResponseFilters());
ioExceptionFilters.addAll(prototype.getIOExceptionFilters());

代码示例来源：origin: io.gatling/async-http-client

for (RequestFilter asyncFilter : config.getRequestFilters()) {
  try {
    fc = asyncFilter.filter(fc);

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-client

/**
 * Execute an HTTP request.
 *
 * @param request {@link Request}
 * @param handler an instance of {@link AsyncHandler}
 * @param <T>     Type of the value that will be returned by the associated {@link java.util.concurrent.Future}
 * @return a {@link Future} of type T
 */
public <T> ListenableFuture<T> executeRequest(Request request, AsyncHandler<T> handler) {
  if (config.getRequestFilters().isEmpty()) {
    return httpProvider.execute(request, handler);
  } else {
    FilterContext<T> fc = new FilterContext.FilterContextBuilder<T>().asyncHandler(handler).request(request).build();
    try {
      fc = preProcessRequest(fc);
    } catch (Exception e) {
      handler.onThrowable(e);
      return new ListenableFuture.CompletedFailure<T>("preProcessRequest failed", e);
    }
    
    return httpProvider.execute(fc.getRequest(), fc.getAsyncHandler());
  }
}

代码示例来源：origin: javaee/grizzly-ahc

/**
 * Configure and execute the associated {@link RequestFilter}. This class may decorate the {@link Request} and {@link AsyncHandler}
 *
 * @param fc {@link FilterContext}
 * @return {@link FilterContext}
 */
private <T> FilterContext<T> preProcessRequest(FilterContext<T> fc) throws FilterException {
  for (RequestFilter asyncFilter : config.getRequestFilters()) {
    fc = asyncFilter.filter(fc);
    if (fc == null) {
      throw new NullPointerException("FilterContext is null");
    }
  }
  Request request = fc.getRequest();
  if (fc.getAsyncHandler() instanceof ResumableAsyncHandler) {
    request = ResumableAsyncHandler.class.cast(fc.getAsyncHandler()).adjustRequestRange(request);
  }
  if (request.getRangeOffset() != 0) {
    RequestBuilder builder = new RequestBuilder(request);
    builder.setHeader("Range", "bytes=" + request.getRangeOffset() + "-");
    request = builder.build();
  }
  fc = new FilterContext.FilterContextBuilder<T>(fc).request(request).build();
  return fc;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-client

/**
 * Configure and execute the associated {@link RequestFilter}. This class may decorate the {@link Request} and {@link AsyncHandler}
 *
 * @param fc {@link FilterContext}
 * @return {@link FilterContext}
 */
private <T> FilterContext<T> preProcessRequest(FilterContext<T> fc) throws FilterException {
  for (RequestFilter asyncFilter : config.getRequestFilters()) {
    fc = asyncFilter.filter(fc);
    if (fc == null) {
      throw new NullPointerException("FilterContext is null");
    }
  }
  Request request = fc.getRequest();
  if (fc.getAsyncHandler() instanceof ResumableAsyncHandler) {
    request = ResumableAsyncHandler.class.cast(fc.getAsyncHandler()).adjustRequestRange(request);
  }
  if (request.getRangeOffset() != 0) {
    RequestBuilder builder = new RequestBuilder(request);
    builder.setHeader("Range", "bytes=" + request.getRangeOffset() + "-");
    request = builder.build();
  }
  fc = new FilterContext.FilterContextBuilder<T>(fc).request(request).build();
  return fc;
}

代码示例来源：origin: javaee/grizzly-ahc

/**
 * Execute an HTTP request.
 *
 * @param request {@link Request}
 * @param handler an instance of {@link AsyncHandler}
 * @param <T>     Type of the value that will be returned by the associated {@link java.util.concurrent.Future}
 * @return a {@link Future} of type T
 */
public <T> ListenableFuture<T> executeRequest(Request request, AsyncHandler<T> handler) {
  if (config.getRequestFilters().isEmpty()) {
    return httpProvider.execute(request, handler);
  } else {
    FilterContext<T> fc = new FilterContext.FilterContextBuilder<T>().asyncHandler(handler).request(request).build();
    try {
      fc = preProcessRequest(fc);
    } catch (Exception e) {
      handler.onThrowable(e);
      return new ListenableFuture.CompletedFailure<T>("preProcessRequest failed", e);
    }
    
    return httpProvider.execute(fc.getRequest(), fc.getAsyncHandler());
  }
}

代码示例来源：origin: io.gatling/async-http-client

ioExceptionFilters.clear();
requestFilters.addAll(prototype.getRequestFilters());
responseFilters.addAll(prototype.getResponseFilters());
ioExceptionFilters.addAll(prototype.getIOExceptionFilters());

代码示例来源：origin: javaee/grizzly-ahc

ioExceptionFilters.clear();
requestFilters.addAll(prototype.getRequestFilters());
responseFilters.addAll(prototype.getResponseFilters());
ioExceptionFilters.addAll(prototype.getIOExceptionFilters());

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-client

ioExceptionFilters.clear();
requestFilters.addAll(prototype.getRequestFilters());
responseFilters.addAll(prototype.getResponseFilters());
ioExceptionFilters.addAll(prototype.getIOExceptionFilters());