io.micronaut.http.client

Class DefaultHttpClient

java.lang.Object

io.micronaut.http.client.DefaultHttpClient

All Implemented Interfaces:

LifeCycle<HttpClient>, HttpClient, RxHttpClient, RxStreamingHttpClient, RxSseClient, SseClient, StreamingHttpClient, RxWebSocketClient, WebSocketClient, Closeable, AutoCloseable

@Prototype
 @Internal
 @Primary
public class DefaultHttpClient
extends Object
implements RxWebSocketClient, RxHttpClient, RxStreamingHttpClient, RxSseClient, Closeable, AutoCloseable

Default implementation of the HttpClient interface based on Netty.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	DefaultHttpClient.HttpClientInitializer Initializes the HTTP client channel.
protected class	DefaultHttpClient.NettyRequestWriter A Netty request writer.

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.bootstrap.Bootstrap	bootstrap
protected ByteBufferFactory<io.netty.buffer.ByteBufAllocator,io.netty.buffer.ByteBuf>	byteBufferFactory
protected io.netty.channel.EventLoopGroup	group
protected static String	HANDLER_AGGREGATOR
protected static String	HANDLER_CHUNK
protected static String	HANDLER_CONNECT_TTL
protected static String	HANDLER_DECODER
protected static String	HANDLER_STREAM
protected MediaTypeCodecRegistry	mediaTypeCodecRegistry

Fields inherited from interface io.micronaut.http.client.HttpClient

DEFAULT_ERROR_TYPE

Constructor Summary

Constructors

Constructor and Description
DefaultHttpClient(LoadBalancer loadBalancer)
DefaultHttpClient(LoadBalancer loadBalancer, HttpClientConfiguration configuration)
DefaultHttpClient(LoadBalancer loadBalancer, HttpClientConfiguration configuration, String contextPath)
DefaultHttpClient(LoadBalancer loadBalancer, HttpClientConfiguration configuration, String contextPath, ThreadFactory threadFactory, NettyClientSslBuilder nettyClientSslBuilder, MediaTypeCodecRegistry codecRegistry, AnnotationMetadataResolver annotationMetadataResolver, HttpClientFilter... filters) Construct a client for the given arguments.
DefaultHttpClient(LoadBalancer loadBalancer, HttpClientConfiguration configuration, String contextPath, ThreadFactory threadFactory, NettyClientSslBuilder nettyClientSslBuilder, MediaTypeCodecRegistry codecRegistry, AnnotationMetadataResolver annotationMetadataResolver, List<HttpClientFilter> filters) Construct a client for the given arguments.
DefaultHttpClient(URL url)
DefaultHttpClient(URL url, HttpClientConfiguration configuration)
DefaultHttpClient(URL url, HttpClientConfiguration configuration, NettyClientSslBuilder nettyClientSslBuilder, MediaTypeCodecRegistry codecRegistry, HttpClientFilter... filters)
DefaultHttpClient(URL url, HttpClientConfiguration configuration, String contextPath)

Method Summary

Modifier and Type	Method and Description
protected <I,O> Publisher<HttpResponse<O>>	applyFilterToResponsePublisher(HttpRequest<?> parentRequest, HttpRequest<I> request, URI requestURI, AtomicReference<HttpRequest> requestWrapper, Publisher<HttpResponse<O>> responsePublisher)
protected <I> io.reactivex.functions.Function<URI,io.reactivex.Flowable<ByteBuffer<?>>>	buildDataStreamPublisher(HttpRequest<I> request)
protected <I,O,E> io.reactivex.functions.Function<URI,Publisher<? extends HttpResponse<O>>>	buildExchangePublisher(HttpRequest<?> parentRequest, HttpRequest<I> request, Argument<O> bodyType, Argument<E> errorType)
protected <I> io.reactivex.functions.Function<URI,io.reactivex.Flowable<HttpResponse<ByteBuffer<?>>>>	buildExchangeStreamPublisher(HttpRequest<I> request)
protected <I,O> io.reactivex.functions.Function<URI,io.reactivex.Flowable<O>>	buildJsonStreamPublisher(HttpRequest<?> parentRequest, HttpRequest<I> request, Argument<O> type)
protected DefaultHttpClient.NettyRequestWriter	buildNettyRequest(MutableHttpRequest request, URI requestURI, MediaType requestContentType, boolean permitsBody)
protected io.netty.handler.ssl.SslContext	buildSslContext(URI uriObject) Builds an SslContext for the given URI if necessary.
protected <I> io.reactivex.Flowable<HttpResponse<Object>>	buildStreamExchange(HttpRequest<?> parentRequest, HttpRequest<I> request, URI requestURI)
void	close() Delegates to LifeCycle.stop().
protected void	closeChannelAsync(io.netty.channel.Channel channel)
protected void	configure(BeanContext beanContext) Configure this client for the active bean context.
protected void	configureProxy(io.netty.channel.ChannelPipeline pipeline, Proxy.Type proxyType, SocketAddress proxyAddress) Configures the HTTP proxy for the pipeline.
protected void	configureProxy(io.netty.channel.ChannelPipeline pipeline, Proxy proxy) Configures the HTTP proxy for the pipeline.
<T extends AutoCloseable> io.reactivex.Flowable<T>	connect(Class<T> clientEndpointType, Map<String,Object> parameters) Connect the given client endpoint type.
<T extends AutoCloseable> io.reactivex.Flowable<T>	connect(Class<T> clientEndpointType, MutableHttpRequest<?> request) Connect the given client endpoint type to the URI over WebSocket.
protected io.netty.channel.nio.NioEventLoopGroup	createEventLoopGroup(HttpClientConfiguration configuration, ThreadFactory threadFactory) Creates the NioEventLoopGroup for this client.
<I> io.reactivex.Flowable<ByteBuffer<?>>	dataStream(HttpRequest<I> request) Request a stream of data where each emitted item is a ByteBuffer instance.
protected io.netty.channel.ChannelFuture	doConnect(io.netty.bootstrap.Bootstrap bootstrap, String host, int port) Creates an initial connection with the given bootstrap and remote host.
protected io.netty.channel.ChannelFuture	doConnect(HttpRequest<?> request, String host, int port, io.netty.handler.ssl.SslContext sslCtx, boolean isStream) Creates an initial connection to the given remote host.
protected io.netty.channel.ChannelFuture	doConnect(HttpRequest<?> request, URI uri, io.netty.handler.ssl.SslContext sslCtx, boolean isStream) Creates an initial connection to the given remote host.
<I> io.reactivex.Flowable<Event<ByteBuffer<?>>>	eventStream(HttpRequest<I> request) Perform an HTTP request and receive data as a stream of SSE Event objects as they become available without blocking.
<I,B> io.reactivex.Flowable<Event<B>>	eventStream(HttpRequest<I> request, Argument<B> eventType) Perform an HTTP request and receive data as a stream of SSE Event objects as they become available without blocking.
<I,O,E> io.reactivex.Flowable<HttpResponse<O>>	exchange(HttpRequest<I> request, Argument<O> bodyType, Argument<E> errorType) Perform an HTTP request for the given request object emitting the full HTTP response from returned Publisher and converting the response body to the specified type.
<I> io.reactivex.Flowable<HttpResponse<ByteBuffer<?>>>	exchangeStream(HttpRequest<I> request) Requests a stream data where each emitted item is a ByteBuffer wrapped in the HttpResponse object (which remains the same for each emitted item).
HttpClientConfiguration	getConfiguration()
protected Object	getLoadBalancerDiscriminator()
org.slf4j.Logger	getLog()
MediaTypeCodecRegistry	getMediaTypeCodecRegistry()
boolean	isRunning()
<I> io.reactivex.Flowable<Map<String,Object>>	jsonStream(HttpRequest<I> request) Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
<I,O> io.reactivex.Flowable<O>	jsonStream(HttpRequest<I> request, Argument<O> type) Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
<I,O> io.reactivex.Flowable<O>	jsonStream(HttpRequest<I> request, Class<O> type) Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
protected List<HttpClientFilter>	resolveFilters(HttpRequest<?> parentRequest, HttpRequest<?> request, URI requestURI) Resolve the filters for the request path.
protected <I> Publisher<URI>	resolveRequestURI(HttpRequest<I> request)
protected URI	resolveRequestURI(URI requestURI)
void	setClientIdentifiers(Set<String> clientIdentifiers) Sets the client identifiers that this client applies to.
void	setClientIdentifiers(String... clientIdentifiers)
void	setMediaTypeCodecRegistry(MediaTypeCodecRegistry mediaTypeCodecRegistry) Sets the MediaTypeCodecRegistry used by this client.
HttpClient	start() Starts the lifecyle component.
HttpClient	stop() Stops the life cycle component.
BlockingHttpClient	toBlocking()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.websocket.RxWebSocketClient

connect, connect

Methods inherited from interface io.micronaut.http.client.RxStreamingHttpClient

create

Methods inherited from interface io.micronaut.http.client.RxHttpClient

exchange, exchange, exchange, exchange, exchange, retrieve, retrieve, retrieve, retrieve, retrieve

Methods inherited from interface io.micronaut.http.client.HttpClient

refresh

Methods inherited from interface io.micronaut.http.client.sse.RxSseClient

eventStream, eventStream, eventStream

Field Detail

HANDLER_AGGREGATOR

protected static final String HANDLER_AGGREGATOR

See Also:

Constant Field Values

HANDLER_CHUNK

protected static final String HANDLER_CHUNK

See Also:

Constant Field Values

HANDLER_STREAM

protected static final String HANDLER_STREAM

See Also:

Constant Field Values

HANDLER_DECODER

protected static final String HANDLER_DECODER

See Also:

Constant Field Values

HANDLER_CONNECT_TTL

protected static final String HANDLER_CONNECT_TTL

See Also:

Constant Field Values

bootstrap

protected final io.netty.bootstrap.Bootstrap bootstrap

group

protected io.netty.channel.EventLoopGroup group

mediaTypeCodecRegistry

protected MediaTypeCodecRegistry mediaTypeCodecRegistry

byteBufferFactory

protected ByteBufferFactory<io.netty.buffer.ByteBufAllocator,io.netty.buffer.ByteBuf> byteBufferFactory

Constructor Detail

DefaultHttpClient

public DefaultHttpClient(@Parameter
                         LoadBalancer loadBalancer,
                         @Parameter
                         HttpClientConfiguration configuration,
                         @Parameter @Nullable
                         String contextPath,
                         @Named(value="netty") @Nullable
                         ThreadFactory threadFactory,
                         NettyClientSslBuilder nettyClientSslBuilder,
                         MediaTypeCodecRegistry codecRegistry,
                         @Nullable
                         AnnotationMetadataResolver annotationMetadataResolver,
                         HttpClientFilter... filters)

Construct a client for the given arguments.

Parameters:

loadBalancer - The LoadBalancer to use for selecting servers

configuration - The HttpClientConfiguration object

contextPath - The base URI to prepend to request uris

threadFactory - The thread factory to use for client threads

nettyClientSslBuilder - The SSL builder

codecRegistry - The MediaTypeCodecRegistry to use for encoding and decoding objects

annotationMetadataResolver - The annotation metadata resolver

filters - The filters to use

DefaultHttpClient

@Inject
public DefaultHttpClient(@Parameter
                                 LoadBalancer loadBalancer,
                                 @Parameter
                                 HttpClientConfiguration configuration,
                                 @Parameter @Nullable
                                 String contextPath,
                                 @Named(value="netty") @Nullable
                                 ThreadFactory threadFactory,
                                 NettyClientSslBuilder nettyClientSslBuilder,
                                 MediaTypeCodecRegistry codecRegistry,
                                 @Nullable
                                 AnnotationMetadataResolver annotationMetadataResolver,
                                 List<HttpClientFilter> filters)

Construct a client for the given arguments.

Parameters:

loadBalancer - The LoadBalancer to use for selecting servers

configuration - The HttpClientConfiguration object

contextPath - The base URI to prepend to request uris

threadFactory - The thread factory to use for client threads

nettyClientSslBuilder - The SSL builder

codecRegistry - The MediaTypeCodecRegistry to use for encoding and decoding objects

annotationMetadataResolver - The annotation metadata resolver

filters - The filters to use

DefaultHttpClient

public DefaultHttpClient(URL url,
                         HttpClientConfiguration configuration,
                         NettyClientSslBuilder nettyClientSslBuilder,
                         MediaTypeCodecRegistry codecRegistry,
                         HttpClientFilter... filters)

Parameters:

url - The URL

configuration - The HttpClientConfiguration object

nettyClientSslBuilder - The SSL builder

codecRegistry - The MediaTypeCodecRegistry to use for encoding and decoding objects

filters - The filters to use

DefaultHttpClient

public DefaultHttpClient(LoadBalancer loadBalancer)

Parameters:

loadBalancer - The LoadBalancer to use for selecting servers

DefaultHttpClient

public DefaultHttpClient(@Parameter
                         URL url)

Parameters:

url - The URL

DefaultHttpClient

public DefaultHttpClient(URL url,
                         HttpClientConfiguration configuration)

Parameters:

url - The URL

configuration - The HttpClientConfiguration object

DefaultHttpClient

public DefaultHttpClient(URL url,
                         HttpClientConfiguration configuration,
                         String contextPath)

Parameters:

url - The URL

configuration - The HttpClientConfiguration object

contextPath - The base URI to prepend to request uris

DefaultHttpClient

public DefaultHttpClient(LoadBalancer loadBalancer,
                         HttpClientConfiguration configuration)

Parameters:

loadBalancer - The LoadBalancer to use for selecting servers

configuration - The HttpClientConfiguration object

DefaultHttpClient

public DefaultHttpClient(LoadBalancer loadBalancer,
                         HttpClientConfiguration configuration,
                         String contextPath)

Parameters:

loadBalancer - The LoadBalancer to use for selecting servers

configuration - The HttpClientConfiguration object

contextPath - The base URI to prepend to request uris

Method Detail

getConfiguration

public HttpClientConfiguration getConfiguration()

Returns:

The configuration used by this client

getLog

public org.slf4j.Logger getLog()

Returns:

The client-specific logger name

start

public HttpClient start()

Description copied from interface: LifeCycle

Starts the lifecyle component.

Specified by:

start in interface LifeCycle<HttpClient>

Returns:

This lifecycle component

isRunning

public boolean isRunning()

Specified by:

isRunning in interface LifeCycle<HttpClient>

Returns:

Whether the component is running

stop

@PreDestroy
public HttpClient stop()

Description copied from interface: LifeCycle

Stops the life cycle component.

Specified by:

stop in interface LifeCycle<HttpClient>

Returns:

This lifecycle component

setClientIdentifiers

public void setClientIdentifiers(Set<String> clientIdentifiers)

Sets the client identifiers that this client applies to. Used to select a subset of HttpClientFilter. The client identifiers are equivalents to the value of Client.id()

Parameters:

clientIdentifiers - The client identifiers

setClientIdentifiers

public void setClientIdentifiers(String... clientIdentifiers)

Parameters:

clientIdentifiers - The client identifiers

See Also:

setClientIdentifiers(Set)

getMediaTypeCodecRegistry

public MediaTypeCodecRegistry getMediaTypeCodecRegistry()

Returns:

The MediaTypeCodecRegistry used by this client

setMediaTypeCodecRegistry

public void setMediaTypeCodecRegistry(MediaTypeCodecRegistry mediaTypeCodecRegistry)

Sets the MediaTypeCodecRegistry used by this client.

Parameters:

mediaTypeCodecRegistry - The registry to use. Should not be null

toBlocking

public BlockingHttpClient toBlocking()

Specified by:

toBlocking in interface HttpClient

Returns:

A blocking HTTP client suitable for testing and non-production scenarios.

eventStream

public <I> io.reactivex.Flowable<Event<ByteBuffer<?>>> eventStream(HttpRequest<I> request)

Description copied from interface: SseClient

Perform an HTTP request and receive data as a stream of SSE Event objects as they become available without blocking.

The downstream Subscriber can regulate demand via the subscription

Specified by:

eventStream in interface RxSseClient

Specified by:

eventStream in interface SseClient

Type Parameters:

I - The request body type

Parameters:

request - The HttpRequest to execute

Returns:

A Publisher that emits an Event with the data represented as a ByteBuffer

eventStream

public <I,B> io.reactivex.Flowable<Event<B>> eventStream(HttpRequest<I> request,
                                                         Argument<B> eventType)

Description copied from interface: SseClient

Perform an HTTP request and receive data as a stream of SSE Event objects as they become available without blocking.

The downstream Subscriber can regulate demand via the subscription

Specified by:

eventStream in interface RxSseClient

Specified by:

eventStream in interface SseClient

Type Parameters:

I - The request body type

B - The event body type

Parameters:

request - The HttpRequest to execute

eventType - The event data type

Returns:

A Publisher that emits an Event with the data represented by the eventType argument

dataStream

public <I> io.reactivex.Flowable<ByteBuffer<?>> dataStream(HttpRequest<I> request)

Description copied from interface: StreamingHttpClient

Request a stream of data where each emitted item is a ByteBuffer instance.

Specified by:

dataStream in interface RxStreamingHttpClient

Specified by:

dataStream in interface StreamingHttpClient

Type Parameters:

I - The request body type

Parameters:

request - The request

Returns:

A Publisher that emits a stream of ByteBuffer instances

exchangeStream

public <I> io.reactivex.Flowable<HttpResponse<ByteBuffer<?>>> exchangeStream(HttpRequest<I> request)

Description copied from interface: StreamingHttpClient

Requests a stream data where each emitted item is a ByteBuffer wrapped in the HttpResponse object (which remains the same for each emitted item).

Specified by:

exchangeStream in interface RxStreamingHttpClient

Specified by:

exchangeStream in interface StreamingHttpClient

Type Parameters:

I - The request body type

Parameters:

request - The HttpRequest

Returns:

A Publisher that emits a stream of ByteBuffer instances wrapped by a HttpResponse

jsonStream

public <I,O> io.reactivex.Flowable<O> jsonStream(HttpRequest<I> request,
                                                 Argument<O> type)

Description copied from interface: StreamingHttpClient

Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.

The downstream Subscriber can regulate demand via the subscription. Incoming data is buffered.

Specified by:

jsonStream in interface RxStreamingHttpClient

Specified by:

jsonStream in interface StreamingHttpClient

Type Parameters:

I - The request body type

O - The response type

Parameters:

request - The HttpRequest to execute

type - The type of object to convert the JSON into

Returns:

A Publisher that emits the full HttpResponse object

jsonStream

public <I> io.reactivex.Flowable<Map<String,Object>> jsonStream(HttpRequest<I> request)

Description copied from interface: StreamingHttpClient

Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.

The downstream Subscriber can regulate demand via the subscription

Specified by:

jsonStream in interface RxStreamingHttpClient

Specified by:

jsonStream in interface StreamingHttpClient

Type Parameters:

I - The request body type

Parameters:

request - The HttpRequest to execute

Returns:

A Publisher that emits the full HttpResponse object

jsonStream

public <I,O> io.reactivex.Flowable<O> jsonStream(HttpRequest<I> request,
                                                 Class<O> type)

Description copied from interface: StreamingHttpClient

Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.

The downstream Subscriber can regulate demand via the subscription

Specified by:

jsonStream in interface RxStreamingHttpClient

Specified by:

jsonStream in interface StreamingHttpClient

Type Parameters:

I - The request body type

O - The response type

Parameters:

request - The HttpRequest to execute

type - The type of object to convert the JSON into

Returns:

A Publisher that emits the full HttpResponse object

exchange

public <I,O,E> io.reactivex.Flowable<HttpResponse<O>> exchange(HttpRequest<I> request,
                                                               Argument<O> bodyType,
                                                               Argument<E> errorType)

Description copied from interface: HttpClient

Perform an HTTP request for the given request object emitting the full HTTP response from returned Publisher and converting the response body to the specified type.

This method will send a Content-Length header and except a content length header the response and is designed for simple non-streaming exchanges of data

By default the exchange Content-Type is application/json, unless otherwise specified in the passed HttpRequest

Specified by:

exchange in interface HttpClient

Specified by:

exchange in interface RxHttpClient

Type Parameters:

I - The request body type

O - The response body type

E - The error type

Parameters:

request - The HttpRequest to execute

bodyType - The body type

errorType - The error type

Returns:

A Publisher that emits the full HttpResponse object

connect

public <T extends AutoCloseable> io.reactivex.Flowable<T> connect(Class<T> clientEndpointType,
                                                                  MutableHttpRequest<?> request)

Description copied from interface: WebSocketClient

Connect the given client endpoint type to the URI over WebSocket.

Specified by:

connect in interface RxWebSocketClient

Specified by:

connect in interface WebSocketClient

Type Parameters:

T - The generic type

Parameters:

clientEndpointType - The endpoint type. Should be a class annotated with ClientWebSocket

request - The original request to establish the connection

Returns:

A Publisher that emits the ClientWebSocket instance

connect

public <T extends AutoCloseable> io.reactivex.Flowable<T> connect(Class<T> clientEndpointType,
                                                                  Map<String,Object> parameters)

Description copied from interface: RxWebSocketClient

Connect the given client endpoint type. Unlike WebSocketClient.connect(Class, URI) this method will the value declared within the ClientWebSocket as the URI and expand the URI with the given parameters.

Specified by:

connect in interface RxWebSocketClient

Specified by:

connect in interface WebSocketClient

Type Parameters:

T - The generic type

Parameters:

clientEndpointType - The endpoint type. Should be a class annotated with ClientWebSocket

parameters - The URI parameters for the endpoint

Returns:

A Publisher that emits the ClientWebSocket instance

close

public void close()

Description copied from interface: LifeCycle

Delegates to LifeCycle.stop().

Specified by:

close in interface LifeCycle<HttpClient>

Specified by:

close in interface WebSocketClient

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

configure

@Inject
protected void configure(BeanContext beanContext)

Configure this client for the active bean context.

Parameters:

beanContext - The bean context

buildExchangeStreamPublisher

protected <I> io.reactivex.functions.Function<URI,io.reactivex.Flowable<HttpResponse<ByteBuffer<?>>>> buildExchangeStreamPublisher(HttpRequest<I> request)

Type Parameters:

I - The input type

Parameters:

request - The request

Returns:

A Function

buildJsonStreamPublisher

protected <I,O> io.reactivex.functions.Function<URI,io.reactivex.Flowable<O>> buildJsonStreamPublisher(HttpRequest<?> parentRequest,
                                                                                                       HttpRequest<I> request,
                                                                                                       Argument<O> type)

Type Parameters:

I - The input type

O - The output type

Parameters:

parentRequest - The parent request

request - The request

type - The type

Returns:

A Function

buildDataStreamPublisher

protected <I> io.reactivex.functions.Function<URI,io.reactivex.Flowable<ByteBuffer<?>>> buildDataStreamPublisher(HttpRequest<I> request)

Type Parameters:

I - The input type

Parameters:

request - The request

Returns:

A Function

buildStreamExchange

protected <I> io.reactivex.Flowable<HttpResponse<Object>> buildStreamExchange(HttpRequest<?> parentRequest,
                                                                              HttpRequest<I> request,
                                                                              URI requestURI)

Type Parameters:

I - The input type

Parameters:

parentRequest - The parent request

request - The request

requestURI - The request URI

Returns:

A Flowable

buildExchangePublisher

protected <I,O,E> io.reactivex.functions.Function<URI,Publisher<? extends HttpResponse<O>>> buildExchangePublisher(HttpRequest<?> parentRequest,
                                                                                                                   HttpRequest<I> request,
                                                                                                                   Argument<O> bodyType,
                                                                                                                   Argument<E> errorType)

Type Parameters:

I - The input type

O - The output type

E - The error type

Parameters:

parentRequest - The parent request

request - The request

bodyType - The body type

errorType - The error type

Returns:

A Function

closeChannelAsync

protected void closeChannelAsync(io.netty.channel.Channel channel)

Parameters:

channel - The channel to close asynchronously

resolveRequestURI

protected <I> Publisher<URI> resolveRequestURI(HttpRequest<I> request)

Type Parameters:

I - The input type

Parameters:

request - The request

Returns:

A Publisher with the resolved URI

resolveRequestURI

protected URI resolveRequestURI(URI requestURI)

Parameters:

requestURI - The request URI

Returns:

A URI that is prepended with the contextPath, if set

getLoadBalancerDiscriminator

protected Object getLoadBalancerDiscriminator()

Returns:

The discriminator to use when selecting a server for the purposes of load balancing (defaults to null)

doConnect

protected io.netty.channel.ChannelFuture doConnect(HttpRequest<?> request,
                                                   URI uri,
                                                   @Nullable
                                                   io.netty.handler.ssl.SslContext sslCtx,
                                                   boolean isStream)
                                            throws HttpClientException

Creates an initial connection to the given remote host.

Parameters:

request - The request

uri - The URI to connect to

sslCtx - The SslContext instance

isStream - Is the connection a stream connection

Returns:

A ChannelFuture

Throws:

HttpClientException - If the URI is invalid

doConnect

protected io.netty.channel.ChannelFuture doConnect(HttpRequest<?> request,
                                                   String host,
                                                   int port,
                                                   @Nullable
                                                   io.netty.handler.ssl.SslContext sslCtx,
                                                   boolean isStream)

Creates an initial connection to the given remote host.

Parameters:

request - The request

host - The host

port - The port

sslCtx - The SslContext instance

isStream - Is the connection a stream connection

Returns:

A ChannelFuture

createEventLoopGroup

protected io.netty.channel.nio.NioEventLoopGroup createEventLoopGroup(HttpClientConfiguration configuration,
                                                                      ThreadFactory threadFactory)

Creates the NioEventLoopGroup for this client.

Parameters:

configuration - The configuration

threadFactory - The thread factory

Returns:

The group

doConnect

protected io.netty.channel.ChannelFuture doConnect(io.netty.bootstrap.Bootstrap bootstrap,
                                                   String host,
                                                   int port)

Creates an initial connection with the given bootstrap and remote host.

Parameters:

bootstrap - The bootstrap instance

host - The host

port - The port

Returns:

The ChannelFuture

buildSslContext

protected io.netty.handler.ssl.SslContext buildSslContext(URI uriObject)

Builds an SslContext for the given URI if necessary.

Parameters:

uriObject - The URI

Returns:

The SslContext instance

resolveFilters

protected List<HttpClientFilter> resolveFilters(@Nullable
                                                HttpRequest<?> parentRequest,
                                                HttpRequest<?> request,
                                                URI requestURI)

Resolve the filters for the request path.

Parameters:

parentRequest - The parent request

request - The path

requestURI - The URI of the request

Returns:

The filters

configureProxy

protected void configureProxy(io.netty.channel.ChannelPipeline pipeline,
                              Proxy proxy)

Configures the HTTP proxy for the pipeline.

Parameters:

pipeline - The pipeline

proxy - The proxy

configureProxy

protected void configureProxy(io.netty.channel.ChannelPipeline pipeline,
                              Proxy.Type proxyType,
                              SocketAddress proxyAddress)

Configures the HTTP proxy for the pipeline.

Parameters:

pipeline - The pipeline

proxyType - The proxy type

proxyAddress - The proxy address

applyFilterToResponsePublisher

protected <I,O> Publisher<HttpResponse<O>> applyFilterToResponsePublisher(HttpRequest<?> parentRequest,
                                                                          HttpRequest<I> request,
                                                                          URI requestURI,
                                                                          AtomicReference<HttpRequest> requestWrapper,
                                                                          Publisher<HttpResponse<O>> responsePublisher)

Type Parameters:

I - The input type

O - The output type

Parameters:

parentRequest - The parent request

request - The request

requestURI - The URI of the request

requestWrapper - The request wrapper

responsePublisher - The response publisher

Returns:

The Publisher for the response

buildNettyRequest

protected DefaultHttpClient.NettyRequestWriter buildNettyRequest(MutableHttpRequest request,
                                                                 URI requestURI,
                                                                 MediaType requestContentType,
                                                                 boolean permitsBody)
                                                          throws io.netty.handler.codec.http.multipart.HttpPostRequestEncoder.ErrorDataEncoderException

Parameters:

request - The request

requestURI - The URI of the request

requestContentType - The request content type

permitsBody - Whether permits body

Returns:

A DefaultHttpClient.NettyRequestWriter

Throws:

HttpPostRequestEncoder.ErrorDataEncoderException - if there is an encoder exception