类AbstractStub
类AbstractStub是stub实现的通用基类。
类AbstractStub也是生成代码中的stub类的通用基类。这个类容许重定义,例如,添加拦截器到stub。
类定义
package io.grpc.stub;
public abstract class AbstractStub<S extends AbstractStub<S>> {
}
属性和构造函数
类AbstractStub有两个属性:
- Channel channel
- CallOptions callOptions
private final Channel channel;
private final CallOptions callOptions;
protected AbstractStub(Channel channel) {
this(channel, CallOptions.DEFAULT);
}
protected AbstractStub(Channel channel, CallOptions callOptions) {
this.channel = channel;
this.callOptions = callOptions;
}
注: 类CallOptions 的内容见 这里
方法
build()抽象方法
定义了抽象方法build()方法来返回一个新的stub,使用给定的Channel和提供的方法配置。
protected abstract S build(Channel channel, CallOptions callOptions);
- channel: 返回的新的stub将使用这个Channel来做通讯。
- callOptions: 运行时调用选项,将被应用于这个stub的每次调用。(也就是说这个不可变的callOptions实例之后将在每次调用中重用)
with方法族
定义有多个with×××()方法,通过创建新的 CallOptions 实例,然后调用上面的build()方法来返回一个新的stub:
public final S withDeadlineNanoTime(@Nullable Long deadlineNanoTime) {
return build(channel, callOptions.withDeadlineNanoTime(deadlineNanoTime));
}
public final S withDeadlineAfter(long duration, TimeUnit unit) {
return build(channel, callOptions.withDeadlineAfter(duration, unit));
}
@ExperimentalApi
public final S withCompression(String compressorName) {
return build(channel, callOptions.withCompression(compressorName));
}
也可以替换使用新的Channel,或者在原有的Channel上添加拦截器:
public final S withChannel(Channel newChannel) {
return build(newChannel, callOptions);
}
public final S withInterceptors(ClientInterceptor... interceptors) {
return build(ClientInterceptors.intercept(channel, interceptors), callOptions);
}