mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-08-08 10:22:12 +00:00
doc[zfoo]: 更新文档
This commit is contained in:
+13
-1
@@ -92,6 +92,18 @@ Javassist字节码增强序列化函数比反射快非常多
|
||||
|
||||
- net原理讲解
|
||||
- 知识点
|
||||
|
||||
```
|
||||
netty的nio,epoll
|
||||
同步和异步通过CompletableFuture去实现的
|
||||
一致性hash算法的负载均衡
|
||||
zookeeper的用法
|
||||
```
|
||||
|
||||
### [第十讲](https://www.bilibili.com/video/BV1rL411W7bo)
|
||||
|
||||
- 综合实战
|
||||
- 知识点
|
||||
|
||||
```
|
||||
netty的nio
|
||||
```
|
||||
@@ -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();
|
||||
|
||||
@@ -25,17 +25,6 @@
|
||||
<net:address name="${registry.address.name}" url="${registry.address.url}"/>
|
||||
</net:registry>
|
||||
|
||||
<net:monitor center="springboot" user="jaysunxiao" password="123456">
|
||||
<net:address name="firstSpringboot" url="127.0.0.1:8080"/>
|
||||
</net:monitor>
|
||||
|
||||
<net:host center="direct connect" user="jaysunxiao" password="123456">
|
||||
<net:address name="server0" url="127.0.0.1:9000"/>
|
||||
<net:address name="server1" url="127.0.0.1:9001"/>
|
||||
<net:address name="client0" url="127.0.0.1:9000"/>
|
||||
<net:address name="client1" url="127.0.0.1:9001"/>
|
||||
</net:host>
|
||||
|
||||
<net:provider dispatch="consistent-hash">
|
||||
<net:module name="providerTest"/>
|
||||
</net:provider>
|
||||
|
||||
Reference in New Issue
Block a user