From 7e39546fcec7f82a9069de3a356f7932087b5df0 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Tue, 11 Dec 2018 19:47:40 +0800 Subject: [PATCH] --- net.html | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/net.html b/net.html index 03d4cc714..ed8af4659 100644 --- a/net.html +++ b/net.html @@ -572,7 +572,7 @@ //获取request创建时间 public long getCreatetime(); } - +

  . HttpResponse 对象

@@ -728,7 +728,7 @@ public void recycleListener(BiConsumer<HttpRequest, HttpResponse> recycleListener); } - +

  . WebSocket 对象

@@ -798,7 +798,13 @@ public CompletableFuture<Integer> broadcastMessage(final WebSocketRange wsrange, final Object message, boolean last); //给符合条件的人群广播消息, 返回结果0表示成功，非0表示错误码 - public CompletableFuture<Integer> broadcastMessage(WebSocketRange wsrange, final Convert convert, Object message, boolean last); + public CompletableFuture<Integer> broadcastMessage(WebSocketRange wsrange, Convert convert, final Object message, boolean last); + + //给指定userid的WebSocket节点发送操作 + public CompletableFuture<Integer> sendAction(final WebSocketAction action, Serializable... userids); + + //广播操作， 给所有人发操作指令 + public CompletableFuture<Integer> broadcastAction(final WebSocketAction action); //获取用户在线的SNCP节点地址列表，不是分布式则返回元素数量为1，且元素值为null的列表 public CompletableFuture<Collection<InetSocketAddress>> getRpcNodeAddresses(final Serializable userid); @@ -821,7 +827,6 @@ //更改本WebSocket的userid public CompletableFuture<Void> changeUserid(final G newuserid); - //获取指定userid的WebSocket数组, 没有返回null 此方法用于单用户多连接模式 protected Stream<WebSocket> getLocalWebSockets(G userid); @@ -839,7 +844,7 @@ //创建userid， null表示异常， 必须实现该方法 protected abstract CompletableFuture<G> createUserid(); - + //WebSocket.broadcastMessage时的过滤条件 protected boolean predicate(WebSocketRange wsrange); @@ -903,7 +908,7 @@ //WebSocket是否已关闭 public boolean isClosed(); } - +

SNCP 协议