Class DefaultConnectionManager

java.lang.Object

com.iohao.net.server.connection.DefaultConnectionManager

All Implemented Interfaces:

CommonConnectionManager, ConnectionManager

public final class DefaultConnectionManager
extends Object
implements ConnectionManager

Default Aeron-based ConnectionManager implementation for net-server peers.

Since:

25.1

Author:

渔民小镇

date:

2025-09-06

Constructor Summary

Constructors

Constructor	Description
DefaultConnectionManager(ConnectionManagerParameter parameter)

Method Summary

Modifier and Type	Method	Description
void	addConnection(ConnectionItem connection)
void	awaitConnect()
boolean	containsNetId(int netId)	Tests whether a publication mapping exists for the given network id.
io.aeron.Publication	getPublicationByNetId(int netId)	Gets the Aeron publication bound to the given network id.
int	poll(io.aeron.logbuffer.FragmentHandler fragmentHandler)	Polls inbound fragments and dispatches them to the provided fragment handler.
void	publishMessage(int serverId, Object message)
void	publishMessage(String pubName, Object message)	Publishes a message through the named publication pipeline.
void	publishMessageByNetId(int netId, Object message)
void	publishMessageToCenter(Object message)

Methods inherited from class Object

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

Constructor Details

DefaultConnectionManager

public DefaultConnectionManager(ConnectionManagerParameter parameter)

Method Details

containsNetId

public boolean containsNetId(int netId)

Description copied from interface: CommonConnectionManager

Tests whether a publication mapping exists for the given network id.

Specified by:

containsNetId in interface CommonConnectionManager

Parameters:

netId - network id

Returns:

true if the mapping exists

awaitConnect

public void awaitConnect()

Specified by:

awaitConnect in interface ConnectionManager

getPublicationByNetId

public io.aeron.Publication getPublicationByNetId(int netId)

Description copied from interface: CommonConnectionManager

Gets the Aeron publication bound to the given network id.

Specified by:

getPublicationByNetId in interface CommonConnectionManager

Parameters:

netId - network id

Returns:

publication, or null if absent

publishMessageToCenter

public void publishMessageToCenter(Object message)

Specified by:

publishMessageToCenter in interface ConnectionManager

publishMessage

public void publishMessage(int serverId,
 Object message)

Specified by:

publishMessage in interface ConnectionManager

publishMessage

public void publishMessage(String pubName,
 Object message)

Description copied from interface: CommonConnectionManager

Publishes a message through the named publication pipeline.

Specified by:

publishMessage in interface CommonConnectionManager

Parameters:

pubName - publication name

message - message to publish

publishMessageByNetId

public void publishMessageByNetId(int netId,
 Object message)

Specified by:

publishMessageByNetId in interface ConnectionManager

addConnection

public void addConnection(ConnectionItem connection)

Specified by:

addConnection in interface ConnectionManager

poll

public int poll(io.aeron.logbuffer.FragmentHandler fragmentHandler)

Description copied from interface: CommonConnectionManager

Polls inbound fragments and dispatches them to the provided fragment handler.

Specified by:

poll in interface CommonConnectionManager

Parameters:

fragmentHandler - fragment callback

Returns:

number of fragments processed