程序包 | 说明 |
---|---|
org.redkale.boot.watch | |
org.redkale.net |
网络TCP/UDP基础服务包
|
org.redkale.net.http |
HTTP协议包,提供HTTP协议服务器
|
限定符和类型 | 字段和说明 |
---|---|
static int |
FilterWatchService.RET_FILTER_EXISTS |
static int |
FilterWatchService.RET_FILTER_JAR_ILLEGAL |
static int |
FilterWatchService.RET_FILTER_TYPE_ILLEGAL |
static int |
FilterWatchService.RET_FILTER_TYPE_NOT_EXISTS |
static int |
ServerWatchService.RET_SERVER_CHANGEPORT_ERROR |
static int |
ServerWatchService.RET_SERVER_NOT_EXISTS |
static int |
ServiceWatchService.RET_SERVICE_DEST_NOT_EXISTS |
static int |
SourceWatchService.RET_SOURCE_CHANGE_METHOD_NOT_EXISTS |
static int |
SourceWatchService.RET_SOURCE_METHOD_INVOKE_NOT_EXISTS |
static int |
SourceWatchService.RET_SOURCE_NOT_EXISTS |
static int |
TransportWatchService.RET_TRANSPORT_ADDR_EXISTS |
static int |
TransportWatchService.RET_TRANSPORT_ADDR_ILLEGAL |
static int |
TransportWatchService.RET_TRANSPORT_GROUP_NOT_EXISTS |
static int |
AbstractWatchService.RET_WATCH_PARAMS_ILLEGAL |
static int |
AbstractWatchService.RET_WATCH_RUN_EXCEPTION |
限定符和类型 | 字段和说明 |
---|---|
static int |
TransportFactory.DEFAULT_READTIMEOUTSECONDS |
static int |
TransportFactory.DEFAULT_WRITETIMEOUTSECONDS |
限定符和类型 | 字段和说明 |
---|---|
static int |
WebSocket.CLOSECODE_CLIENTCLOSE |
static int |
WebSocket.CLOSECODE_ILLPACKET |
static int |
WebSocket.CLOSECODE_SERVERCLOSE |
static int |
WebSocket.CLOSECODE_WSEXCEPTION |
protected java.lang.String |
HttpRequest.cookie |
protected Cryptor |
WebSocketEngine.cryptor |
protected java.util.concurrent.atomic.AtomicInteger |
WebSocketEngine.currconns |
static int |
WebSocketServlet.DEFAILT_LIVEINTERVAL |
protected int |
WebSocketEngine.liveinterval |
protected java.util.logging.Logger |
WebSocketEngine.logger |
protected boolean |
WebSocketEngine.mergemsg |
protected WebSocketNode |
WebSocketEngine.node |
static int |
WebSocket.RETCODE_DEAYSEND |
static int |
WebSocket.RETCODE_ENGINE_NULL |
static int |
WebSocket.RETCODE_GROUP_EMPTY |
static int |
WebSocket.RETCODE_ILLEGALBUFFER |
static int |
WebSocket.RETCODE_NODESERVICE_NULL |
static int |
WebSocket.RETCODE_SEND_ILLPACKET |
static int |
WebSocket.RETCODE_SENDEXCEPTION |
static int |
WebSocket.RETCODE_WSOCKET_CLOSED |
static int |
WebSocket.RETCODE_WSOFFLINE |
protected boolean |
WebSocketEngine.single |
static java.lang.String |
WebSocketNode.SOURCE_SNCP_ADDRS_KEY |
static java.lang.String |
WebSocketNode.SOURCE_SNCP_USERID_PREFIX |
static java.lang.String |
WebSocketServlet.WEBPARAM__CRYPTOR |
static java.lang.String |
WebSocketServlet.WEBPARAM__LIVEINTERVAL |
static java.lang.String |
WebSocketServlet.WEBPARAM__WSMAXBODY |
static java.lang.String |
WebSocketServlet.WEBPARAM__WSMAXCONNS |
static java.lang.String |
WebSocketServlet.WEBPARAM__WSMERGEMSG |
static java.lang.String |
WebSocketServlet.WEBPARAM__WSTHREADS |
protected int |
WebSocketEngine.wsmaxbody |
protected int |
WebSocketEngine.wsmaxconns |
protected int |
WebSocketEngine.wsthreads |
限定符和类型 | 方法和说明 |
---|---|
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.broadcastLocalAction(WebSocketAction action) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.broadcastLocalMessage(java.lang.Object message,
boolean last) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.broadcastLocalMessage(java.util.function.Predicate<WebSocket> predicate,
java.lang.Object message,
boolean last) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.broadcastLocalMessage(WebSocketRange wsrange,
java.lang.Object message,
boolean last) |
WebSocket |
WebSocketEngine.findLocalWebSocket(java.io.Serializable userid) |
int |
WebSocketEngine.forceCloseLocalWebSocket(java.io.Serializable userid) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocket.forceCloseWebSocket(java.io.Serializable userid)
强制关闭用户的所有WebSocket
|
void |
WebSocketEngine.forEachLocalWebSocket(java.util.function.Consumer<WebSocket> consumer) |
int |
WebSocketEngine.getLocalUserSize() |
java.util.Collection<WebSocket> |
WebSocketEngine.getLocalWebSockets() |
java.util.stream.Stream<WebSocket> |
WebSocketEngine.getLocalWebSockets(java.io.Serializable userid) |
int |
WebSocketEngine.getLocalWebSocketSize() |
int |
WebSocketEngine.getLocalWsmaxconns() |
boolean |
WebSocketEngine.isLocalConnLimited() |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.sendLocalAction(WebSocketAction action,
java.io.Serializable... userids) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.sendLocalAction(WebSocketAction action,
java.util.stream.Stream<? extends java.io.Serializable> userids) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.sendLocalMessage(java.lang.Object message,
boolean last,
java.io.Serializable... userids) |
java.util.concurrent.CompletableFuture<java.lang.Integer> |
WebSocketEngine.sendLocalMessage(java.lang.Object message,
boolean last,
java.util.stream.Stream<? extends java.io.Serializable> userids) |