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

Class NettyNetworkClient

java.lang.Object

de.dytanic.cloudnet.driver.network.netty.NettyNetworkClient

All Implemented Interfaces:

INetworkClient, IPacketSender, java.lang.AutoCloseable

public final class NettyNetworkClient
extends java.lang.Object
implements INetworkClient

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Collection<INetworkChannel>	channels
protected long	connectedTime
protected io.netty.channel.EventLoopGroup	eventLoopGroup
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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	closeChannels()
boolean	connect(@NotNull HostAndPort hostAndPort)	Open a new connection to the specific host and port
java.util.Collection<INetworkChannel>	getChannels()
long	getConnectedTime()	Gets the time when this client was connected to the server in milliseconds
IPacketListenerRegistry	getPacketRegistry()
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

channels

protected final java.util.Collection<INetworkChannel> channels

packetRegistry

protected final IPacketListenerRegistry packetRegistry

eventLoopGroup

protected final io.netty.channel.EventLoopGroup eventLoopGroup

networkChannelHandler

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

taskScheduler

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

taskSchedulerFromConstructor

protected final boolean taskSchedulerFromConstructor

sslConfiguration

protected final SSLConfiguration sslConfiguration

sslContext

protected io.netty.handler.ssl.SslContext sslContext

connectedTime

protected long connectedTime

Constructor Detail

NettyNetworkClient

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

NettyNetworkClient

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

Method Detail

isSslEnabled

public boolean isSslEnabled()

connect

public boolean connect(@NotNull
                       @NotNull HostAndPort hostAndPort)

Description copied from interface: INetworkClient

Open a new connection to the specific host and port

Specified by:

connect in interface INetworkClient

Parameters:

hostAndPort - the address, that should the client connect to

Returns:

true if the connection was success or false if the connection was unsuccessful or refused

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

getChannels

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

closeChannels

public void closeChannels()

getConnectedTime

public long getConnectedTime()

Description copied from interface: INetworkClient

Gets the time when this client was connected to the server in milliseconds

Specified by:

getConnectedTime in interface INetworkClient

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()