【发布时间】:2022-01-17 21:54:26
【问题描述】:
我不确定我是否正确理解了通道和客户端负载平衡在 grpc 中的工作方式。我所做的一切都是基于one tutorial。
我有几台服务器要处理请求。我写了一个简单的 NameResolverProvider。
public class BalancingNameResolverProvider extends NameResolverProvider {
private Set<String> replicas;
private Optional<Map<String, Object>> config;
private String schema;
private int priority = 5;
public BalancingNameResolverProvider(Set<String> replicas, Optional<Map<String, Object>> config, String schema, int priority) {
this.replicas = replicas;
this.config = config;
this.schema = schema;
this.priority = priority;
}
@Override
protected boolean isAvailable() {
return true;
}
@Override
protected int priority() {
return priority;
}
@Override
public NameResolver newNameResolver(URI targetUri, NameResolver.Args args) {
List<EquivalentAddressGroup> delegates = replicas.stream()
.map(x -> new InetSocketAddress(x.split(":")[0], Integer.parseInt(x.split(":")[1])))
.map(EquivalentAddressGroup::new)
.collect(Collectors.toList());
return new NameResolver() {
private Optional<NameResolver.ConfigOrError> parsedConfig = config.map(x ->
args.getServiceConfigParser().parseServiceConfig(x)
);
@Override
public String getServiceAuthority() {
return targetUri.getAuthority();
}
@Override
public void shutdown() {
}
@Override
public void start(final NameResolver.Listener2 listener) {
ResolutionResult.Builder builder = ResolutionResult.newBuilder()
.setAddresses(delegates)
.setAttributes(Attributes.EMPTY);
parsedConfig.ifPresent(builder::setServiceConfig);
listener.onResult(builder.build());
}
};
}
@Override
public String getDefaultScheme() {
return schema;
}
}
我写了一个简单的客户端。
NameResolverRegistry.getDefaultRegistry().register(resolverConfig.toProvider());
ManagedChannel channel = NettyChannelBuilder
.forTarget("???") //or forAddress("???")
.enableRetry()
.usePlaintext()
.build();
try {
HelloServiceGrpc.HelloServiceBlockingStub client = HelloServiceGrpc.newBlockingStub(channel);
for (int i = 0; i < count; i++) {
System.out.println(client.hello(HelloRequest.newBuilder()
.setFirstName("first_" + i)
.setLastName("lastName_" + i)
.build())
.getGreeting());
}
} finally {
channel.shutdown();
}
但在我查看的所有手册中,要么为通道(forAddress)指定了一个主机和端口,要么在“forTarget()”中指定了某个名称。
但是我有好几台服务器,我该如何指定它们?
在什么时候选择服务器?我正确理解 NameResolverProvider 参与其中,我在其中指定了服务器列表
我使用 round_robin 策略。也许我不需要 NameResolverProvider?
编辑
为了使用dns,我添加了DnsNameResolverProvider。
NameResolverRegistry.getDefaultRegistry().register(new DnsNameResolverProvider());
但我还不明白如何指定两个服务器,例如,forAddress
或forTarget
中的地址为first.example.com:5000
和second.example.com:5001
。会是什么样子?
【问题讨论】: