From 221537df204dbd8a27cd766f9a41bfba13b206c9 Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Sun, 11 Jul 2021 10:59:10 +0800 Subject: [PATCH] =?UTF-8?q?doc[zfoo]:=20=E6=9B=B4=E6=96=B0=E6=96=87?= =?UTF-8?q?=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doc/视频教程.md | 14 +++++++++++++- .../core/tcp/server/TcpServerPacketController.java | 10 +++++----- .../test/resources/provider/provider_config.xml | 11 ----------- 3 files changed, 18 insertions(+), 17 deletions(-) diff --git a/doc/视频教程.md b/doc/视频教程.md index 11b04729..bf05210a 100644 --- a/doc/视频教程.md +++ b/doc/视频教程.md @@ -92,6 +92,18 @@ Javassist字节码增强序列化函数比反射快非常多 - net原理讲解 - 知识点 + +``` +netty的nio,epoll +同步和异步通过CompletableFuture去实现的 +一致性hash算法的负载均衡 +zookeeper的用法 +``` + +### [第十讲](https://www.bilibili.com/video/BV1rL411W7bo) + +- 综合实战 +- 知识点 + ``` -netty的nio ``` \ No newline at end of file diff --git a/net/src/test/java/com/zfoo/net/core/tcp/server/TcpServerPacketController.java b/net/src/test/java/com/zfoo/net/core/tcp/server/TcpServerPacketController.java index a518dba2..b82ee7fa 100644 --- a/net/src/test/java/com/zfoo/net/core/tcp/server/TcpServerPacketController.java +++ b/net/src/test/java/com/zfoo/net/core/tcp/server/TcpServerPacketController.java @@ -61,18 +61,18 @@ public class TcpServerPacketController { } - // client0->server0->server1->server0->client0 + // client->server1->server0->client @PacketReceiver public void atAsyncMess0Ask(Session session, AsyncMess0Ask ask0) { var ask1 = new AsyncMess1Ask(); ask1.setMessage("Hello, server0 -> server1"); - var server1 = NetContext.getSessionManager().getClientSession(0L); - NetContext.getDispatcher().asyncAsk(server1, ask1, AsyncMess1Answer.class, null) + var client0 = NetContext.getSessionManager().getClientSession(0L); + NetContext.getDispatcher().asyncAsk(client0, ask1, AsyncMess1Answer.class, null) .whenComplete(sm_asyncMess0 -> { var answer = new AsyncMess0Answer(); - answer.setMessage("Hello, server0 -> client0!"); + answer.setMessage("Hello, server1 -> client!"); NetContext.getDispatcher().send(session, answer); }); @@ -85,7 +85,7 @@ public class TcpServerPacketController { // 测试正常返回 var answer = new AsyncMess1Answer(); - answer.setMessage("Hello, server1 -> server0!"); + answer.setMessage("Hello, server0 -> server1!"); // 测试返回不是预期的消息 // SM_Int sm = new SM_Int(); diff --git a/net/src/test/resources/provider/provider_config.xml b/net/src/test/resources/provider/provider_config.xml index dedde153..302f6a40 100644 --- a/net/src/test/resources/provider/provider_config.xml +++ b/net/src/test/resources/provider/provider_config.xml @@ -25,17 +25,6 @@ - - - - - - - - - - -