org.redkale.net.http

类 WebSocketEngine

java.lang.Object

org.redkale.net.http.WebSocketEngine

public final class WebSocketEngine
extends java.lang.Object

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected HttpContext	context
protected JsonConvert	convert
protected boolean	finest
protected java.util.logging.Logger	logger
protected WebSocketNode	node
protected boolean	single

构造器概要

构造器

限定符	构造器和说明
protected	WebSocketEngine(java.lang.String engineid, boolean single, HttpContext context, int liveinterval, WebSocketNode node, java.util.logging.Logger logger)

方法概要

限定符和类型	方法和说明
java.util.concurrent.CompletableFuture<java.lang.Integer>	broadcastMessage(java.lang.Object message, boolean last)
boolean	existsLocalWebSocket(java.io.Serializable userid)
WebSocket	findLocalWebSocket(java.io.Serializable userid)
java.lang.String	getEngineid()
java.util.stream.Stream<WebSocket>	getLocalWebSockets(java.io.Serializable userid)
java.util.concurrent.CompletableFuture<java.lang.Integer>	sendMessage(java.lang.Object message, boolean last, java.io.Serializable... userids)

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

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

字段详细资料

node

protected final WebSocketNode node

context

protected final HttpContext context

convert

protected final JsonConvert convert

single

protected final boolean single

logger

protected final java.util.logging.Logger logger

finest

protected final boolean finest

构造器详细资料

WebSocketEngine

protected WebSocketEngine(java.lang.String engineid,
                          boolean single,
                          HttpContext context,
                          int liveinterval,
                          WebSocketNode node,
                          java.util.logging.Logger logger)

方法详细资料

broadcastMessage

public java.util.concurrent.CompletableFuture<java.lang.Integer> broadcastMessage(java.lang.Object message,
                                                                                  boolean last)

sendMessage

public java.util.concurrent.CompletableFuture<java.lang.Integer> sendMessage(java.lang.Object message,
                                                                             boolean last,
                                                                             java.io.Serializable... userids)

findLocalWebSocket

public WebSocket findLocalWebSocket(java.io.Serializable userid)

getLocalWebSockets

public java.util.stream.Stream<WebSocket> getLocalWebSockets(java.io.Serializable userid)

existsLocalWebSocket

public boolean existsLocalWebSocket(java.io.Serializable userid)

getEngineid

public java.lang.String getEngineid()