import org.apache.hadoop.ipc.protobuf.ProtocolInfoProtos.ProtocolSignatureProto; //导入依赖的package包/类
private static Map<Long, ProtocolSignature> 
convertProtocolSignatureProtos(List<ProtocolSignatureProto> protoList) {
  Map<Long, ProtocolSignature> map = new TreeMap<Long, ProtocolSignature>();
  for (ProtocolSignatureProto p : protoList) {
    int [] methods = new int[p.getMethodsList().size()];
    int index=0;
    for (int m : p.getMethodsList()) {
      methods[index++] = m;
    }
    map.put(p.getVersion(), new ProtocolSignature(p.getVersion(), methods));
  }
  return map;
}
 

import org.apache.hadoop.ipc.protobuf.ProtocolInfoProtos.ProtocolSignatureProto; //导入依赖的package包/类
@Override
public GetProtocolSignatureResponseProto getProtocolSignature(
    RpcController controller, GetProtocolSignatureRequestProto request)
    throws ServiceException {
  GetProtocolSignatureResponseProto.Builder builder = GetProtocolSignatureResponseProto
      .newBuilder();
  String protocol = request.getProtocol();
  String rpcKind = request.getRpcKind();
  long[] versions;
  try {
    versions = getProtocolVersionForRpcKind(RPC.RpcKind.valueOf(rpcKind),
        protocol);
  } catch (ClassNotFoundException e1) {
    throw new ServiceException(e1);
  }
  if (versions == null) {
    return builder.build();
  }
  for (long v : versions) {
    ProtocolSignatureProto.Builder sigBuilder = ProtocolSignatureProto
        .newBuilder();
    sigBuilder.setVersion(v);
    try {
      ProtocolSignature signature = ProtocolSignature.getProtocolSignature(
          protocol, v);
      for (int m : signature.getMethods()) {
        sigBuilder.addMethods(m);
      }
    } catch (ClassNotFoundException e) {
      throw new ServiceException(e);
    }
    builder.addProtocolSignature(sigBuilder.build());
  }
  return builder.build();
}
 

import org.apache.hadoop.ipc.protobuf.ProtocolInfoProtos.ProtocolSignatureProto; //导入依赖的package包/类
/**
 * Verify that ProtocolMetaInfoServerSideTranslatorPB correctly looks up
 * the server registry to extract protocol signatures and versions.
 */
@Test
public void testProtocolMetaInfoSSTranslatorPB() throws Exception {
  TestImpl1 impl = new TestImpl1();
  server = new RPC.Builder(conf).setProtocol(TestProtocol1.class)
      .setInstance(impl).setBindAddress(ADDRESS).setPort(0).setNumHandlers(2)
      .setVerbose(false).build();
  server.addProtocol(RPC.RpcKind.RPC_WRITABLE, TestProtocol0.class, impl);
  server.start();

  ProtocolMetaInfoServerSideTranslatorPB xlator = 
      new ProtocolMetaInfoServerSideTranslatorPB(server);

  GetProtocolSignatureResponseProto resp = xlator.getProtocolSignature(
      null,
      createGetProtocolSigRequestProto(TestProtocol1.class,
          RPC.RpcKind.RPC_PROTOCOL_BUFFER));
  //No signatures should be found
  Assert.assertEquals(0, resp.getProtocolSignatureCount());
  resp = xlator.getProtocolSignature(
      null,
      createGetProtocolSigRequestProto(TestProtocol1.class,
          RPC.RpcKind.RPC_WRITABLE));
  Assert.assertEquals(1, resp.getProtocolSignatureCount());
  ProtocolSignatureProto sig = resp.getProtocolSignatureList().get(0);
  Assert.assertEquals(TestProtocol1.versionID, sig.getVersion());
  boolean found = false;
  int expected = ProtocolSignature.getFingerprint(TestProtocol1.class
      .getMethod("echo", String.class));
  for (int m : sig.getMethodsList()) {
    if (expected == m) {
      found = true;
      break;
    }
  }
  Assert.assertTrue(found);
}