org.redkale.net.http

类 WebSocketEngine

java.lang.Object

org.redkale.net.http.WebSocketEngine

public class WebSocketEngine
extends java.lang.Object

详情见: https://redkale.org

字段概要

字段

限定符和类型	字段和说明
protected HttpContext	context
protected Cryptor	cryptor
protected java.util.concurrent.atomic.AtomicInteger	currconns
protected int	liveinterval
protected java.util.logging.Logger	logger
protected boolean	mergemsg
protected WebSocketNode	node
protected Convert	sendConvert
protected boolean	single
protected int	wsmaxbody
protected int	wsmaxconns
protected int	wsthreads

构造器概要

构造器

限定符	构造器和说明
protected	WebSocketEngine(java.lang.String engineid, boolean single, HttpContext context, int liveinterval, int wsmaxconns, int wsthreads, int wsmaxbody, boolean mergemsg, Cryptor cryptor, WebSocketNode node, Convert sendConvert, java.util.logging.Logger logger)

方法概要

限定符和类型	方法和说明
java.util.concurrent.CompletableFuture<java.lang.Integer>	broadcastLocalAction(WebSocketAction action)
java.util.concurrent.CompletableFuture<java.lang.Integer>	broadcastLocalMessage(java.lang.Object message, boolean last)
java.util.concurrent.CompletableFuture<java.lang.Integer>	broadcastLocalMessage(java.util.function.Predicate<WebSocket> predicate, java.lang.Object message, boolean last)
java.util.concurrent.CompletableFuture<java.lang.Integer>	broadcastLocalMessage(WebSocketRange wsrange, java.lang.Object message, boolean last)
boolean	existsLocalWebSocket(java.io.Serializable userid)
WebSocket	findLocalWebSocket(java.io.Serializable userid)
int	forceCloseLocalWebSocket(java.io.Serializable userid)
void	forEachLocalWebSocket(java.util.function.Consumer<WebSocket> consumer)
java.lang.String	getEngineid()
int	getLocalUserSize()
java.util.Collection<WebSocket>	getLocalWebSockets()
java.util.stream.Stream<WebSocket>	getLocalWebSockets(java.io.Serializable userid)
int	getLocalWebSocketSize()
int	getLocalWsmaxconns()
boolean	isLocalConnLimited()
java.util.concurrent.CompletableFuture<java.lang.Integer>	sendLocalAction(WebSocketAction action, java.io.Serializable... userids)
java.util.concurrent.CompletableFuture<java.lang.Integer>	sendLocalAction(WebSocketAction action, java.util.stream.Stream<? extends java.io.Serializable> userids)
java.util.concurrent.CompletableFuture<java.lang.Integer>	sendLocalMessage(java.lang.Object message, boolean last, java.io.Serializable... userids)
java.util.concurrent.CompletableFuture<java.lang.Integer>	sendLocalMessage(java.lang.Object message, boolean last, java.util.stream.Stream<? extends java.io.Serializable> userids)

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

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

字段详细资料

node

@Comment(value="\u5f53\u524dWebSocket\u5bf9\u5e94\u7684Node")
protected final WebSocketNode node

context

protected final HttpContext context

sendConvert

protected final Convert sendConvert

single

@Comment(value="\u662f\u5426\u5355\u7528\u6237\u5355\u8fde\u63a5")
protected final boolean single

currconns

@Comment(value="\u5f53\u524d\u8fde\u63a5\u6570")
protected final java.util.concurrent.atomic.AtomicInteger currconns

logger

@Comment(value="\u65e5\u5fd7")
protected final java.util.logging.Logger logger

liveinterval

@Comment(value="PING\u7684\u95f4\u9694\u79d2\u6570")
protected int liveinterval

wsmaxconns

@Comment(value="\u6700\u5927\u8fde\u63a5\u6570, \u4e3a0\u8868\u793a\u65e0\u9650\u5236")
protected int wsmaxconns

wsthreads

@Comment(value="\u64cd\u4f5cWebSocketNode\u5bf9\u5e94CacheSource\u5e76\u53d1\u6570, \u4e3a-1\u8868\u793a\u65e0\u9650\u5236\uff0c\u4e3a0\u8868\u793a\u7cfb\u7edf\u9ed8\u8ba4\u503c(CPU*8)")
protected int wsthreads

wsmaxbody

@Comment(value="\u6700\u5927\u6d88\u606f\u4f53\u957f\u5ea6, \u5c0f\u4e8e1\u8868\u793a\u65e0\u9650\u5236")
protected int wsmaxbody

mergemsg

@Comment(value="\u63a5\u6536\u5ba2\u6237\u7aef\u7684\u5206\u5305(last=false)\u6d88\u606f\u65f6\u662f\u5426\u81ea\u52a8\u5408\u5e76\u5305")
protected boolean mergemsg

cryptor

@Comment(value="\u52a0\u5bc6\u89e3\u5bc6\u5668")
protected Cryptor cryptor

构造器详细资料

WebSocketEngine

protected WebSocketEngine(java.lang.String engineid,
                          boolean single,
                          HttpContext context,
                          int liveinterval,
                          int wsmaxconns,
                          int wsthreads,
                          int wsmaxbody,
                          boolean mergemsg,
                          Cryptor cryptor,
                          WebSocketNode node,
                          Convert sendConvert,
                          java.util.logging.Logger logger)

方法详细资料

forceCloseLocalWebSocket

@Comment(value="\u5f3a\u5236\u5173\u95ed\u672c\u5730\u7528\u6237\u7684WebSocket")
public int forceCloseLocalWebSocket(java.io.Serializable userid)

broadcastLocalMessage

@Comment(value="\u7ed9\u6240\u6709\u8fde\u63a5\u7528\u6237\u53d1\u9001\u6d88\u606f")
public java.util.concurrent.CompletableFuture<java.lang.Integer> broadcastLocalMessage(java.lang.Object message,
                                                                                                                                                                             boolean last)

broadcastLocalMessage

@Comment(value="\u7ed9\u6307\u5b9aWebSocket\u8fde\u63a5\u7528\u6237\u53d1\u9001\u6d88\u606f")
public java.util.concurrent.CompletableFuture<java.lang.Integer> broadcastLocalMessage(WebSocketRange wsrange,
                                                                                                                                                                                      java.lang.Object message,
                                                                                                                                                                                      boolean last)

broadcastLocalMessage

@Comment(value="\u7ed9\u6307\u5b9aWebSocket\u8fde\u63a5\u7528\u6237\u53d1\u9001\u6d88\u606f")
public java.util.concurrent.CompletableFuture<java.lang.Integer> broadcastLocalMessage(java.util.function.Predicate<WebSocket> predicate,
                                                                                                                                                                                      java.lang.Object message,
                                                                                                                                                                                      boolean last)

sendLocalMessage

@Comment(value="\u7ed9\u6307\u5b9a\u7528\u6237\u7ec4\u53d1\u9001\u6d88\u606f")
public java.util.concurrent.CompletableFuture<java.lang.Integer> sendLocalMessage(java.lang.Object message,
                                                                                                                                                                  boolean last,
                                                                                                                                                                  java.util.stream.Stream<? extends java.io.Serializable> userids)

sendLocalMessage

@Comment(value="\u7ed9\u6307\u5b9a\u7528\u6237\u7ec4\u53d1\u9001\u6d88\u606f")
public java.util.concurrent.CompletableFuture<java.lang.Integer> sendLocalMessage(java.lang.Object message,
                                                                                                                                                                  boolean last,
                                                                                                                                                                  java.io.Serializable... userids)

broadcastLocalAction

@Comment(value="\u7ed9\u6307\u5b9aWebSocket\u8fde\u63a5\u7528\u6237\u53d1\u8d77\u64cd\u4f5c\u6307\u4ee4")
public java.util.concurrent.CompletableFuture<java.lang.Integer> broadcastLocalAction(WebSocketAction action)

sendLocalAction

@Comment(value="\u7ed9\u6307\u5b9a\u7528\u6237\u7ec4\u53d1\u9001\u64cd\u4f5c")
public java.util.concurrent.CompletableFuture<java.lang.Integer> sendLocalAction(WebSocketAction action,
                                                                                                                                                                 java.util.stream.Stream<? extends java.io.Serializable> userids)

sendLocalAction

@Comment(value="\u7ed9\u6307\u5b9a\u7528\u6237\u7ec4\u53d1\u9001\u64cd\u4f5c")
public java.util.concurrent.CompletableFuture<java.lang.Integer> sendLocalAction(WebSocketAction action,
                                                                                                                                                                 java.io.Serializable... userids)

getLocalWsmaxconns

@Comment(value="\u83b7\u53d6\u6700\u5927\u8fde\u63a5\u6570")
public int getLocalWsmaxconns()

isLocalConnLimited

@Comment(value="\u8fde\u63a5\u6570\u662f\u5426\u8fbe\u5230\u4e0a\u9650")
public boolean isLocalConnLimited()

getLocalWebSockets

@Comment(value="\u83b7\u53d6\u6240\u6709\u8fde\u63a5")
public java.util.Collection<WebSocket> getLocalWebSockets()

forEachLocalWebSocket

@Comment(value="\u83b7\u53d6\u6240\u6709\u8fde\u63a5")
public void forEachLocalWebSocket(java.util.function.Consumer<WebSocket> consumer)

getLocalWebSocketSize

@Comment(value="\u83b7\u53d6\u5f53\u524d\u8fde\u63a5\u603b\u6570")
public int getLocalWebSocketSize()

getLocalUserSize

@Comment(value="\u83b7\u53d6\u5f53\u524d\u7528\u6237\u603b\u6570")
public int getLocalUserSize()

findLocalWebSocket

@Comment(value="\u9002\u7528\u4e8e\u5355\u7528\u6237\u5355\u8fde\u63a5\u6a21\u5f0f")
public WebSocket findLocalWebSocket(java.io.Serializable userid)

getLocalWebSockets

@Comment(value="\u9002\u7528\u4e8e\u5355\u7528\u6237\u591a\u8fde\u63a5\u6a21\u5f0f")
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()