diff --git a/test/org/redkale/test/http/WebSocketDesc.java b/test/org/redkale/test/http/WebSocketDesc.java index 85f4080bc..c7ff624d4 100644 --- a/test/org/redkale/test/http/WebSocketDesc.java +++ b/test/org/redkale/test/http/WebSocketDesc.java @@ -87,6 +87,12 @@ public interface WebSocketDesc { //给符合条件的人群广播消息, 返回结果0表示成功,非0表示错误码 public CompletableFuture broadcastMessage(WebSocketRange wsrange, Convert convert, final Object message, boolean last); + //给指定userid的WebSocket节点发送操作 + public CompletableFuture sendAction(final WebSocketAction action, Serializable... userids); + + //广播操作, 给所有人发操作指令 + public CompletableFuture broadcastAction(final WebSocketAction action); + //获取用户在线的SNCP节点地址列表,不是分布式则返回元素数量为1,且元素值为null的列表 public CompletableFuture> getRpcNodeAddresses(final Serializable userid); @@ -120,16 +126,19 @@ public interface WebSocketDesc { //获取当前进程节点所有在线的WebSocket /* protected */ Collection getLocalWebSockets(); + //获取ByteBuffer资源池 /* protected */ Supplier getByteBufferSupplier(); + //返回sessionid, null表示连接不合法或异常,默认实现是request.sessionid(true),通常需要重写该方法 /* protected */ CompletableFuture onOpen(final HttpRequest request); //创建userid, null表示异常, 必须实现该方法 /* protected abstract */ CompletableFuture createUserid(); - + + //WebSocket.broadcastMessage时的过滤条件 /* protected */ boolean predicate(WebSocketRange wsrange);