Class DefaultCommunicationAggregation

java.lang.Object

com.iohao.net.server.DefaultCommunicationAggregation

All Implemented Interfaces:

BroadcastCommunication, CommunicationAggregation, EventBusMessageCommunication, ExternalCollectCommunication, ExternalCommunication, LogicCollectCommunication, LogicCommunication, PublisherCommunication, NetServerSettingAware

public class DefaultCommunicationAggregation
extends Object
implements CommunicationAggregation, NetServerSettingAware

Default communication aggregation implementation for routing, broadcasting, and RPC-like calls.

Since:

25.1

Author:

渔民小镇

date:

2025-09-07

Field Summary

Fields

Modifier and Type	Field	Description
protected ConnectionManager	connectionManager
protected ExternalServerLoadBalanced	externalServerLoadBalanced
protected FindServer	findServer
protected FutureManager	futureManager
protected Publisher	publisher

Constructor Summary

Constructors

Constructor	Description
DefaultCommunicationAggregation()

Method Summary

Modifier and Type	Method	Description
CommonResponse	bindingLogicServer(BindingLogicServerMessage message)	Synchronously bind a user session to a specific logic server.
CompletableFuture<CommonResponse>	bindingLogicServerFuture(BindingLogicServerMessage message)	Asynchronously bind a user session to a specific logic server.
void	broadcast(BroadcastMulticastMessage message)	Broadcast a message to multiple recipients via multicast.
void	broadcast(BroadcastUserListMessage message)	Broadcast a message to a specific list of users.
void	broadcast(BroadcastUserMessage message)	Broadcast a message to a single user (unicast).
Response	call(RequestMessage message)	Call another logic server and block until a response is received.
ResponseCollect	callCollect(RequestMessage message)	Synchronously call all matching logic servers and collect their responses.
ResponseCollectExternal	callCollectExternal(ExternalRequestMessage message)	Synchronously call all external servers and collect their responses.
CompletableFuture<ResponseCollectExternal>	callCollectExternalFuture(ExternalRequestMessage message)	Asynchronously call all external servers and collect their responses.
CompletableFuture<ResponseCollect>	callCollectFuture(RequestMessage message)	Asynchronously call all matching logic servers and collect their responses.
ExternalResponse	callExternal(ExternalRequestMessage message)	Send a request to an external server and block until a response is received.
CompletableFuture<ExternalResponse>	callExternalFuture(ExternalRequestMessage message)	Send a request to an external server asynchronously.
CompletableFuture<Response>	callFuture(RequestMessage message)	Call another logic server asynchronously and return a future for the response.
void	fireRemote(EventBusMessage message)	Fire an event bus message to remote logic servers.
protected CompletableFuture<Response>	ofErrorFuture(ErrorInformation errorInformation)
void	publishMessage(int serverId, Object message)	Publish a message to a server identified by its server ID.
void	publishMessage(String name, Object message)	Publish a message to a server identified by its logical name.
void	publishMessageByNetId(int netId, Object message)	Publish a message to a server identified by its net ID.
void	send(SendMessage message)	Send a message to another logic server without expecting a response (fire-and-forget).
void	setNetServerSetting(NetServerSetting setting)	Injects the runtime setting.
void	writeMessage(UserResponseMessage message)	Write a response message directly to a user session on the external server.

Methods inherited from class Object

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

Field Details

connectionManager

protected ConnectionManager connectionManager

externalServerLoadBalanced

protected ExternalServerLoadBalanced externalServerLoadBalanced

futureManager

protected FutureManager futureManager

publisher

protected Publisher publisher

findServer

protected FindServer findServer

Constructor Details

DefaultCommunicationAggregation

public DefaultCommunicationAggregation()

Method Details

setNetServerSetting

public void setNetServerSetting(NetServerSetting setting)

Description copied from interface: NetServerSettingAware

Injects the runtime setting.

Specified by:

setNetServerSetting in interface NetServerSettingAware

Parameters:

setting - runtime setting

publishMessageByNetId

public void publishMessageByNetId(int netId,
 Object message)

Description copied from interface: PublisherCommunication

Publish a message to a server identified by its net ID.

Specified by:

publishMessageByNetId in interface PublisherCommunication

Parameters:

netId - the net ID of the target server

message - the message to publish

publishMessage

public void publishMessage(int serverId,
 Object message)

Description copied from interface: PublisherCommunication

Publish a message to a server identified by its server ID.

Specified by:

publishMessage in interface PublisherCommunication

Parameters:

serverId - the server ID of the target server

message - the message to publish

publishMessage

public void publishMessage(String name,
 Object message)

Description copied from interface: PublisherCommunication

Publish a message to a server identified by its logical name.

Specified by:

publishMessage in interface PublisherCommunication

Parameters:

name - the logical name of the target server

message - the message to publish

writeMessage

public void writeMessage(UserResponseMessage message)

Description copied from interface: ExternalCollectCommunication

Write a response message directly to a user session on the external server.

Specified by:

writeMessage in interface ExternalCollectCommunication

Parameters:

message - the user response message to deliver

broadcast

public void broadcast(BroadcastUserMessage message)

Description copied from interface: BroadcastCommunication

Broadcast a message to a single user (unicast).

Specified by:

broadcast in interface BroadcastCommunication

Parameters:

message - the unicast broadcast message

broadcast

public void broadcast(BroadcastUserListMessage message)

Description copied from interface: BroadcastCommunication

Broadcast a message to a specific list of users.

Specified by:

broadcast in interface BroadcastCommunication

Parameters:

message - the user-list broadcast message

broadcast

public void broadcast(BroadcastMulticastMessage message)

Description copied from interface: BroadcastCommunication

Broadcast a message to multiple recipients via multicast.

Specified by:

broadcast in interface BroadcastCommunication

Parameters:

message - the multicast broadcast message

callExternal

public ExternalResponse callExternal(ExternalRequestMessage message)

Description copied from interface: ExternalCommunication

Send a request to an external server and block until a response is received.

Specified by:

callExternal in interface ExternalCommunication

Parameters:

message - the external request message

Returns:

the external response

callExternalFuture

public CompletableFuture<ExternalResponse> callExternalFuture(ExternalRequestMessage message)

Description copied from interface: ExternalCommunication

Send a request to an external server asynchronously.

Specified by:

callExternalFuture in interface ExternalCommunication

Parameters:

message - the external request message

Returns:

a CompletableFuture that completes with the external response

callCollectExternalFuture

public CompletableFuture<ResponseCollectExternal> callCollectExternalFuture(ExternalRequestMessage message)

Description copied from interface: ExternalCollectCommunication

Asynchronously call all external servers and collect their responses.

Specified by:

callCollectExternalFuture in interface ExternalCollectCommunication

Parameters:

message - the external request message to broadcast

Returns:

a future that completes with the aggregated response from all external servers

callCollectExternal

public ResponseCollectExternal callCollectExternal(ExternalRequestMessage message)

Description copied from interface: ExternalCollectCommunication

Synchronously call all external servers and collect their responses.

Specified by:

callCollectExternal in interface ExternalCollectCommunication

Parameters:

message - the external request message to broadcast

Returns:

the aggregated response from all external servers

bindingLogicServerFuture

public CompletableFuture<CommonResponse> bindingLogicServerFuture(BindingLogicServerMessage message)

Description copied from interface: ExternalCollectCommunication

Asynchronously bind a user session to a specific logic server.

Specified by:

bindingLogicServerFuture in interface ExternalCollectCommunication

Parameters:

message - the binding request message

Returns:

a future that completes with the common response

bindingLogicServer

public CommonResponse bindingLogicServer(BindingLogicServerMessage message)

Description copied from interface: ExternalCollectCommunication

Synchronously bind a user session to a specific logic server.

Specified by:

bindingLogicServer in interface ExternalCollectCommunication

Parameters:

message - the binding request message

Returns:

the common response indicating success or failure

callFuture

public CompletableFuture<Response> callFuture(RequestMessage message)

Description copied from interface: LogicCommunication

Call another logic server asynchronously and return a future for the response.

Specified by:

callFuture in interface LogicCommunication

Parameters:

message - the request message

Returns:

a CompletableFuture that completes with the response

call

public Response call(RequestMessage message)

Description copied from interface: LogicCommunication

Call another logic server and block until a response is received.

Specified by:

call in interface LogicCommunication

Parameters:

message - the request message

Returns:

the response from the target logic server

send

public void send(SendMessage message)

Description copied from interface: LogicCommunication

Send a message to another logic server without expecting a response (fire-and-forget).

Specified by:

send in interface LogicCommunication

Parameters:

message - the send message

callCollectFuture

public CompletableFuture<ResponseCollect> callCollectFuture(RequestMessage message)

Description copied from interface: LogicCollectCommunication

Asynchronously call all matching logic servers and collect their responses.

Specified by:

callCollectFuture in interface LogicCollectCommunication

Parameters:

message - the request message to broadcast

Returns:

a future that completes with the aggregated response from all logic servers

callCollect

public ResponseCollect callCollect(RequestMessage message)

Description copied from interface: LogicCollectCommunication

Synchronously call all matching logic servers and collect their responses.

Specified by:

callCollect in interface LogicCollectCommunication

Parameters:

message - the request message to broadcast

Returns:

the aggregated response from all logic servers

ofErrorFuture

protected CompletableFuture<Response> ofErrorFuture(ErrorInformation errorInformation)

fireRemote

public void fireRemote(EventBusMessage message)

Description copied from interface: EventBusMessageCommunication

Fire an event bus message to remote logic servers.

Specified by:

fireRemote in interface EventBusMessageCommunication

Parameters:

message - the event bus message to dispatch remotely