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) |
@Comment(value="\u5f53\u524dWebSocket\u5bf9\u5e94\u7684Node") protected final WebSocketNode node
protected final HttpContext context
protected final Convert sendConvert
@Comment(value="\u662f\u5426\u5355\u7528\u6237\u5355\u8fde\u63a5") protected final boolean single
@Comment(value="\u5f53\u524d\u8fde\u63a5\u6570") protected final java.util.concurrent.atomic.AtomicInteger currconns
@Comment(value="\u6700\u5927\u8fde\u63a5\u6570, \u4e3a0\u8868\u793a\u65e0\u9650\u5236") protected int wsmaxconns
@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
@Comment(value="\u6700\u5927\u6d88\u606f\u4f53\u957f\u5ea6, \u5c0f\u4e8e1\u8868\u793a\u65e0\u9650\u5236") protected int wsmaxbody
@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
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)
@Comment(value="\u5f3a\u5236\u5173\u95ed\u672c\u5730\u7528\u6237\u7684WebSocket") public int forceCloseLocalWebSocket(java.io.Serializable userid)
@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)
@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)
@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)
@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)
@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)
@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)
@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)
@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)
@Comment(value="\u83b7\u53d6\u6700\u5927\u8fde\u63a5\u6570") public int getLocalWsmaxconns()
@Comment(value="\u8fde\u63a5\u6570\u662f\u5426\u8fbe\u5230\u4e0a\u9650") public boolean isLocalConnLimited()
@Comment(value="\u83b7\u53d6\u6240\u6709\u8fde\u63a5") public java.util.Collection<WebSocket> getLocalWebSockets()
@Comment(value="\u83b7\u53d6\u6240\u6709\u8fde\u63a5") public void forEachLocalWebSocket(java.util.function.Consumer<WebSocket> consumer)
@Comment(value="\u83b7\u53d6\u5f53\u524d\u8fde\u63a5\u603b\u6570") public int getLocalWebSocketSize()
@Comment(value="\u83b7\u53d6\u5f53\u524d\u7528\u6237\u603b\u6570") public int getLocalUserSize()
@Comment(value="\u9002\u7528\u4e8e\u5355\u7528\u6237\u5355\u8fde\u63a5\u6a21\u5f0f") public WebSocket findLocalWebSocket(java.io.Serializable userid)
@Comment(value="\u9002\u7528\u4e8e\u5355\u7528\u6237\u591a\u8fde\u63a5\u6a21\u5f0f") public java.util.stream.Stream<WebSocket> getLocalWebSockets(java.io.Serializable userid)
public boolean existsLocalWebSocket(java.io.Serializable userid)
public java.lang.String getEngineid()