mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-18 09:26:32 +00:00
doc[net]: 更新文档注释
This commit is contained in:
@@ -48,7 +48,7 @@ public class NetAutoConfiguration {
|
||||
|
||||
@Bean
|
||||
@ConditionalOnMissingBean
|
||||
public Router packetDispatcher() {
|
||||
public Router router() {
|
||||
return new Router();
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,7 @@ import java.util.concurrent.TimeoutException;
|
||||
/**
|
||||
* 服务调度和负载均衡,两个关键点:摘除故障节点,负载均衡
|
||||
* <p>
|
||||
* 在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);
|
||||
|
||||
@@ -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());
|
||||
|
||||
Reference in New Issue
Block a user