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());