org.redkale.service

类 WebSocketNodeService

java.lang.Object

org.redkale.net.http.WebSocketNode

org.redkale.service.WebSocketNodeService

所有已实现的接口:

Service

@AutoLoad(value=false)
 @ResourceType(value=WebSocketNode.class)
public class WebSocketNodeService
extends WebSocketNode
implements Service

详情见: https://redkale.org

作者:

zhangjx

字段概要

从类继承的字段 org.redkale.net.http.WebSocketNode

localEngine, localSncpAddress, logger, remoteNode, semaphore, sendConvert, sncpNodeAddresses, SOURCE_SNCP_ADDRS_KEY, SOURCE_SNCP_USERID_PREFIX

构造器概要

构造器

构造器和说明
WebSocketNodeService()

方法概要

限定符和类型	方法和说明
CompletableFuture<Integer>	broadcastMessage(InetSocketAddress targetAddress, WebSocketRange wsrange, Object message, boolean last)
CompletableFuture<Void>	changeUserid(Serializable olduserid, Serializable newuserid, InetSocketAddress sncpAddr) 更改用户ID，需要更新到CacheSource
CompletableFuture<Void>	connect(Serializable userid, InetSocketAddress sncpAddr) 当用户连接到节点，需要更新到CacheSource
void	destroy(AnyValue conf) 进程退出时，调用Service销毁 远程模式下该方法会重载成空方法
CompletableFuture<Void>	disconnect(Serializable userid, InetSocketAddress sncpAddr) 当用户从一个节点断掉了所有的连接，需要从CacheSource中删除
CompletableFuture<Integer>	forceCloseWebSocket(Serializable userid, InetSocketAddress targetAddress) 强制关闭用户的WebSocket
CompletableFuture<List<String>>	getWebSocketAddresses(InetSocketAddress targetAddress, Serializable groupid)
void	init(AnyValue conf) 该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法
CompletableFuture<Integer>	sendMessage(InetSocketAddress targetAddress, Object message, boolean last, Serializable userid)

从类继承的方法 org.redkale.net.http.WebSocketNode

broadcastMessage, broadcastMessage, broadcastMessage, broadcastMessage, broadcastMessage, broadcastMessage, broadcastMessage, broadcastMessage, existsWebSocket, forceCloseWebSocket, formatRemoteMessage, getLocalWebSocketEngine, getRpcNodeAddresses, getRpcNodeWebSocketAddresses, getSemaphore, getUserSize, postDestroy, releaseSemaphore, remoteWebSocketAddresses, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendOneMessage, tryAcquireSemaphore

从类继承的方法 java.lang.Object

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

构造器详细资料

WebSocketNodeService

public WebSocketNodeService()

方法详细资料

init

public void init(AnyValue conf)

从接口复制的说明: Service

该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法

指定者:

init 在接口中 Service

覆盖:

init 在类中 WebSocketNode

参数:

conf - 配置参数

destroy

public void destroy(AnyValue conf)

从接口复制的说明: Service

进程退出时，调用Service销毁 远程模式下该方法会重载成空方法

指定者:

destroy 在接口中 Service

覆盖:

destroy 在类中 WebSocketNode

参数:

conf - 配置参数

getWebSocketAddresses

public CompletableFuture<List<String>> getWebSocketAddresses(@RpcTargetAddress
                                                             InetSocketAddress targetAddress,
                                                             Serializable groupid)

指定者:

getWebSocketAddresses 在类中 WebSocketNode

sendMessage

public CompletableFuture<Integer> sendMessage(@RpcTargetAddress
                                              InetSocketAddress targetAddress,
                                              Object message,
                                              boolean last,
                                              Serializable userid)

指定者:

sendMessage 在类中 WebSocketNode

broadcastMessage

public CompletableFuture<Integer> broadcastMessage(@RpcTargetAddress
                                                   InetSocketAddress targetAddress,
                                                   WebSocketRange wsrange,
                                                   Object message,
                                                   boolean last)

指定者:

broadcastMessage 在类中 WebSocketNode

connect

public CompletableFuture<Void> connect(Serializable userid,
                                       InetSocketAddress sncpAddr)

当用户连接到节点，需要更新到CacheSource

指定者:

connect 在类中 WebSocketNode

参数:

userid - Serializable

sncpAddr - InetSocketAddress

返回:

无返回值

disconnect

public CompletableFuture<Void> disconnect(Serializable userid,
                                          InetSocketAddress sncpAddr)

当用户从一个节点断掉了所有的连接，需要从CacheSource中删除

指定者:

disconnect 在类中 WebSocketNode

参数:

userid - Serializable

sncpAddr - InetSocketAddress

返回:

无返回值

changeUserid

public CompletableFuture<Void> changeUserid(Serializable olduserid,
                                            Serializable newuserid,
                                            InetSocketAddress sncpAddr)

更改用户ID，需要更新到CacheSource

指定者:

changeUserid 在类中 WebSocketNode

参数:

olduserid - Serializable

newuserid - Serializable

sncpAddr - InetSocketAddress

返回:

无返回值

forceCloseWebSocket

public CompletableFuture<Integer> forceCloseWebSocket(Serializable userid,
                                                      @RpcTargetAddress
                                                      InetSocketAddress targetAddress)

强制关闭用户的WebSocket

指定者:

forceCloseWebSocket 在类中 WebSocketNode

参数:

userid - Serializable

targetAddress - InetSocketAddress

返回:

无返回值