Class NeonRelay

java.lang.Object

com.quietterminal.neon.core.AbstractLifecycle

com.quietterminal.neon.relay.NeonRelay

All Implemented Interfaces:

Lifecycle, AutoCloseable

public final class NeonRelay
extends AbstractLifecycle
implements AutoCloseable

UDP relay server for the Neon multiplayer protocol.

A NeonRelay routes packets between session hosts and clients. It manages session state, enforces per-source rate limits, and handles the connection and reconnection handshake on behalf of the host.

The relay is stateless with respect to game logic — it only understands the protocol lifecycle packets (CONNECT_REQUEST, CONNECT_ACCEPT, etc.) and routes everything else based on the destination ID in the packet header.

Typical deployment:

NeonRelay relay = new NeonRelay("0.0.0.0", NeonConfig.defaults());
Thread.ofVirtual().start(relay::startAndRun);

Nested Class Summary

Nested classes/interfaces inherited from interface Lifecycle

Lifecycle.State

Constructor Summary

Constructors

Constructor	Description
NeonRelay(String bindAddress, NeonConfig config)	Creates a relay bound to the given address on the port specified by NeonConfig.getRelayPort().

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	doStart()
protected void	doStop()
InetSocketAddress	getLocalAddress()	Returns the local address the relay is bound to.
void	startAndRun()	Starts the relay and runs the packet processing loop until AbstractLifecycle.stop() is called.

Methods inherited from class AbstractLifecycle

getState, isRunning, start, stop

Methods inherited from class Object

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

Constructor Details

NeonRelay

public NeonRelay(String bindAddress,
 NeonConfig config)
          throws IOException

Creates a relay bound to the given address on the port specified by NeonConfig.getRelayPort().

Parameters:

bindAddress - IP address to bind (e.g. "0.0.0.0" for all interfaces)

config - protocol configuration

Throws:

IOException - if the socket cannot be bound

Method Details

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycle

doStop

protected void doStop()
               throws IOException

Specified by:

doStop in class AbstractLifecycle

Throws:

IOException

startAndRun

public void startAndRun()
                 throws Exception

Starts the relay and runs the packet processing loop until AbstractLifecycle.stop() is called. Intended to run in a dedicated virtual thread.

Throws:

Exception - if startup fails

getLocalAddress

public InetSocketAddress getLocalAddress()
                                  throws IOException

Returns the local address the relay is bound to.

Throws:

IOException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception