io.micronaut.http.server.netty

Class NettyHttpServer

java.lang.Object

io.micronaut.http.server.netty.NettyHttpServer

All Implemented Interfaces:

ApplicationContextLifeCycle<EmbeddedServer>, ApplicationContextProvider, LifeCycle, WebSocketSessionRepository, EmbeddedApplication<EmbeddedServer>, EmbeddedServer, Closeable, AutoCloseable

@Singleton
 @Internal
public class NettyHttpServer
extends Object
implements EmbeddedServer, WebSocketSessionRepository

Implements the bootstrap and configuration logic for the Netty implementation of EmbeddedServer.

Since:

1.0

Author:

Graeme Rocher

See Also:

RoutingInBoundHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	HTTP_CHUNKED_HANDLER
static String	HTTP_CODEC
static String	HTTP_COMPRESSOR
static String	HTTP_DECOMPRESSOR
static String	HTTP_KEEP_ALIVE_HANDLER
static String	HTTP_STREAMS_CODEC
static String	MICRONAUT_HANDLER
static String	OUTBOUND_KEY

Constructor Summary

Constructors

Constructor and Description

NettyHttpServer(NettyHttpServerConfiguration serverConfiguration, ApplicationContext applicationContext, Router router, RequestArgumentSatisfier requestArgumentSatisfier, MediaTypeCodecRegistry mediaTypeCodecRegistry, NettyCustomizableResponseTypeHandlerRegistry customizableResponseTypeHandlerRegistry, StaticResourceResolver resourceResolver, ExecutorService ioExecutor, ThreadFactory threadFactory, ExecutorSelector executorSelector, Optional<ServerSslBuilder> serverSslBuilder, List<io.netty.channel.ChannelOutboundHandler> outboundHandlers, EventLoopGroupFactory eventLoopGroupFactory, HttpCompressionStrategy httpCompressionStrategy)

Method Summary

Modifier and Type	Method and Description
void	addChannel(io.netty.channel.Channel channel) Adds a channel to the repository.
protected io.netty.channel.EventLoopGroup	createParentEventLoopGroup()
protected io.netty.bootstrap.ServerBootstrap	createServerBootstrap()
protected io.netty.channel.EventLoopGroup	createWorkerEventLoopGroup()
ApplicationConfiguration	getApplicationConfiguration()
ApplicationContext	getApplicationContext() Resolves the ApplicationContext for this class.
io.netty.channel.group.ChannelGroup	getChannelGroup() Returns the ChannelGroup used to store WebSocketSessions.
String	getHost()
int	getPort()
String	getScheme()
NettyHttpServerConfiguration	getServerConfiguration()
URI	getURI()
URL	getURL()
WebSocketSessionRepository	getWebSocketSessionRepository()
boolean	isKeepAlive() Most servers provide a way to block such that the server doesn't exit, however some require the creation of a keep alive thread.
boolean	isRunning()
void	removeChannel(io.netty.channel.Channel channel) Remove a channel from the repository.
EmbeddedServer	start() Starts the lifecyle component.
EmbeddedServer	stop() Stops the life cycle component.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.runtime.server.EmbeddedServer

isServer

Methods inherited from interface io.micronaut.runtime.EmbeddedApplication

getEnvironment, isForceExit

Methods inherited from interface io.micronaut.context.LifeCycle

close, refresh

Field Detail

HTTP_STREAMS_CODEC

public static final String HTTP_STREAMS_CODEC

See Also:

Constant Field Values

HTTP_CHUNKED_HANDLER

public static final String HTTP_CHUNKED_HANDLER

See Also:

Constant Field Values

HTTP_CODEC

public static final String HTTP_CODEC

See Also:

Constant Field Values

HTTP_COMPRESSOR

public static final String HTTP_COMPRESSOR

See Also:

Constant Field Values

HTTP_DECOMPRESSOR

public static final String HTTP_DECOMPRESSOR

See Also:

Constant Field Values

HTTP_KEEP_ALIVE_HANDLER

public static final String HTTP_KEEP_ALIVE_HANDLER

See Also:

Constant Field Values

MICRONAUT_HANDLER

public static final String MICRONAUT_HANDLER

See Also:

Constant Field Values

OUTBOUND_KEY

public static final String OUTBOUND_KEY

See Also:

Constant Field Values

Constructor Detail

NettyHttpServer

@Inject
public NettyHttpServer(NettyHttpServerConfiguration serverConfiguration,
                               ApplicationContext applicationContext,
                               Router router,
                               RequestArgumentSatisfier requestArgumentSatisfier,
                               MediaTypeCodecRegistry mediaTypeCodecRegistry,
                               NettyCustomizableResponseTypeHandlerRegistry customizableResponseTypeHandlerRegistry,
                               StaticResourceResolver resourceResolver,
                               @Named(value="io")
                               ExecutorService ioExecutor,
                               @Named(value="netty")
                               ThreadFactory threadFactory,
                               ExecutorSelector executorSelector,
                               Optional<ServerSslBuilder> serverSslBuilder,
                               List<io.netty.channel.ChannelOutboundHandler> outboundHandlers,
                               EventLoopGroupFactory eventLoopGroupFactory,
                               HttpCompressionStrategy httpCompressionStrategy)

Parameters:

serverConfiguration - The Netty HTTP server configuration

applicationContext - The application context

router - The router

requestArgumentSatisfier - The request argument satisfier

mediaTypeCodecRegistry - The Media type codec registry

customizableResponseTypeHandlerRegistry - The Netty customizable response type handler registry

resourceResolver - The static resource resolver

ioExecutor - The IO executor

threadFactory - The thread factory

executorSelector - The executor selector

serverSslBuilder - The Netty Server SSL builder

outboundHandlers - The outbound handlers

eventLoopGroupFactory - The EventLoopGroupFactory

httpCompressionStrategy - The http compression strategy

Method Detail

isKeepAlive

public boolean isKeepAlive()

Description copied from interface: EmbeddedServer

Most servers provide a way to block such that the server doesn't exit, however some require the creation of a keep alive thread.

Specified by:

isKeepAlive in interface EmbeddedServer

Returns:

True if the server should be kept alive.

getServerConfiguration

public NettyHttpServerConfiguration getServerConfiguration()

Returns:

The configuration for the server

isRunning

public boolean isRunning()

Specified by:

isRunning in interface LifeCycle

Returns:

Whether the component is running

start

public EmbeddedServer start()

Description copied from interface: LifeCycle

Starts the lifecyle component.

Specified by:

start in interface ApplicationContextLifeCycle<EmbeddedServer>

Specified by:

start in interface LifeCycle

Returns:

This lifecycle component

stop

public EmbeddedServer stop()

Description copied from interface: LifeCycle

Stops the life cycle component.

Specified by:

stop in interface ApplicationContextLifeCycle<EmbeddedServer>

Specified by:

stop in interface LifeCycle

Returns:

This lifecycle component

getPort

public int getPort()

Specified by:

getPort in interface EmbeddedServer

Returns:

The port exposed by the server

getHost

public String getHost()

Specified by:

getHost in interface EmbeddedServer

Returns:

The host of the server

getScheme

public String getScheme()

Specified by:

getScheme in interface EmbeddedServer

Returns:

The scheme of the server (http/https)

getURL

public URL getURL()

Specified by:

getURL in interface EmbeddedServer

Returns:

The full URL to the server

getURI

public URI getURI()

Specified by:

getURI in interface EmbeddedServer

Returns:

The full URI to the server

getApplicationContext

public ApplicationContext getApplicationContext()

Description copied from interface: ApplicationContextProvider

Resolves the ApplicationContext for this class.

Specified by:

getApplicationContext in interface ApplicationContextProvider

Specified by:

getApplicationContext in interface EmbeddedApplication<EmbeddedServer>

Returns:

The ApplicationContext for the server

getApplicationConfiguration

public ApplicationConfiguration getApplicationConfiguration()

Specified by:

getApplicationConfiguration in interface EmbeddedApplication<EmbeddedServer>

Returns:

The ApplicationConfiguration instance

createParentEventLoopGroup

protected io.netty.channel.EventLoopGroup createParentEventLoopGroup()

Returns:

The parent event loop group

createWorkerEventLoopGroup

protected io.netty.channel.EventLoopGroup createWorkerEventLoopGroup()

Returns:

The worker event loop group

createServerBootstrap

protected io.netty.bootstrap.ServerBootstrap createServerBootstrap()

Returns:

The Netty server bootstrap

addChannel

public void addChannel(io.netty.channel.Channel channel)

Description copied from interface: WebSocketSessionRepository

Adds a channel to the repository.

Specified by:

addChannel in interface WebSocketSessionRepository

Parameters:

channel - The channel

removeChannel

public void removeChannel(io.netty.channel.Channel channel)

Description copied from interface: WebSocketSessionRepository

Remove a channel from the repository.

Specified by:

removeChannel in interface WebSocketSessionRepository

Parameters:

channel - The channel

getChannelGroup

public io.netty.channel.group.ChannelGroup getChannelGroup()

Description copied from interface: WebSocketSessionRepository

Returns the ChannelGroup used to store WebSocketSessions.

Specified by:

getChannelGroup in interface WebSocketSessionRepository

Returns:

A ChannelGroup

getWebSocketSessionRepository

public WebSocketSessionRepository getWebSocketSessionRepository()

Returns:

NettyHttpServer which implements WebSocketSessionRepository