protected abstract CompletableFuture<Integer> |
WebSocketNode.broadcastAction(String topic,
InetSocketAddress targetAddress,
WebSocketAction action) |
|
CompletableFuture<Integer> |
WebSocketNodeService.broadcastAction(String topic,
InetSocketAddress targetAddress,
WebSocketAction action) |
|
protected abstract CompletableFuture<Integer> |
WebSocketNode.broadcastMessage(String topic,
InetSocketAddress targetAddress,
WebSocketRange wsrange,
Object message,
boolean last) |
|
CompletableFuture<Integer> |
WebSocketNodeService.broadcastMessage(String topic,
InetSocketAddress targetAddress,
WebSocketRange wsrange,
Object message,
boolean last) |
|
protected abstract CompletableFuture<Boolean> |
WebSocketNode.existsWebSocket(Serializable userid,
String topic,
InetSocketAddress targetAddress) |
|
CompletableFuture<Boolean> |
WebSocketNodeService.existsWebSocket(Serializable userid,
String topic,
InetSocketAddress targetAddress) |
判断用户是否有WebSocket
|
protected abstract CompletableFuture<Integer> |
WebSocketNode.forceCloseWebSocket(Serializable userid,
String topic,
InetSocketAddress targetAddress) |
|
CompletableFuture<Integer> |
WebSocketNodeService.forceCloseWebSocket(Serializable userid,
String topic,
InetSocketAddress targetAddress) |
强制关闭用户的WebSocket
|
protected abstract CompletableFuture<Integer> |
WebSocketNode.getUserSize(String topic,
InetSocketAddress targetAddress) |
|
CompletableFuture<Integer> |
WebSocketNodeService.getUserSize(String topic,
InetSocketAddress targetAddress) |
|
protected abstract CompletableFuture<List<String>> |
WebSocketNode.getWebSocketAddresses(String topic,
InetSocketAddress targetAddress,
Serializable userid) |
|
CompletableFuture<List<String>> |
WebSocketNodeService.getWebSocketAddresses(String topic,
InetSocketAddress targetAddress,
Serializable groupid) |
|
protected CompletableFuture<List<String>> |
WebSocketNode.remoteWebSocketAddresses(String topic,
InetSocketAddress targetAddress,
Serializable userid) |
获取目标地址
该方法仅供内部调用
|
protected abstract CompletableFuture<Integer> |
WebSocketNode.sendAction(String topic,
InetSocketAddress targetAddress,
WebSocketAction action,
Serializable... userids) |
|
CompletableFuture<Integer> |
WebSocketNodeService.sendAction(String topic,
InetSocketAddress targetAddress,
WebSocketAction action,
Serializable... userids) |
|
protected abstract CompletableFuture<Integer> |
WebSocketNode.sendMessage(String topic,
InetSocketAddress targetAddress,
Object message,
boolean last,
Serializable... userids) |
|
CompletableFuture<Integer> |
WebSocketNodeService.sendMessage(String topic,
InetSocketAddress targetAddress,
Object message,
boolean last,
Serializable... userids) |
|