This commit is contained in:
17
net.html
17
net.html
@@ -572,7 +572,7 @@
|
||||
<span class="c1">//获取request创建时间</span>
|
||||
<span class="kd">public</span> <span class="kt">long</span> <span class="nf">getCreatetime</span><span class="o">();</span>
|
||||
<span class="o">}</span>
|
||||
</pre></div>
|
||||
</pre></div>
|
||||
|
||||
|
||||
<p id="net_httpresponse"> <b>. HttpResponse 对象</b> </p>
|
||||
@@ -728,7 +728,7 @@
|
||||
<span class="kd">public</span> <span class="kt">void</span> <span class="nf">recycleListener</span><span class="o">(</span><span class="n">BiConsumer</span><span class="o"><</span><span class="n">HttpRequest</span><span class="o">,</span> <span class="n">HttpResponse</span><span class="o">></span> <span class="n">recycleListener</span><span class="o">);</span>
|
||||
|
||||
<span class="o">}</span>
|
||||
</pre></div>
|
||||
</pre></div>
|
||||
|
||||
|
||||
<p id="net_websocket"> <b>. WebSocket 对象</b> </p>
|
||||
@@ -798,7 +798,13 @@
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="nf">broadcastMessage</span><span class="o">(</span><span class="kd">final</span> <span class="n">WebSocketRange</span> <span class="n">wsrange</span><span class="o">,</span> <span class="kd">final</span> <span class="n">Object</span> <span class="n">message</span><span class="o">,</span> <span class="kt">boolean</span> <span class="n">last</span><span class="o">);</span>
|
||||
|
||||
<span class="c1">//给符合条件的人群广播消息, 返回结果0表示成功,非0表示错误码</span>
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="nf">broadcastMessage</span><span class="o">(</span><span class="n">WebSocketRange</span> <span class="n">wsrange</span><span class="o">,</span> <span class="kd">final</span> <span class="n">Convert</span> <span class="n">convert</span><span class="o">,</span> <span class="n">Object</span> <span class="n">message</span><span class="o">,</span> <span class="kt">boolean</span> <span class="n">last</span><span class="o">);</span>
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="nf">broadcastMessage</span><span class="o">(</span><span class="n">WebSocketRange</span> <span class="n">wsrange</span><span class="o">,</span> <span class="n">Convert</span> <span class="n">convert</span><span class="o">,</span> <span class="kd">final</span> <span class="n">Object</span> <span class="n">message</span><span class="o">,</span> <span class="kt">boolean</span> <span class="n">last</span><span class="o">);</span>
|
||||
|
||||
<span class="c1">//给指定userid的WebSocket节点发送操作</span>
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="nf">sendAction</span><span class="o">(</span><span class="kd">final</span> <span class="n">WebSocketAction</span> <span class="n">action</span><span class="o">,</span> <span class="n">Serializable</span><span class="o">...</span> <span class="n">userids</span><span class="o">);</span>
|
||||
|
||||
<span class="c1">//广播操作, 给所有人发操作指令</span>
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="nf">broadcastAction</span><span class="o">(</span><span class="kd">final</span> <span class="n">WebSocketAction</span> <span class="n">action</span><span class="o">);</span>
|
||||
|
||||
<span class="c1">//获取用户在线的SNCP节点地址列表,不是分布式则返回元素数量为1,且元素值为null的列表</span>
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Collection</span><span class="o"><</span><span class="n">InetSocketAddress</span><span class="o">>></span> <span class="nf">getRpcNodeAddresses</span><span class="o">(</span><span class="kd">final</span> <span class="n">Serializable</span> <span class="n">userid</span><span class="o">);</span>
|
||||
@@ -821,7 +827,6 @@
|
||||
<span class="c1">//更改本WebSocket的userid</span>
|
||||
<span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Void</span><span class="o">></span> <span class="nf">changeUserid</span><span class="o">(</span><span class="kd">final</span> <span class="n">G</span> <span class="n">newuserid</span><span class="o">);</span>
|
||||
|
||||
|
||||
<span class="c1">//获取指定userid的WebSocket数组, 没有返回null 此方法用于单用户多连接模式</span>
|
||||
<span class="kd">protected</span> <span class="n">Stream</span><span class="o"><</span><span class="n">WebSocket</span><span class="o">></span> <span class="nf">getLocalWebSockets</span><span class="o">(</span><span class="n">G</span> <span class="n">userid</span><span class="o">);</span>
|
||||
|
||||
@@ -839,7 +844,7 @@
|
||||
|
||||
<span class="c1">//创建userid, null表示异常, 必须实现该方法</span>
|
||||
<span class="kd">protected</span> <span class="kd">abstract</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">G</span><span class="o">></span> <span class="nf">createUserid</span><span class="o">();</span>
|
||||
|
||||
|
||||
<span class="c1">//WebSocket.broadcastMessage时的过滤条件</span>
|
||||
<span class="kd">protected</span> <span class="kt">boolean</span> <span class="nf">predicate</span><span class="o">(</span><span class="n">WebSocketRange</span> <span class="n">wsrange</span><span class="o">);</span>
|
||||
|
||||
@@ -903,7 +908,7 @@
|
||||
<span class="c1">//WebSocket是否已关闭</span>
|
||||
<span class="kd">public</span> <span class="kt">boolean</span> <span class="nf">isClosed</span><span class="o">();</span>
|
||||
<span class="o">}</span>
|
||||
</pre></div>
|
||||
</pre></div>
|
||||
|
||||
<h3><a id="net_sncp" class="anchor" href="#" aria-hidden="true"></a>SNCP 协议</h3>
|
||||
<p>
|
||||
|
||||
Reference in New Issue
Block a user