org.apache.hadoop.ipc.RPC.getProtocolVersion()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(152)

本文整理了Java中org.apache.hadoop.ipc.RPC.getProtocolVersion方法的一些代码示例，展示了RPC.getProtocolVersion的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RPC.getProtocolVersion方法的具体详情如下：
包路径：org.apache.hadoop.ipc.RPC
类名称：RPC
方法名：getProtocolVersion

RPC.getProtocolVersion介绍

[英]Get the protocol version from protocol class. If the protocol class has a ProtocolAnnotation, then get the protocol name from the annotation; otherwise the class name is the protocol name.
[中]从协议类获取协议版本。如果协议类有ProtocolAnnotation，则从该注释中获取协议名称；否则，类名就是协议名。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public long getProtocolVersion(String protocol, long clientVersion)
  throws IOException {
 return RPC.getProtocolVersion(ZKFCProtocolPB.class);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public long getProtocolVersion(String protocol, long clientVersion)
  throws IOException {
 return RPC.getProtocolVersion(HAServiceProtocolPB.class);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
   GenericRefreshProtocolPB.class,
   RPC.RpcKind.RPC_PROTOCOL_BUFFER,
   RPC.getProtocolVersion(GenericRefreshProtocolPB.class),
   methodName);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
    RefreshAuthorizationPolicyProtocolPB.class,
    RPC.RpcKind.RPC_PROTOCOL_BUFFER,
    RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
    methodName);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
    GetUserMappingsProtocolPB.class, RPC.RpcKind.RPC_PROTOCOL_BUFFER,
    RPC.getProtocolVersion(GetUserMappingsProtocolPB.class), methodName);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
    RefreshCallQueueProtocolPB.class,
    RPC.RpcKind.RPC_PROTOCOL_BUFFER,
    RPC.getProtocolVersion(RefreshCallQueueProtocolPB.class),
    methodName);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil
    .isMethodSupported(rpcProxy, RefreshUserMappingsProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshUserMappingsProtocolPB.class),
      methodName);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

public Invocation(Method method, Object[] parameters) {
 this.methodName = method.getName();
 this.parameterClasses = method.getParameterTypes();
 this.parameters = parameters;
 rpcVersion = writableRpcVersion;
 if (method.getDeclaringClass().equals(VersionedProtocol.class)) {
  //VersionedProtocol is exempted from version check.
  clientVersion = 0;
  clientMethodsHash = 0;
 } else {
  this.clientVersion = RPC.getProtocolVersion(method.getDeclaringClass());
  this.clientMethodsHash = ProtocolSignature.getFingerprint(method
    .getDeclaringClass().getMethods());
 }
 this.declaringClassProtocolName = 
   RPC.getProtocolName(method.getDeclaringClass());
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

public ZKFCProtocolClientSideTranslatorPB(
  InetSocketAddress addr, Configuration conf,
  SocketFactory socketFactory, int timeout) throws IOException {
 RPC.setProtocolEngine(conf, ZKFCProtocolPB.class,
   ProtobufRpcEngine.class);
 rpcProxy = RPC.getProxy(ZKFCProtocolPB.class,
   RPC.getProtocolVersion(ZKFCProtocolPB.class), addr,
   UserGroupInformation.getCurrentUser(), conf, socketFactory, timeout);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

public HAServiceProtocolClientSideTranslatorPB(
  InetSocketAddress addr, Configuration conf,
  SocketFactory socketFactory, int timeout) throws IOException {
 RPC.setProtocolEngine(conf, HAServiceProtocolPB.class,
   ProtobufRpcEngine.class);
 rpcProxy = RPC.getProxy(HAServiceProtocolPB.class,
   RPC.getProtocolVersion(HAServiceProtocolPB.class), addr,
   UserGroupInformation.getCurrentUser(), conf, socketFactory, timeout);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

/**
 * This constructor takes a connectionId, instead of creating a new one.
 */
private Invoker(Class<?> protocol, Client.ConnectionId connId,
  Configuration conf, SocketFactory factory) {
 this.remoteId = connId;
 this.client = CLIENTS.getClient(conf, factory, RpcWritable.Buffer.class);
 this.protocolName = RPC.getProtocolName(protocol);
 this.clientProtocolVersion = RPC
   .getProtocolVersion(protocol);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public ProtocolSignature getProtocolSignature(String protocol,
  long clientVersion, int clientMethodsHash) throws IOException {
 if (!protocol.equals(RPC.getProtocolName(ZKFCProtocolPB.class))) {
  throw new IOException("Serverside implements " +
    RPC.getProtocolName(ZKFCProtocolPB.class) +
    ". The following requested protocol is unknown: " + protocol);
 }
 return ProtocolSignature.getProtocolSignature(clientMethodsHash,
   RPC.getProtocolVersion(ZKFCProtocolPB.class),
   HAServiceProtocolPB.class);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

public HAServiceProtocolClientSideTranslatorPB(InetSocketAddress addr,
  Configuration conf) throws IOException {
 RPC.setProtocolEngine(conf, HAServiceProtocolPB.class,
   ProtobufRpcEngine.class);
 rpcProxy = RPC.getProxy(HAServiceProtocolPB.class,
   RPC.getProtocolVersion(HAServiceProtocolPB.class), addr, conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public ProtocolSignature getProtocolSignature(String protocol,
     long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(TraceAdminProtocolPB.class))) {
   throw new IOException("Serverside implements " +
     RPC.getProtocolName(TraceAdminProtocolPB.class) +
     ". The following requested protocol is unknown: " + protocol);
  }
  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
    RPC.getProtocolVersion(TraceAdminProtocolPB.class),
    TraceAdminProtocolPB.class);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public ProtocolSignature getProtocolSignature(String protocol,
   long clientVersion, int clientMethodsHash) throws IOException {
  if (!protocol.equals(RPC.getProtocolName(HAServiceProtocolPB.class))) {
   throw new IOException("Serverside implements " +
     RPC.getProtocolName(HAServiceProtocolPB.class) +
     ". The following requested protocol is unknown: " + protocol);
  }

  return ProtocolSignature.getProtocolSignature(clientMethodsHash,
    RPC.getProtocolVersion(HAServiceProtocolPB.class),
    HAServiceProtocolPB.class);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

void registerProtocolAndImpl(RpcKind rpcKind, Class<?> protocolClass, 
  Object protocolImpl) {
 String protocolName = RPC.getProtocolName(protocolClass);
 long version;
  try {
  version = RPC.getProtocolVersion(protocolClass);
 } catch (Exception ex) {
  LOG.warn("Protocol "  + protocolClass + 
    " NOT registered as cannot get protocol version ");
  return;
 }
 getProtocolImplMap(rpcKind).put(new ProtoNameVer(protocolName, version),
   new ProtoClassProtoImpl(protocolClass, protocolImpl)); 
 if (LOG.isDebugEnabled()) {
  LOG.debug("RpcKind = " + rpcKind + " Protocol Name = " + protocolName +
    " version=" + version +
    " ProtocolImpl=" + protocolImpl.getClass().getName() +
    " protocolClass=" + protocolClass.getName());
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

private void fetchServerMethods(Method method) throws IOException {
 long clientVersion;
 clientVersion = RPC.getProtocolVersion(method.getDeclaringClass());
 int clientMethodsHash = ProtocolSignature.getFingerprint(method
   .getDeclaringClass().getMethods());
 ProtocolSignature serverInfo = ((VersionedProtocol) proxy)
   .getProtocolSignature(RPC.getProtocolName(protocol), clientVersion,
     clientMethodsHash);
 long serverVersion = serverInfo.getVersion();
 if (serverVersion != clientVersion) {
  throw new RPC.VersionMismatch(protocol.getName(), clientVersion,
    serverVersion);
 }
 int[] serverMethodsCodes = serverInfo.getMethods();
 if (serverMethodsCodes != null) {
  serverMethods = new HashSet<Integer>(serverMethodsCodes.length);
  for (int m : serverMethodsCodes) {
   this.serverMethods.add(Integer.valueOf(m));
  }
 }
 serverMethodsFetched = true;
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

Class<?> xface = TraceAdminProtocolPB.class;
proxy = (TraceAdminProtocolPB)RPC.getProxy(xface,
  RPC.getProtocolVersion(xface), address,
  ugi, getConf(), NetUtils.getDefaultSocketFactory(getConf()), 0);
remote = new TraceAdminProtocolTranslatorPB(proxy);

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

public boolean isMethodSupported(String methodName) throws IOException {
 return RpcClientUtil.isMethodSupported(rpcProxy,
   QJournalProtocolPB.class, RPC.RpcKind.RPC_PROTOCOL_BUFFER,
   RPC.getProtocolVersion(QJournalProtocolPB.class), methodName);
}

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

private static DatanodeLifelineProtocolPB createNamenode(
  InetSocketAddress nameNodeAddr, Configuration conf,
  UserGroupInformation ugi) throws IOException {
 return RPC.getProxy(DatanodeLifelineProtocolPB.class,
   RPC.getProtocolVersion(DatanodeLifelineProtocolPB.class), nameNodeAddr,
   ugi, conf,
   NetUtils.getSocketFactory(conf, DatanodeLifelineProtocolPB.class));
}

内容来源于网络，如有侵权，请联系作者删除！

rpc

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com