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

RPC.getConnectionIdForProxy介绍

[英]Return the connection ID of the given object. If the provided object is in fact a protocol translator, we'll get the connection ID of the underlying proxy object.
[中]返回给定对象的连接ID。如果提供的对象实际上是协议转换器，我们将获得底层代理对象的连接ID。

代码示例

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

@Override //RpcInvocationHandler
 public ConnectionId getConnectionId() {
  return RPC.getConnectionIdForProxy(proxyDescriptor.getProxy());
 }
}

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

/**
 * Returns the server address for a given proxy.
 */
public static InetSocketAddress getServerAddress(Object proxy) {
 return getConnectionIdForProxy(proxy).getAddress();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override //RpcInvocationHandler
public ConnectionId getConnectionId() {
 return RPC.getConnectionIdForProxy(currentProxy.proxy);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override //RpcInvocationHandler
public ConnectionId getConnectionId() {
 return RPC.getConnectionIdForProxy(currentProxy.proxy);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override //RpcInvocationHandler
public ConnectionId getConnectionId() {
 return RPC.getConnectionIdForProxy(currentProxy.proxy);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

/**
 * Returns the server address for a given proxy.
 */
public static InetSocketAddress getServerAddress(Object proxy) {
 return getConnectionIdForProxy(proxy).getAddress();
}

代码示例来源：origin: io.hops/hadoop-common

/**
 * Returns the server address for a given proxy.
 */
public static InetSocketAddress getServerAddress(Object proxy) {
 return getConnectionIdForProxy(proxy).getAddress();
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * Returns the server address for a given proxy.
 */
public static InetSocketAddress getServerAddress(Object proxy) {
 return getConnectionIdForProxy(proxy).getAddress();
}

代码示例来源：origin: io.hops/hadoop-common

@Override //RpcInvocationHandler
 public ConnectionId getConnectionId() {
  return RPC.getConnectionIdForProxy(proxyDescriptor.getProxy());
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

/**
 * Returns the server address for a given proxy.
 */
public static InetSocketAddress getServerAddress(Object proxy) {
 return getConnectionIdForProxy(proxy).getAddress();
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

private void doDigestRpc(Server server, TestTokenSecretManager sm
             ) throws Exception {
 server.start();
 final UserGroupInformation current = UserGroupInformation.getCurrentUser();
 final InetSocketAddress addr = NetUtils.getConnectAddress(server);
 TestTokenIdentifier tokenId = new TestTokenIdentifier(new Text(current
   .getUserName()));
 Token<TestTokenIdentifier> token = new Token<TestTokenIdentifier>(tokenId,
   sm);
 SecurityUtil.setTokenService(token, addr);
 current.addToken(token);
 TestSaslProtocol proxy = null;
 try {
  proxy = RPC.getProxy(TestSaslProtocol.class,
    TestSaslProtocol.versionID, addr, conf);
  AuthMethod authMethod = proxy.getAuthMethod();
  assertEquals(TOKEN, authMethod);
  //QOP must be auth
  assertEquals(expectedQop.saslQop,
         RPC.getConnectionIdForProxy(proxy).getSaslQop());            
  proxy.ping();
 } finally {
  server.stop();
  if (proxy != null) {
   RPC.stopProxy(proxy);
  }
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

private void doDigestRpc(Server server, TestTokenSecretManager sm
             ) throws Exception {
 server.start();
 final UserGroupInformation current = UserGroupInformation.getCurrentUser();
 final InetSocketAddress addr = NetUtils.getConnectAddress(server);
 TestTokenIdentifier tokenId = new TestTokenIdentifier(new Text(current
   .getUserName()));
 Token<TestTokenIdentifier> token = new Token<TestTokenIdentifier>(tokenId,
   sm);
 SecurityUtil.setTokenService(token, addr);
 current.addToken(token);
 TestSaslProtocol proxy = null;
 try {
  proxy = RPC.getProxy(TestSaslProtocol.class,
    TestSaslProtocol.versionID, addr, conf);
  AuthMethod authMethod = proxy.getAuthMethod();
  assertEquals(TOKEN, authMethod);
  //QOP must be auth
  assertEquals(expectedQop.saslQop,
         RPC.getConnectionIdForProxy(proxy).getSaslQop());            
  proxy.ping();
 } finally {
  server.stop();
  if (proxy != null) {
   RPC.stopProxy(proxy);
  }
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
 public String run() throws IOException {
  TestSaslProtocol proxy = null;
  try {
   proxy = RPC.getProxy(TestSaslProtocol.class,
     TestSaslProtocol.versionID, addr, clientConf);
   
   proxy.ping();
   // make sure the other side thinks we are who we said we are!!!
   assertEquals(clientUgi.getUserName(), proxy.getAuthUser());
   AuthMethod authMethod = proxy.getAuthMethod();
   // verify sasl completed with correct QOP
   assertEquals((authMethod != SIMPLE) ? expectedQop.saslQop : null,
          RPC.getConnectionIdForProxy(proxy).getSaslQop());            
   return authMethod.toString();
  } finally {
   if (proxy != null) {
    RPC.stopProxy(proxy);
   }
  }
 }
});

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
 public String run() throws IOException {
  TestSaslProtocol proxy = null;
  try {
   proxy = RPC.getProxy(TestSaslProtocol.class,
     TestSaslProtocol.versionID, addr, clientConf);
   
   proxy.ping();
   // make sure the other side thinks we are who we said we are!!!
   assertEquals(clientUgi.getUserName(), proxy.getAuthUser());
   AuthMethod authMethod = proxy.getAuthMethod();
   // verify sasl completed with correct QOP
   assertEquals((authMethod != SIMPLE) ? expectedQop.saslQop : null,
          RPC.getConnectionIdForProxy(proxy).getSaslQop());            
   return authMethod.toString();
  } finally {
   if (proxy != null) {
    RPC.stopProxy(proxy);
   }
  }
 }
});

代码示例来源：origin: ch.cern.hadoop/hadoop-common

RPC.getConnectionIdForProxy(proxy1),
  RPC.getConnectionIdForProxy(proxy2),
  RPC.getConnectionIdForProxy(proxy3)
};
assertEquals(connsArray[0], connsArray[1]);

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

RPC.getConnectionIdForProxy(proxy1),
  RPC.getConnectionIdForProxy(proxy2),
  RPC.getConnectionIdForProxy(proxy3)
};
assertEquals(connsArray[0], connsArray[1]);