Module stincmale.server

Package stincmale.server.netty4

Class NettyServer

java.lang.Object

stincmale.server.AbstractServer

stincmale.server.netty4.NettyServer

All Implemented Interfaces:

Server

@ThreadSafe
public class NettyServer
extends AbstractServer

Netty-based implementation of Server interface.

Constructor Summary

Constructors

Constructor	Description
NettyServer(ServerBootstrap sBootstrap)

Method Summary

Modifier and Type	Method	Description
protected void	doStart(CompletableFuture<Void> futureStop)	This method is called from AbstractServer.start() only when it is required, so it does not need to care if the server was already started/stopped.
protected void	doStop(CompletableFuture<Void> futureStop)	This method is called from AbstractServer.stop() only when it is required, so it does not need to care if the server was already started/stopped.
static ServerBootstrap	newDefaultSBootstrap()	Creates a default ServerBootstrap.
String	toString()

Methods inherited from class stincmale.server.AbstractServer

start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

NettyServer

public NettyServer(ServerBootstrap sBootstrap)

Parameters:

sBootstrap - Should be used to specify server options as well as the address to listen.

Method Details

doStart

protected void doStart(CompletableFuture<Void> futureStop)

Description copied from class: AbstractServer

This method is called from AbstractServer.start() only when it is required, so it does not need to care if the server was already started/stopped.

Specified by:

doStart in class AbstractServer

Parameters:

futureStop - The same CompletableFuture method AbstractServer.start() returns.

doStop

protected void doStop(CompletableFuture<Void> futureStop)

Description copied from class: AbstractServer

This method is called from AbstractServer.stop() only when it is required, so it does not need to care if the server was already started/stopped.

Specified by:

doStop in class AbstractServer

Parameters:

futureStop - The same CompletableFuture method AbstractServer.start() returns.

toString

public String toString()

Overrides:

toString in class Object

newDefaultSBootstrap

public static final ServerBootstrap newDefaultSBootstrap()

Creates a default ServerBootstrap.

Server (parent) channel options:

• ChannelOption.TCP_NODELAY true
• ChannelOption.SO_REUSEADDR true
• ChannelOption.SO_BACKLOG 50
• ChannelOption.ALLOCATOR UnpooledByteBufAllocator.DEFAULT

Accepted (child) channel options:

• ChannelOption.WRITE_BUFFER_WATER_MARK WriteBufferWaterMark.DEFAULT
• ChannelOption.ALLOCATOR UnpooledByteBufAllocator.DEFAULT

Note: if you want to use PooledByteBufAllocator, you have to release ByteBuf objects in your code. DispatchMonoHandler releases request after response was sent.