org.redkale.net.http

类 WebSocketNode

java.lang.Object

org.redkale.net.http.WebSocketNode

直接已知子类:

WebSocketNodeService

public abstract class WebSocketNode
extends java.lang.Object

详情见: http://www.redkale.org

字段概要

字段

限定符和类型	字段和说明
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,WebSocketEngine>	engines
protected boolean	finest
protected java.util.concurrent.ConcurrentHashMap<java.io.Serializable,java.util.Set<java.lang.String>>	localNodes
protected java.net.InetSocketAddress	localSncpAddress
protected java.util.logging.Logger	logger
protected WebSocketNode	remoteNode
protected CacheSource<java.io.Serializable,java.net.InetSocketAddress>	source

构造器概要

构造器

构造器和说明
WebSocketNode()

方法概要

限定符和类型	方法和说明
protected abstract void	connect(java.io.Serializable groupid, java.net.InetSocketAddress addr)
void	connect(java.io.Serializable groupid, java.lang.String engineid, java.lang.String wsinfo)
void	destroy(AnyValue conf)
protected abstract void	disconnect(java.io.Serializable groupid, java.net.InetSocketAddress addr)
void	disconnect(java.io.Serializable groupid, java.lang.String engineid)
java.util.Collection<java.net.InetSocketAddress>	getOnlineNodes(java.io.Serializable groupid) 获取在线用户的节点地址列表
java.util.Map<java.net.InetSocketAddress,java.util.List<java.lang.String>>	getOnlineRemoteAddress(java.io.Serializable groupid) 获取在线用户的详细连接信息
protected abstract java.util.List<java.lang.String>	getOnlineRemoteAddresses(java.net.InetSocketAddress targetAddress, java.io.Serializable groupid)
void	init(AnyValue conf)
protected java.util.List<java.lang.String>	remoteOnlineRemoteAddresses(java.net.InetSocketAddress targetAddress, java.io.Serializable groupid)
int	sendEachMessage(java.io.Serializable groupid, byte[] data)
int	sendEachMessage(java.io.Serializable groupid, byte[] data, boolean last)
int	sendEachMessage(java.io.Serializable groupid, java.lang.String text)
int	sendEachMessage(java.io.Serializable groupid, java.lang.String text, boolean last)
protected abstract int	sendMessage(java.net.InetSocketAddress targetAddress, java.io.Serializable groupid, boolean recent, java.io.Serializable message, boolean last)
int	sendMessage(java.io.Serializable groupid, boolean recent, byte[] data)
int	sendMessage(java.io.Serializable groupid, boolean recent, byte[] data, boolean last)
int	sendMessage(java.io.Serializable groupid, boolean recent, java.io.Serializable message, boolean last)
int	sendMessage(java.io.Serializable groupid, boolean recent, java.lang.String text)
int	sendMessage(java.io.Serializable groupid, boolean recent, java.lang.String text, boolean last)
int	sendRecentMessage(java.io.Serializable groupid, byte[] data)
int	sendRecentMessage(java.io.Serializable groupid, byte[] data, boolean last)
int	sendRecentMessage(java.io.Serializable groupid, java.lang.String text)
int	sendRecentMessage(java.io.Serializable groupid, java.lang.String text, boolean last)

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

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

字段详细资料

logger

protected final java.util.logging.Logger logger

finest

protected final boolean finest

localSncpAddress

protected java.net.InetSocketAddress localSncpAddress

remoteNode

@DynRemote
protected WebSocketNode remoteNode

source

protected CacheSource<java.io.Serializable,java.net.InetSocketAddress> source

localNodes

protected final java.util.concurrent.ConcurrentHashMap<java.io.Serializable,java.util.Set<java.lang.String>> localNodes

engines

protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,WebSocketEngine> engines

构造器详细资料

WebSocketNode

public WebSocketNode()

方法详细资料

init

public void init(AnyValue conf)

destroy

public void destroy(AnyValue conf)

getOnlineRemoteAddresses

protected abstract java.util.List<java.lang.String> getOnlineRemoteAddresses(@DynTargetAddress
                                                                             java.net.InetSocketAddress targetAddress,
                                                                             java.io.Serializable groupid)

sendMessage

protected abstract int sendMessage(@DynTargetAddress
                                   java.net.InetSocketAddress targetAddress,
                                   java.io.Serializable groupid,
                                   boolean recent,
                                   java.io.Serializable message,
                                   boolean last)

connect

protected abstract void connect(java.io.Serializable groupid,
                                java.net.InetSocketAddress addr)

disconnect

protected abstract void disconnect(java.io.Serializable groupid,
                                   java.net.InetSocketAddress addr)

remoteOnlineRemoteAddresses

protected java.util.List<java.lang.String> remoteOnlineRemoteAddresses(@DynTargetAddress
                                                                       java.net.InetSocketAddress targetAddress,
                                                                       java.io.Serializable groupid)

getOnlineNodes

public java.util.Collection<java.net.InetSocketAddress> getOnlineNodes(java.io.Serializable groupid)

获取在线用户的节点地址列表

参数:

groupid - groupid

返回:

地址列表

getOnlineRemoteAddress

public java.util.Map<java.net.InetSocketAddress,java.util.List<java.lang.String>> getOnlineRemoteAddress(java.io.Serializable groupid)

获取在线用户的详细连接信息

参数:

groupid - groupid

返回:

地址集合

connect

public final void connect(java.io.Serializable groupid,
                          java.lang.String engineid,
                          java.lang.String wsinfo)

disconnect

public final void disconnect(java.io.Serializable groupid,
                             java.lang.String engineid)

sendMessage

public final int sendMessage(java.io.Serializable groupid,
                             boolean recent,
                             java.io.Serializable message,
                             boolean last)

sendEachMessage

public final int sendEachMessage(java.io.Serializable groupid,
                                 java.lang.String text)

sendEachMessage

public final int sendEachMessage(java.io.Serializable groupid,
                                 java.lang.String text,
                                 boolean last)

sendRecentMessage

public final int sendRecentMessage(java.io.Serializable groupid,
                                   java.lang.String text)

sendRecentMessage

public final int sendRecentMessage(java.io.Serializable groupid,
                                   java.lang.String text,
                                   boolean last)

sendMessage

public final int sendMessage(java.io.Serializable groupid,
                             boolean recent,
                             java.lang.String text)

sendMessage

public final int sendMessage(java.io.Serializable groupid,
                             boolean recent,
                             java.lang.String text,
                             boolean last)

sendEachMessage

public final int sendEachMessage(java.io.Serializable groupid,
                                 byte[] data)

sendEachMessage

public final int sendEachMessage(java.io.Serializable groupid,
                                 byte[] data,
                                 boolean last)

sendRecentMessage

public final int sendRecentMessage(java.io.Serializable groupid,
                                   byte[] data)

sendRecentMessage

public final int sendRecentMessage(java.io.Serializable groupid,
                                   byte[] data,
                                   boolean last)

sendMessage

public final int sendMessage(java.io.Serializable groupid,
                             boolean recent,
                             byte[] data)

sendMessage

public final int sendMessage(java.io.Serializable groupid,
                             boolean recent,
                             byte[] data,
                             boolean last)