org.apache.hadoop.ipc

类 RPC

java.lang.Object

org.apache.hadoop.ipc.RPC

public class RPC
extends Object

A simple RPC mechanism. A protocol is a Java interface. All parameters and return types must be one of:

• a primitive type, boolean, byte, char, short, int, long, float, double, or void; or
• a String; or
• a Writable; or
• an array of the above types

All methods in the protocol should throw only IOException. No field data of the protocol instance is transmitted.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	RPC.Server An RPC Server.
static class	RPC.VersionMismatch A version mismatch for the RPC protocol.

方法概要

方法

限定符和类型	方法和说明
static Object[]	call(Method method, Object[][] params, InetSocketAddress[] addrs, Configuration conf) 已过时。 Use call(Method, Object[][], InetSocketAddress[], UserGroupInformation, Configuration) instead
static Object[]	call(Method method, Object[][] params, InetSocketAddress[] addrs, UserGroupInformation ticket, Configuration conf) Expert: Make multiple, parallel calls to a set of servers.
static void	checkVersion(Class<? extends VersionedProtocol> protocol, long clientVersion, VersionedProtocol proxy) Get server version and then compare it with client version.
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) Construct a client-side proxy object with the default SocketFactory
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, int rpcTimeout)
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, SocketFactory factory) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, SocketFactory factory, int rpcTimeout) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.
static VersionedProtocol	getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, boolean checkVersion) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.
static RPC.Server	getServer(Object instance, String bindAddress, int port, Configuration conf) Construct a server for a protocol implementation instance listening on a port and address.
static RPC.Server	getServer(Object instance, String bindAddress, int port, int numHandlers, boolean verbose, Configuration conf) Construct a server for a protocol implementation instance listening on a port and address.
static RPC.Server	getServer(Object instance, String bindAddress, int port, int numHandlers, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager) Construct a server for a protocol implementation instance listening on a port and address, with a secret manager.
static void	stopProxy(VersionedProtocol proxy) Stop this proxy and release its invoker's resource
static VersionedProtocol	waitForProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

waitForProxy

public static VersionedProtocol waitForProxy(Class<? extends VersionedProtocol> protocol,
                             long clientVersion,
                             InetSocketAddress addr,
                             Configuration conf)
                                      throws IOException

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         Configuration conf,
                         SocketFactory factory)
                                  throws IOException

Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         Configuration conf,
                         SocketFactory factory,
                         int rpcTimeout)
                                  throws IOException

Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         UserGroupInformation ticket,
                         Configuration conf,
                         SocketFactory factory)
                                  throws IOException

Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         UserGroupInformation ticket,
                         Configuration conf,
                         SocketFactory factory,
                         int rpcTimeout)
                                  throws IOException

Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         UserGroupInformation ticket,
                         Configuration conf,
                         SocketFactory factory,
                         int rpcTimeout,
                         RetryPolicy connectionRetryPolicy,
                         boolean checkVersion)
                                  throws IOException

Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.

抛出:

IOException

checkVersion

public static void checkVersion(Class<? extends VersionedProtocol> protocol,
                long clientVersion,
                VersionedProtocol proxy)
                         throws IOException

Get server version and then compare it with client version.

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         Configuration conf)
                                  throws IOException

Construct a client-side proxy object with the default SocketFactory

参数:

protocol -

clientVersion -

addr -

conf -

返回:

a proxy instance

抛出:

IOException

getProxy

public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol,
                         long clientVersion,
                         InetSocketAddress addr,
                         Configuration conf,
                         int rpcTimeout)
                                  throws IOException

抛出:

IOException

stopProxy

public static void stopProxy(VersionedProtocol proxy)

Stop this proxy and release its invoker's resource

参数:

proxy - the proxy to be stopped

call

public static Object[] call(Method method,
            Object[][] params,
            InetSocketAddress[] addrs,
            Configuration conf)
                     throws IOException,
                            InterruptedException

已过时。 Use call(Method, Object[][], InetSocketAddress[], UserGroupInformation, Configuration) instead

Expert: Make multiple, parallel calls to a set of servers.

抛出:

IOException

InterruptedException

call

public static Object[] call(Method method,
            Object[][] params,
            InetSocketAddress[] addrs,
            UserGroupInformation ticket,
            Configuration conf)
                     throws IOException,
                            InterruptedException

Expert: Make multiple, parallel calls to a set of servers.

抛出:

IOException

InterruptedException

getServer

public static RPC.Server getServer(Object instance,
                   String bindAddress,
                   int port,
                   Configuration conf)
                            throws IOException

Construct a server for a protocol implementation instance listening on a port and address.

抛出:

IOException

getServer

public static RPC.Server getServer(Object instance,
                   String bindAddress,
                   int port,
                   int numHandlers,
                   boolean verbose,
                   Configuration conf)
                            throws IOException

Construct a server for a protocol implementation instance listening on a port and address.

抛出:

IOException

getServer

public static RPC.Server getServer(Object instance,
                   String bindAddress,
                   int port,
                   int numHandlers,
                   boolean verbose,
                   Configuration conf,
                   SecretManager<? extends TokenIdentifier> secretManager)
                            throws IOException

Construct a server for a protocol implementation instance listening on a port and address, with a secret manager.

抛出:

IOException