NameResolver - 类DirectAddressNameResolver
优质
小牛编辑
131浏览
2023-12-01
在类 AbstractManagedChannelImplBuilder 中有一个内部类,DirectAddressNameResolverFactory,这里实现了一个 NameResolver ,用于处理 DirectAddress。
Factory的代码
private static final String DIRECT_ADDRESS_SCHEME = "directaddress";
private static class DirectAddressNameResolverFactory extends NameResolver.Factory {
final SocketAddress address;
final String authority;
// 构造函数中直接提供 address 和 authority
DirectAddressNameResolverFactory(SocketAddress address, String authority) {
this.address = address;
this.authority = authority;
}
@Override
public NameResolver newNameResolver(URI notUsedUri, Attributes params) {
return new NameResolver() {
......// 细节后面看
}
}
@Override
public String getDefaultScheme() {
// 默认的scheme是固定的 "directaddress"
return DIRECT_ADDRESS_SCHEME;
}
}
NameResolver的实现
DirectAddressNameResolverFactory的NameResolver的实现是一个内部匿名类:
public NameResolver newNameResolver(URI notUsedUri, Attributes params) {
return new NameResolver() {
@Override
public String getServiceAuthority() {
// 直接返回factory中传入并保存的authority
return authority;
}
@Override
public void start(final Listener listener) {
// 不用解析,直接将 factory 中传入并保存的 address 给出去
listener.onAddresses(
Collections.singletonList(new EquivalentAddressGroup(address)),
Attributes.EMPTY);
}
@Override
public void shutdown() {}
};
}
总结
这个实现够简单,不过考虑到平时也是有需要用到直接地址的。