Package io.micronaut.http.client.jdk

Class JdkBlockingHttpClient

java.lang.Object

io.micronaut.http.client.jdk.JdkBlockingHttpClient

All Implemented Interfaces:

BlockingHttpClient, Closeable, AutoCloseable

@Internal
public class JdkBlockingHttpClient
extends Object
implements BlockingHttpClient

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

Constructor Summary

Constructors

Constructor

Description

JdkBlockingHttpClient(LoadBalancer loadBalancer, HttpVersionSelection httpVersion, HttpClientConfiguration configuration, 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)

Method Summary

Modifier and Type	Method	Description
protected <I, R extends HttpResponse<?>> Publisher<R>	applyFilterToResponsePublisher(HttpRequest<I> request, URI requestURI, Publisher<R> responsePublisher)
void	close()
<I, O, E> HttpResponse<O>	exchange(HttpRequest<I> request, @Nullable Argument<O> bodyType, @Nullable 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()
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)

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.BlockingHttpClient

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

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

JdkBlockingHttpClient

public JdkBlockingHttpClient(LoadBalancer loadBalancer,
 HttpVersionSelection httpVersion,
 HttpClientConfiguration configuration,
 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)

Method Details

exchange

public <I,
O,
E> HttpResponse<O> exchange(@NonNull
 HttpRequest<I> request,
 @Nullable
 @Nullable Argument<O> bodyType,
 @Nullable
 @Nullable Argument<E> errorType)

Description copied from interface: BlockingHttpClient

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 BlockingHttpClient

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:

The full HttpResponse object

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

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)