Question

类NettyChannelProvider

用于创建 NettyChannelBuilder 实例的provider。

@Internal
public final class NettyChannelProvider extends ManagedChannelProvider {
  @Override
  public boolean isAvailable() {
    // 总是返回true
    return true;
  }
  @Override
  public int priority() {
    // 使用默认优先级 5
    return 5;
  }
  @Override
  public NettyChannelBuilder builderForAddress(String name, int port) {
    // 对接NettyChannelBuilder
    return NettyChannelBuilder.forAddress(name, port);
  }
  @Override
  public NettyChannelBuilder builderForTarget(String target) {
    // 对接NettyChannelBuilder
    return NettyChannelBuilder.forTarget(target);
  }
}

类OkHttpChannelProvider

用于创建 OkHttpChannelBuilder 实例的provider。

@Internal
public final class OkHttpChannelProvider extends ManagedChannelProvider {
  @Override
  public boolean isAvailable() {
    return true;
  }
  @Override
  public int priority() {
    // 会更加当前环境动态调整优先级
    // 如果是 IS_RESTRICTED_APPENGINE 或者 android 环境下，调整为 8, 此时优先级高于 netty(默认为5)
    // 其他情况下为 3, 此时优先级低于 netty(默认为5)
    return (GrpcUtil.IS_RESTRICTED_APPENGINE || isAndroid()) ? 8 : 3;
  }
  @Override
  public OkHttpChannelBuilder builderForAddress(String name, int port) {
    return OkHttpChannelBuilder.forAddress(name, port);
  }
  @Override
  public OkHttpChannelBuilder builderForTarget(String target) {
    return OkHttpChannelBuilder.forTarget(target);
  }
}

IS_RESTRICTED_APPENGINE的判断逻辑如下(和 google appengine 有关，细节不追究了)：

  public static final boolean IS_RESTRICTED_APPENGINE =
     "Production".equals(System.getProperty("com.google.appengine.runtime.environment"))
          && "1.7".equals(System.getProperty("java.specification.version"));

ServiceProvider 的实现

为了实现jdk的ServiceProvider，以便被load()函数装载，okjava 和 netty 在打包的时候都会按照JDK SPI的要求在他们的jar文件中加入SPI的内容，以netty为例：

上图是 grpc-java 中 netty 子项目的相关文件，在resources下的 META-INF.services 目录，存在一个名为 io.grpc.ManagedChannelProvider 文件，其内容为：

io.grpc.netty.NettyChannelProvider

总结

通过这种标准的SPI的方式，grpc实现了将 channel 的提供者和使用者分离并解藕。