reactor.netty.udp

Class UdpServer

java.lang.Object

reactor.netty.udp.UdpServer

public abstract class UdpServer
extends Object

A UdpServer allows to build in a safe immutable way a UDP server that is materialized and connecting when bind(Bootstrap) is ultimately called.

Internally, materialization happens in two phases, first configure() is called to retrieve a ready to use Bootstrap then bind(Bootstrap) is called.

Example:

 
 UdpServer.create()
          .doOnBind(startMetrics)
          .doOnBound(startedMetrics)
          .doOnUnbind(stopMetrics)
          .host("127.0.0.1")
          .port(1234)
          .bind()
          .block()
 

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
UdpServer()

Method Summary

Modifier and Type	Method and Description
UdpServer	addressSupplier(java.util.function.Supplier<? extends SocketAddress> bindingAddressSupplier) The address to which this server should bind on subscribe.
<T> UdpServer	attr(AttributeKey<T> key, T value) Inject default attribute to the future child Channel connections.
Mono<? extends Connection>	bind() Bind the UdpServer and return a Mono of Connection.
protected abstract Mono<? extends Connection>	bind(Bootstrap b) Bind the UdpServer and return a Mono of Connection
Connection	bindNow(java.time.Duration timeout) Start a Server in a blocking fashion, and wait for it to finish initializing.
UdpServer	bootstrap(java.util.function.Function<? super Bootstrap,? extends Bootstrap> bootstrapMapper) Apply Bootstrap configuration given mapper taking currently configured one and returning a new one to be ultimately used for socket binding.
protected Bootstrap	configure() Materialize a Bootstrap from the parent UdpServer chain to use with bind(Bootstrap) or separately
static UdpServer	create() Prepare a UdpServer
UdpServer	doOnBind(java.util.function.Consumer<? super Bootstrap> doOnBind) Setup a callback called when Channel is about to bind.
UdpServer	doOnBound(java.util.function.Consumer<? super Connection> doOnBound) Setup a callback called when Channel is bound.
UdpServer	doOnLifecycle(java.util.function.Consumer<? super Bootstrap> onBind, java.util.function.Consumer<? super Connection> onBound, java.util.function.Consumer<? super Connection> onUnbound) Setup all lifecycle callbacks called on or after Channel has been bound and after it has been unbound.
UdpServer	doOnUnbound(java.util.function.Consumer<? super Connection> doOnUnbound) Setup a callback called when Channel is unbound.
UdpServer	handle(java.util.function.BiFunction<? super UdpInbound,? super UdpOutbound,? extends Publisher<Void>> handler) Attach an IO handler to react on connected client
UdpServer	host(String host) The host to which this server should bind.
UdpServer	metrics(boolean metricsEnabled) Specifies whether the metrics are enabled on the UdpServer.
UdpServer	metrics(boolean metricsEnabled, ChannelMetricsRecorder recorder) Specifies whether the metrics are enabled on the UdpServer.
UdpServer	observe(ConnectionObserver observer) Setup all lifecycle callbacks called on or after Channel has been connected and after it has been disconnected.
<T> UdpServer	option(ChannelOption<T> key, T value) Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE.
UdpServer	port(int port) The port to which this server should bind.
UdpServer	runOn(EventLoopGroup eventLoopGroup) Run IO loops on the given EventLoopGroup.
UdpServer	runOn(LoopResources channelResources) Run IO loops on a supplied EventLoopGroup from the LoopResources container.
UdpServer	runOn(LoopResources channelResources, boolean preferNative) Run IO loops on a supplied EventLoopGroup from the LoopResources container.
UdpServer	runOn(LoopResources channelResources, InternetProtocolFamily family) Run IO loops on a supplied EventLoopGroup from the LoopResources container.
UdpServer	wiretap(boolean enable) Apply or remove a wire logger configuration using UdpServer category and DEBUG logger level
UdpServer	wiretap(String category) Apply a wire logger configuration using the specified category and DEBUG logger level
UdpServer	wiretap(String category, LogLevel level) Apply a wire logger configuration using the specified category and logger level

Methods inherited from class java.lang.Object

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

Constructor Detail

UdpServer

public UdpServer()

Method Detail

create

public static UdpServer create()

Prepare a UdpServer

Returns:

a UdpServer

addressSupplier

public final UdpServer addressSupplier(java.util.function.Supplier<? extends SocketAddress> bindingAddressSupplier)

The address to which this server should bind on subscribe.

Parameters:

bindingAddressSupplier - A supplier of the address to bind to.

Returns:

a new UdpServer

attr

public final <T> UdpServer attr(AttributeKey<T> key,
                                T value)

Inject default attribute to the future child Channel connections. They will be available via AttributeMap.attr(AttributeKey).

Type Parameters:

T - the attribute type

Parameters:

key - the attribute key

value - the attribute value

Returns:

a new UdpServer

See Also:

AbstractBootstrap.attr(AttributeKey, Object)

bootstrap

public final UdpServer bootstrap(java.util.function.Function<? super Bootstrap,? extends Bootstrap> bootstrapMapper)

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

Configuration will apply during configure() phase.

Parameters:

bootstrapMapper - A bootstrap mapping function to update configuration and return an enriched bootstrap.

Returns:

a new UdpServer

bind

public final Mono<? extends Connection> bind()

Bind the UdpServer and return a Mono of Connection. If Mono is cancelled, the underlying binding will be aborted. Once the Connection 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 Connection

bindNow

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

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

Parameters:

timeout - max startup timeout

Returns:

a Connection

doOnBind

public final UdpServer doOnBind(java.util.function.Consumer<? super Bootstrap> doOnBind)

Setup a callback called when Channel is about to bind.

Parameters:

doOnBind - a consumer observing server start event

Returns:

a new UdpServer

doOnBound

public final UdpServer doOnBound(java.util.function.Consumer<? super Connection> doOnBound)

Setup a callback called when Channel is bound.

Parameters:

doOnBound - a consumer observing server started event

Returns:

a new UdpServer

doOnUnbound

public final UdpServer doOnUnbound(java.util.function.Consumer<? super Connection> doOnUnbound)

Setup a callback called when Channel is unbound.

Parameters:

doOnUnbound - a consumer observing server stop event

Returns:

a new UdpServer

doOnLifecycle

public final UdpServer doOnLifecycle(java.util.function.Consumer<? super Bootstrap> onBind,
                                     java.util.function.Consumer<? super Connection> onBound,
                                     java.util.function.Consumer<? super Connection> onUnbound)

Setup all lifecycle callbacks called on or after Channel has been bound and after it has been unbound.

Parameters:

onBind - a consumer observing server start event

onBound - a consumer observing server started event

onUnbound - a consumer observing server stop event

Returns:

a new UdpServer

handle

public final UdpServer handle(java.util.function.BiFunction<? super UdpInbound,? super UdpOutbound,? extends Publisher<Void>> handler)

Attach an IO handler to react on connected client

Parameters:

handler - an IO handler that can dispose underlying connection when Publisher terminates.

Returns:

a new UdpServer

host

public final UdpServer host(String host)

The host to which this server should bind.

Parameters:

host - The host to bind to.

Returns:

a new UdpServer

observe

public final UdpServer observe(ConnectionObserver observer)

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

Parameters:

observer - a consumer observing state changes

Returns:

a new UdpServer

option

public final <T> UdpServer option(ChannelOption<T> key,
                                  T value)

Set a ChannelOption value for low level connection settings like SO_TIMEOUT or SO_KEEPALIVE. This will apply to each new channel from remote peer.

Type Parameters:

T - the option type

Parameters:

key - the option key

value - the option value

Returns:

new UdpServer

See Also:

AbstractBootstrap.option(ChannelOption, Object)

port

public final UdpServer port(int port)

The port to which this server should bind.

Parameters:

port - The port to bind to.

Returns:

a new UdpServer

runOn

public final UdpServer runOn(EventLoopGroup eventLoopGroup)

Run IO loops on the given EventLoopGroup.

Parameters:

eventLoopGroup - an eventLoopGroup to share

Returns:

a new UdpServer

runOn

public final UdpServer runOn(LoopResources channelResources)

Run IO loops on a supplied EventLoopGroup from the LoopResources container. Will prefer native (epoll/kqueue) implementation if available unless the environment property reactor.netty.native is set to false.

Parameters:

channelResources - a LoopResources accepting native runtime expectation and returning an eventLoopGroup

Returns:

a new UdpServer

runOn

public final UdpServer runOn(LoopResources channelResources,
                             boolean preferNative)

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

Parameters:

channelResources - a LoopResources accepting native runtime expectation and returning an eventLoopGroup.

preferNative - Should the connector prefer native (epoll/kqueue) if available.

Returns:

a new UdpServer

runOn

public final UdpServer runOn(LoopResources channelResources,
                             InternetProtocolFamily family)

Run IO loops on a supplied EventLoopGroup from the LoopResources container.

Parameters:

channelResources - a LoopResources accepting native runtime expectation and returning an eventLoopGroup.

family - a specific InternetProtocolFamily to run with

Returns:

a new UdpServer

metrics

public final UdpServer metrics(boolean metricsEnabled)

Specifies whether the metrics are enabled on the UdpServer. All generated metrics are registered in the Micrometer MeterRegistry, assuming Micrometer is on the classpath. if name is NULL - reactor.netty.udp.server will be used as a name.

Parameters:

metricsEnabled - if true enables the metrics on the server.

Returns:

a new UdpServer

metrics

public final UdpServer metrics(boolean metricsEnabled,
                               ChannelMetricsRecorder recorder)

Specifies whether the metrics are enabled on the UdpServer. All generated metrics are provided to the specified recorder.

Parameters:

metricsEnabled - if true enables the metrics on the server.

recorder - the ChannelMetricsRecorder

Returns:

a new UdpServer

wiretap

public final UdpServer wiretap(boolean enable)

Apply or remove a wire logger configuration using UdpServer category and DEBUG logger level

Parameters:

enable - Specifies whether the wire logger configuration will be added to the pipeline

Returns:

a new UdpServer

wiretap

public final UdpServer wiretap(String category)

Apply a wire logger configuration using the specified category and DEBUG logger level

Parameters:

category - the logger category

Returns:

a new UdpServer

wiretap

public final UdpServer wiretap(String category,
                               LogLevel level)

Apply a wire logger configuration using the specified category and logger level

Parameters:

category - the logger category

level - the logger level

Returns:

a new UdpServer

configure

protected Bootstrap configure()

Materialize a Bootstrap from the parent UdpServer chain to use with bind(Bootstrap) or separately

Returns:

a configured Bootstrap

bind

protected abstract Mono<? extends Connection> bind(Bootstrap b)

Bind the UdpServer and return a Mono of Connection

Parameters:

b - the Bootstrap to bind

Returns:

a Mono of Connection