From d7fef2489be94ca8b91cfbe3eff7ef4148208a89 Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Thu, 14 Oct 2021 13:56:17 +0800 Subject: [PATCH] =?UTF-8?q?doc[net]:=20=E6=9B=B4=E6=96=B0=E6=96=87?= =?UTF-8?q?=E6=A1=A3=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- boot/src/main/java/com/zfoo/boot/NetAutoConfiguration.java | 2 +- net/src/main/java/com/zfoo/net/consumer/Consumer.java | 4 ++-- .../main/java/com/zfoo/net/schema/NetDefinitionParser.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/boot/src/main/java/com/zfoo/boot/NetAutoConfiguration.java b/boot/src/main/java/com/zfoo/boot/NetAutoConfiguration.java index 755bb9cb..9d1be7ee 100644 --- a/boot/src/main/java/com/zfoo/boot/NetAutoConfiguration.java +++ b/boot/src/main/java/com/zfoo/boot/NetAutoConfiguration.java @@ -48,7 +48,7 @@ public class NetAutoConfiguration { @Bean @ConditionalOnMissingBean - public Router packetDispatcher() { + public Router router() { return new Router(); } diff --git a/net/src/main/java/com/zfoo/net/consumer/Consumer.java b/net/src/main/java/com/zfoo/net/consumer/Consumer.java index 543f4d1b..d3a52182 100644 --- a/net/src/main/java/com/zfoo/net/consumer/Consumer.java +++ b/net/src/main/java/com/zfoo/net/consumer/Consumer.java @@ -38,7 +38,7 @@ import java.util.concurrent.TimeoutException; /** * 服务调度和负载均衡，两个关键点：摘除故障节点，负载均衡 *

- * 在clientSession中选择一个可用的session，最终还是调用的IPacketDispatcherManager中的方法 + * 在clientSession中选择一个可用的session，最终还是调用的IRouter中的方法 * * @author jaysunxiao * @version 3.0 @@ -66,7 +66,7 @@ public class Consumer implements IConsumer { var session = loadBalancer.loadBalancer(packet, argument); - // 下面的代码逻辑同PacketDispatcher的syncAsk，如果修改的话，记得一起修改 + // 下面的代码逻辑同Router的syncAsk，如果修改的话，记得一起修改 var clientAttachment = new SignalPacketAttachment(); var executorConsistentHash = (argument == null) ? RandomUtils.randomInt() : HashUtils.fnvHash(argument); clientAttachment.setExecutorConsistentHash(executorConsistentHash); diff --git a/net/src/main/java/com/zfoo/net/schema/NetDefinitionParser.java b/net/src/main/java/com/zfoo/net/schema/NetDefinitionParser.java index 8698fbd9..714676b3 100644 --- a/net/src/main/java/com/zfoo/net/schema/NetDefinitionParser.java +++ b/net/src/main/java/com/zfoo/net/schema/NetDefinitionParser.java @@ -64,7 +64,7 @@ public class NetDefinitionParser implements BeanDefinitionParser { builder = BeanDefinitionBuilder.rootBeanDefinition(clazz); parserContext.getRegistry().registerBeanDefinition(clazz.getCanonicalName(), builder.getBeanDefinition()); - // 注册PacketDispatcherManager + // 注册Router clazz = Router.class; builder = BeanDefinitionBuilder.rootBeanDefinition(clazz); parserContext.getRegistry().registerBeanDefinition(clazz.getCanonicalName(), builder.getBeanDefinition());