Package io.micronaut.http.client.jdk

Class DefaultJdkHttpClient

java.lang.Object

io.micronaut.http.client.jdk.DefaultJdkHttpClient

All Implemented Interfaces:

LifeCycle<HttpClient>, HttpClient, JdkHttpClient, Closeable, AutoCloseable

@Internal
public class DefaultJdkHttpClient
extends Object
implements JdkHttpClient

HttpClient implementation for java.net.http.* HTTP Client.

Since:

4.0.0

Author:

Sergio del Amo

Field Summary

Fields

Modifier and Type	Field	Description
protected final HttpClient	client
protected final List<HttpFilterResolver.FilterEntry>	clientFilterEntries
protected final String	clientId
protected final HttpClientConfiguration	configuration
protected final String	contextPath
protected final ConversionService	conversionService
protected final CookieDecoder	cookieDecoder
protected final CookieManager	cookieManager
protected final HttpClientFilterResolver<ClientFilterResolutionContext>	filterResolver
static final String	H2C_ERROR_MESSAGE
static final String	H3_ERROR_MESSAGE
protected final HttpVersionSelection	httpVersion
protected final LoadBalancer	loadBalancer
protected final org.slf4j.Logger	log
protected MediaTypeCodecRegistry	mediaTypeCodecRegistry
protected MessageBodyHandlerRegistry	messageBodyHandlerRegistry
protected final RequestBinderRegistry	requestBinderRegistry
protected final JdkClientSslBuilder	sslBuilder
static final String	WEIRD_ALPN_ERROR_MESSAGE

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

DEFAULT_ERROR_TYPE

Constructor Summary

Constructors

Constructor	Description
DefaultJdkHttpClient(@Nullable LoadBalancer loadBalancer, HttpVersionSelection httpVersion, @NonNull HttpClientConfiguration configuration, @Nullable String contextPath, @Nullable HttpClientFilterResolver<ClientFilterResolutionContext> filterResolver, @Nullable List<HttpFilterResolver.FilterEntry> clientFilterEntries, MediaTypeCodecRegistry mediaTypeCodecRegistry, MessageBodyHandlerRegistry messageBodyHandlerRegistry, RequestBinderRegistry requestBinderRegistry, String clientId, ConversionService conversionService, JdkClientSslBuilder sslBuilder, CookieDecoder cookieDecoder)
DefaultJdkHttpClient(URI uri, ConversionService conversionService)
DefaultJdkHttpClient(URI uri, HttpClientConfiguration configuration, MediaTypeCodecRegistry mediaTypeCodecRegistry, MessageBodyHandlerRegistry messageBodyHandlerRegistry, ConversionService conversionService)

Method Summary

Modifier and Type	Method	Description
protected <I, R extends HttpResponse<?>> Publisher<R>	applyFilterToResponsePublisher(HttpRequest<I> request, URI requestURI, Publisher<R> responsePublisher)
<I, O, E> Publisher<HttpResponse<O>>	exchange(@NonNull HttpRequest<I> request, @NonNull Argument<O> bodyType, @NonNull 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.
protected <I, O> reactor.core.publisher.Flux<HttpResponse<O>>	exchangeImpl(HttpRequest<I> request, @Nullable Argument<O> bodyType)
MediaTypeCodecRegistry	getMediaTypeCodecRegistry()
MessageBodyHandlerRegistry	getMessageBodyHandlerRegistry()
boolean	isRunning()
protected <I> reactor.core.publisher.Mono<HttpRequest>	mapToHttpRequest(HttpRequest<I> request, @Nullable Argument<?> bodyType)	Convert the Micronaut request to a JDK request.
protected reactor.core.publisher.Mono<URI>	resolveRequestUri(HttpRequest<?> request)
protected <O> @NonNull HttpResponse<O>	response(HttpResponse<byte[]> netResponse, @NonNull Argument<O> bodyType)	Convert the JDK response to a Micronaut response.
protected <O> Publisher<HttpResponse<O>>	responsePublisher(HttpRequest<?> request, @Nullable Argument<O> bodyType)
void	setMediaTypeCodecRegistry(MediaTypeCodecRegistry mediaTypeCodecRegistry)
void	setMessageBodyHandlerRegistry(MessageBodyHandlerRegistry messageBodyHandlerRegistry)
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.http.client.HttpClient

exchange, exchange, exchange, exchange, exchange, refresh, retrieve, retrieve, retrieve, retrieve, retrieve

Methods inherited from interface io.micronaut.context.LifeCycle

close, start, stop

Field Details

H2C_ERROR_MESSAGE

public static final String H2C_ERROR_MESSAGE

See Also:

• Constant Field Values

H3_ERROR_MESSAGE

public static final String H3_ERROR_MESSAGE

See Also:

• Constant Field Values

WEIRD_ALPN_ERROR_MESSAGE

public static final String WEIRD_ALPN_ERROR_MESSAGE

See Also:

• Constant Field Values

loadBalancer

protected final LoadBalancer loadBalancer

httpVersion

protected final HttpVersionSelection httpVersion

configuration

protected final HttpClientConfiguration configuration

contextPath

protected final String contextPath

client

protected final HttpClient client

cookieManager

protected final CookieManager cookieManager

requestBinderRegistry

protected final RequestBinderRegistry requestBinderRegistry

clientId

protected final String clientId

conversionService

protected final ConversionService conversionService

sslBuilder

protected final JdkClientSslBuilder sslBuilder

log

protected final org.slf4j.Logger log

filterResolver

protected final HttpClientFilterResolver<ClientFilterResolutionContext> filterResolver

clientFilterEntries

protected final List<HttpFilterResolver.FilterEntry> clientFilterEntries

cookieDecoder

protected final CookieDecoder cookieDecoder

mediaTypeCodecRegistry

protected MediaTypeCodecRegistry mediaTypeCodecRegistry

messageBodyHandlerRegistry

protected MessageBodyHandlerRegistry messageBodyHandlerRegistry

Constructor Details

DefaultJdkHttpClient

public DefaultJdkHttpClient(@Nullable
 @Nullable LoadBalancer loadBalancer,
 HttpVersionSelection httpVersion,
 @NonNull
 @NonNull HttpClientConfiguration configuration,
 @Nullable
 @Nullable String contextPath,
 @Nullable
 @Nullable HttpClientFilterResolver<ClientFilterResolutionContext> filterResolver,
 @Nullable
 @Nullable List<HttpFilterResolver.FilterEntry> clientFilterEntries,
 MediaTypeCodecRegistry mediaTypeCodecRegistry,
 MessageBodyHandlerRegistry messageBodyHandlerRegistry,
 RequestBinderRegistry requestBinderRegistry,
 String clientId,
 ConversionService conversionService,
 JdkClientSslBuilder sslBuilder,
 CookieDecoder cookieDecoder)

DefaultJdkHttpClient

public DefaultJdkHttpClient(URI uri,
 ConversionService conversionService)

DefaultJdkHttpClient

public DefaultJdkHttpClient(URI uri,
 HttpClientConfiguration configuration,
 MediaTypeCodecRegistry mediaTypeCodecRegistry,
 MessageBodyHandlerRegistry messageBodyHandlerRegistry,
 ConversionService conversionService)

Method Details

toBlocking

public BlockingHttpClient toBlocking()

Specified by:

toBlocking in interface HttpClient

Returns:

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

exchange

public <I,
O,
E> Publisher<HttpResponse<O>> exchange(@NonNull
 @NonNull HttpRequest<I> request,
 @NonNull
 @NonNull Argument<O> bodyType,
 @NonNull
 @NonNull 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

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

isRunning

public boolean isRunning()

Specified by:

isRunning in interface LifeCycle<HttpClient>

Returns:

Whether the component is running

getMediaTypeCodecRegistry

public MediaTypeCodecRegistry getMediaTypeCodecRegistry()

Returns:

The MediaTypeCodecRegistry

setMediaTypeCodecRegistry

public void setMediaTypeCodecRegistry(MediaTypeCodecRegistry mediaTypeCodecRegistry)

Parameters:

mediaTypeCodecRegistry - The MediaTypeCodecRegistry

getMessageBodyHandlerRegistry

public MessageBodyHandlerRegistry getMessageBodyHandlerRegistry()

Returns:

The MessageBodyHandlerRegistry

setMessageBodyHandlerRegistry

public void setMessageBodyHandlerRegistry(MessageBodyHandlerRegistry messageBodyHandlerRegistry)

Parameters:

messageBodyHandlerRegistry - The MessageBodyHandlerRegistry

mapToHttpRequest

protected <I>
reactor.core.publisher.Mono<HttpRequest> mapToHttpRequest(@NonNull
 HttpRequest<I> request,
 @Nullable
 @Nullable Argument<?> bodyType)

Convert the Micronaut request to a JDK request.

Type Parameters:

I - The body type

Parameters:

request - The Micronaut request object

bodyType - The body type

Returns:

A JDK request object

resolveRequestUri

protected reactor.core.publisher.Mono<URI> resolveRequestUri(HttpRequest<?> request)

response

@NonNull
protected <O> @NonNull HttpResponse<O> response(@NonNull
 HttpResponse<byte[]> netResponse,
 @NonNull
 @NonNull Argument<O> bodyType)

Convert the JDK response to a Micronaut response.

Type Parameters:

O - The body type

Parameters:

netResponse - The JDK response

bodyType - The body type

Returns:

A Micronaut response

exchangeImpl

protected <I,
O>
reactor.core.publisher.Flux<HttpResponse<O>> exchangeImpl(@NonNull
 HttpRequest<I> request,
 @Nullable
 @Nullable Argument<O> bodyType)

applyFilterToResponsePublisher

protected <I,
R extends HttpResponse<?>>
Publisher<R> applyFilterToResponsePublisher(HttpRequest<I> request,
 URI requestURI,
 Publisher<R> responsePublisher)

responsePublisher

protected <O> Publisher<HttpResponse<O>> responsePublisher(@NonNull
 HttpRequest<?> request,
 @Nullable
 @Nullable Argument<O> bodyType)