Package de.dytanic.cloudnet.driver.network.netty

Class NettyNetworkServer

java.lang.Object

de.dytanic.cloudnet.driver.network.netty.NettyNetworkServer

All Implemented Interfaces:

INetworkServer, IPacketSender, java.lang.AutoCloseable

public final class NettyNetworkServer
extends java.lang.Object
implements INetworkServer

Field Summary

Fields

Modifier and Type	Field	Description
protected io.netty.channel.EventLoopGroup	bossEventLoopGroup
protected java.util.Map<java.lang.Integer,de.dytanic.cloudnet.common.collection.Pair<HostAndPort,io.netty.channel.ChannelFuture>>	channelFutures
protected java.util.Collection<INetworkChannel>	channels
protected java.util.concurrent.Callable<INetworkChannelHandler>	networkChannelHandler
protected IPacketListenerRegistry	packetRegistry
protected SSLConfiguration	sslConfiguration
protected io.netty.handler.ssl.SslContext	sslContext
protected de.dytanic.cloudnet.common.concurrent.ITaskScheduler	taskScheduler
protected boolean	taskSchedulerFromConstructor
protected io.netty.channel.EventLoopGroup	workerEventLoopGroup

Constructor Summary

Constructors

Constructor	Description
NettyNetworkServer(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler)
NettyNetworkServer(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler, de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler)
NettyNetworkServer(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler, SSLConfiguration sslConfiguration, de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler)

Method Summary

Modifier and Type	Method	Description
boolean	addListener(int port)	Binds the server to a specific port with the host alias address "0.0.0.0"
boolean	addListener(@NotNull HostAndPort hostAndPort)	Binds the server to a specific address that is as parameter defined
void	close()
void	closeChannels()
java.util.Collection<INetworkChannel>	getChannels()
IPacketListenerRegistry	getPacketRegistry()
protected void	init()
boolean	isSslEnabled()
void	sendPacket(@NotNull IPacket packet)	Transport a packet instance into the network to the receiver.
void	sendPacket(@NotNull IPacket... packets)	Transport packet instances into the network to the receiver.

Methods inherited from class java.lang.Object

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

Field Detail

channelFutures

protected final java.util.Map<java.lang.Integer,de.dytanic.cloudnet.common.collection.Pair<HostAndPort,io.netty.channel.ChannelFuture>> channelFutures

channels

protected final java.util.Collection<INetworkChannel> channels

packetRegistry

protected final IPacketListenerRegistry packetRegistry

bossEventLoopGroup

protected final io.netty.channel.EventLoopGroup bossEventLoopGroup

workerEventLoopGroup

protected final io.netty.channel.EventLoopGroup workerEventLoopGroup

taskScheduler

protected final de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler

taskSchedulerFromConstructor

protected final boolean taskSchedulerFromConstructor

networkChannelHandler

protected final java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler

sslConfiguration

protected final SSLConfiguration sslConfiguration

sslContext

protected io.netty.handler.ssl.SslContext sslContext

Constructor Detail

NettyNetworkServer

public NettyNetworkServer(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler)

NettyNetworkServer

public NettyNetworkServer(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler,
                          de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler)

NettyNetworkServer

public NettyNetworkServer(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler,
                          SSLConfiguration sslConfiguration,
                          de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler)

Method Detail

isSslEnabled

public boolean isSslEnabled()

addListener

public boolean addListener(int port)

Description copied from interface: INetworkServer

Binds the server to a specific port with the host alias address "0.0.0.0"

Specified by:

addListener in interface INetworkServer

Parameters:

port - the port, that the server should bind

Returns:

true when the binding was successful or false if an error was threw or the port is already bind

addListener

public boolean addListener(@NotNull
                           @NotNull HostAndPort hostAndPort)

Description copied from interface: INetworkServer

Binds the server to a specific address that is as parameter defined

Specified by:

addListener in interface INetworkServer

Parameters:

hostAndPort - the address that should the server bind

Returns:

true when the binding was successful or false if an error was threw or the port is already bind

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

getChannels

public java.util.Collection<INetworkChannel> getChannels()

closeChannels

public void closeChannels()

sendPacket

public void sendPacket(@NotNull
                       @NotNull IPacket packet)

Description copied from interface: IPacketSender

Transport a packet instance into the network to the receiver. The receiver will handle the packet if he knows the channel and has listeners for the channel

The packet are doesn't allow to be null

Specified by:

sendPacket in interface IPacketSender

Parameters:

packet - the packet, which should transport into the network

sendPacket

public void sendPacket(@NotNull
                       @NotNull IPacket... packets)

Description copied from interface: IPacketSender

Transport packet instances into the network to the receiver. The receiver will handle the packets if he knows the channel and has listeners for the channel

A packet are doesn't allow to be null All elements should be checked that be not null and send after that

Specified by:

sendPacket in interface IPacketSender

Parameters:

packets - the packets, which should transport into the network

getPacketRegistry

public IPacketListenerRegistry getPacketRegistry()

init

protected void init()
             throws java.lang.Exception

Throws:

java.lang.Exception