reactor.netty.http.server

Class HttpServer

java.lang.Object

reactor.netty.http.server.HttpServer

public abstract class HttpServer
extends java.lang.Object

An HttpServer allows to build in a safe immutable way an HTTP server that is materialized and connecting when bind(TcpServer) is ultimately called.

Internally, materialization happens in three phases, first tcpConfiguration() is called to retrieve a ready to use TcpServer, then tcpConfiguration() ()} retrieve a usable TcpServer for the final bind(TcpServer) is called.

Examples:

 
 HttpServer.create()
           .host("0.0.0.0")
           .handle((req, res) -> res.sendString(Flux.just("hello"))
           .bind()
           .block();
 

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
HttpServer()

Method Summary

Modifier and Type	Method and Description
Mono<? extends DisposableServer>	bind() Bind the HttpServer and return a Mono of DisposableServer.
protected abstract Mono<? extends DisposableServer>	bind(TcpServer b) Bind the HttpServer and return a Mono of DisposableServer
DisposableServer	bindNow() Start a Server in a blocking fashion, and wait for it to finish initializing.
DisposableServer	bindNow(java.time.Duration timeout) Start a Server in a blocking fashion, and wait for it to finish initializing.
void	bindUntilJavaShutdown(java.time.Duration timeout, java.util.function.Consumer<DisposableServer> onStart) Start a Server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the client/server.
HttpServer	compress() Enable GZip response compression if the client request presents accept encoding headers.
HttpServer	compress(java.util.function.BiPredicate<HttpServerRequest,HttpServerResponse> predicate) Enable GZip response compression if the client request presents accept encoding headers and the passed Predicate matches.
HttpServer	compress(int minResponseSize) Enable GZip response compression if the client request presents accept encoding headers AND the response reaches a minimum threshold
static HttpServer	create() Prepare a HttpServer
HttpServer	forwarded() Enable support for the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection.
static HttpServer	from(TcpServer tcpServer) Prepare a HttpServer
HttpServer	handle(java.util.function.BiFunction<? super HttpServerRequest,? super HttpServerResponse,? extends Publisher<java.lang.Void>> handler) Attach an IO handler to react on connected server
HttpServer	host(java.lang.String host) The host to which this server should bind.
HttpServer	httpRequestDecoder(java.util.function.Function<HttpRequestDecoderSpec,HttpRequestDecoderSpec> requestDecoderOptions) Configure the HttpServerCodec's request decoding options.
HttpServer	noCompression() Disable gzip compression
HttpServer	noForwarded() Disable support for the "Forwarded" and "X-Forwarded-*" HTTP request headers.
HttpServer	observe(ConnectionObserver observer) Setup all lifecycle callbacks called on or after each child Channel has been connected and after it has been disconnected.
HttpServer	port(int port) The port to which this server should bind.
HttpServer	protocol(HttpProtocol... supportedProtocols) The HTTP protocol to support.
HttpServer	route(java.util.function.Consumer<? super HttpServerRoutes> routesBuilder) Define routes for the server through the provided HttpServerRoutes builder.
HttpServer	secure(java.util.function.Consumer<? super SslProvider.SslContextSpec> sslProviderBuilder) Apply an SSL configuration customization via the passed builder.
protected TcpServer	tcpConfiguration() Materialize a TcpServer from the parent HttpServer chain to use with bind(TcpServer) or separately
HttpServer	tcpConfiguration(java.util.function.Function<? super TcpServer,? extends TcpServer> tcpMapper) Apply ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
HttpServer	wiretap() Apply a wire logger configuration using HttpServer category and DEBUG logger level

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpServer

public HttpServer()

Method Detail

create

public static HttpServer create()

Prepare a HttpServer

Returns:

a HttpServer

from

public static HttpServer from(TcpServer tcpServer)

Prepare a HttpServer

Returns:

a HttpServer

bind

public final Mono<? extends DisposableServer> bind()

Bind the HttpServer and return a Mono of DisposableServer. If Mono is cancelled, the underlying binding will be aborted. Once the DisposableServer has been emitted and is not necessary anymore, disposing main server loop must be done by the user via DisposableChannel.dispose(). If update configuration phase fails, a Mono.error(Throwable) will be returned

Returns:

a Mono of DisposableServer

bindNow

public final DisposableServer bindNow()

Start a Server in a blocking fashion, and wait for it to finish initializing. The returned DisposableServer offers simple server API, including to DisposableChannel.disposeNow() shut it down in a blocking fashion.

Returns:

a Connection

bindNow

public final DisposableServer bindNow(java.time.Duration timeout)

Start a Server in a blocking fashion, and wait for it to finish initializing. The returned DisposableServer offers simple server API, including to DisposableChannel.disposeNow() shut it down in a blocking fashion.

Parameters:

timeout - max startup timeout

Returns:

a DisposableServer

bindUntilJavaShutdown

public final void bindUntilJavaShutdown(java.time.Duration timeout,
                                        @Nullable
                                        java.util.function.Consumer<DisposableServer> onStart)

Start a Server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the client/server. Since most servers will be long-lived, this is more adapted to running a server out of a main method, only allowing shutdown of the servers through sigkill.

Note that a JVM shutdown hook is added by this method in order to properly disconnect the client/server upon receiving a sigkill signal.

Parameters:

timeout - a timeout for server shutdown

onStart - an optional callback on server start

compress

public final HttpServer compress()

Enable GZip response compression if the client request presents accept encoding headers.

Returns:

a new HttpServer

compress

public final HttpServer compress(int minResponseSize)

Enable GZip response compression if the client request presents accept encoding headers AND the response reaches a minimum threshold

Parameters:

minResponseSize - compression is performed once response size exceeds given value in byte

Returns:

a new HttpServer

compress

public final HttpServer compress(java.util.function.BiPredicate<HttpServerRequest,HttpServerResponse> predicate)

Enable GZip response compression if the client request presents accept encoding headers and the passed Predicate matches.

note the passed HttpServerRequest and HttpServerResponse should be considered read-only and the implement SHOULD NOT consume or write the request/response in this predicate.

Parameters:

predicate - that returns true to compress the response.

Returns:

a new HttpServer

forwarded

public final HttpServer forwarded()

Enable support for the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection.

Returns:

a new HttpServer

host

public final HttpServer host(java.lang.String host)

The host to which this server should bind.

Parameters:

host - The host to bind to.

Returns:

a new HttpServer

handle

public final HttpServer handle(java.util.function.BiFunction<? super HttpServerRequest,? super HttpServerResponse,? extends Publisher<java.lang.Void>> handler)

Attach an IO handler to react on connected server

Parameters:

handler - an IO handler that can dispose underlying connection when Publisher terminates. Only the first registered handler will subscribe to the returned Publisher while other will immediately cancel given a same Connection

Returns:

a new HttpServer

httpRequestDecoder

public final HttpServer httpRequestDecoder(java.util.function.Function<HttpRequestDecoderSpec,HttpRequestDecoderSpec> requestDecoderOptions)

Configure the HttpServerCodec's request decoding options.

Parameters:

requestDecoderOptions - a function to mutate the provided Http request decoder options

Returns:

a new HttpServer

noCompression

public final HttpServer noCompression()

Disable gzip compression

Returns:

a new HttpServer

noForwarded

public final HttpServer noForwarded()

Disable support for the "Forwarded" and "X-Forwarded-*" HTTP request headers.

Returns:

a new HttpServer

observe

public final HttpServer observe(ConnectionObserver observer)

Setup all lifecycle callbacks called on or after each child Channel has been connected and after it has been disconnected.

Parameters:

observer - a consumer observing state changes

Returns:

a new HttpServer

protocol

public final HttpServer protocol(HttpProtocol... supportedProtocols)

The HTTP protocol to support. Default is HttpProtocol.HTTP11.

Parameters:

supportedProtocols - The various HttpProtocol this server will support

Returns:

a new HttpServer

port

public final HttpServer port(int port)

The port to which this server should bind.

Parameters:

port - The port to bind to.

Returns:

a new HttpServer

secure

public final HttpServer secure(java.util.function.Consumer<? super SslProvider.SslContextSpec> sslProviderBuilder)

Apply an SSL configuration customization via the passed builder. The builder will produce the SslContext to be passed to with a default value of 10 seconds handshake timeout unless the environment property reactor.netty.tcp.sslHandshakeTimeout is set. If SelfSignedCertificate needs to be used, the sample below can be used. Note that SelfSignedCertificate should not be used in production.

 
     SelfSignedCertificate cert = new SelfSignedCertificate();
     SslContextBuilder sslContextBuilder =
             SslContextBuilder.forServer(cert.certificate(), cert.privateKey());
     secure(sslContextSpec -> sslContextSpec.sslContext(sslContextBuilder));
 

Parameters:

sslProviderBuilder - builder callback for further customization of SslContext.

Returns:

a new HttpServer

route

public final HttpServer route(java.util.function.Consumer<? super HttpServerRoutes> routesBuilder)

Define routes for the server through the provided HttpServerRoutes builder.

Parameters:

routesBuilder - provides a route builder to be mutated in order to define routes.

Returns:

a new HttpServer starting the router on subscribe

tcpConfiguration

public final HttpServer tcpConfiguration(java.util.function.Function<? super TcpServer,? extends TcpServer> tcpMapper)

Apply ServerBootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.

Configuration will apply during tcpConfiguration() phase.

Parameters:

tcpMapper - A tcpServer mapping function to update tcp configuration and return an enriched tcp server to use.

Returns:

a new HttpServer

wiretap

public final HttpServer wiretap()

Apply a wire logger configuration using HttpServer category and DEBUG logger level

Returns:

a new HttpServer

bind

protected abstract Mono<? extends DisposableServer> bind(TcpServer b)

Bind the HttpServer and return a Mono of DisposableServer

Parameters:

b - the TcpServer to bind

Returns:

a Mono of DisposableServer

tcpConfiguration

protected TcpServer tcpConfiguration()

Materialize a TcpServer from the parent HttpServer chain to use with bind(TcpServer) or separately

Returns:

a configured TcpServer