org.apache.hadoop.net

类 NetUtils

java.lang.Object

org.apache.hadoop.net.NetUtils

public class NetUtils
extends Object

构造器概要

构造器

构造器和说明
NetUtils()

方法概要

方法

限定符和类型	方法和说明
static void	addStaticResolution(String host, String resolvedName) Adds a static resolution for host.
static void	connect(Socket socket, SocketAddress address, int timeout) This is a drop-in replacement for Socket.connect(SocketAddress, int).
static void	connect(Socket socket, SocketAddress endpoint, SocketAddress localAddr, int timeout) Like connect(Socket, SocketAddress, int) but also takes a local address and port to bind the socket to.
static InetSocketAddress	createSocketAddr(String target) Util method to build socket addr from either: : ://:/
static InetSocketAddress	createSocketAddr(String target, int defaultPort) Util method to build socket addr from either: : ://:/
static List<String[]>	getAllStaticResolutions() This is used to get all the resolutions that were added using addStaticResolution(String, String).
static URI	getCanonicalUri(URI uri, int defaultPort) Resolve the uri's hostname and add the default port if not in the uri
static InetSocketAddress	getConnectAddress(Server server) Returns InetSocketAddress that a client can use to connect to the server.
static SocketFactory	getDefaultSocketFactory(Configuration conf) Get the default socket factory as specified by the configuration parameter hadoop.rpc.socket.factory.default
static InputStream	getInputStream(Socket socket) Same as getInputStream(socket, socket.getSoTimeout()).
static InputStream	getInputStream(Socket socket, long timeout) Returns InputStream for the socket.
static List<InetAddress>	getIPs(String subnet, boolean returnSubinterfaces) Return an InetAddress for each interface that matches the given subnet specified using CIDR notation.
static InetAddress	getLocalInetAddress(String host) Checks if host is a local host name and return InetAddress corresponding to that address.
static OutputStream	getOutputStream(Socket socket) Same as getOutputStream(socket, 0).
static OutputStream	getOutputStream(Socket socket, long timeout) Returns OutputStream for the socket.
static String	getServerAddress(Configuration conf, String oldBindAddressName, String oldPortName, String newBindAddressName) 已过时。
static SocketFactory	getSocketFactory(Configuration conf, Class<?> clazz) Get the socket factory for the given class according to its configuration parameter hadoop.rpc.socket.factory.class.
static SocketFactory	getSocketFactoryFromProperty(Configuration conf, String propValue) Get the socket factory corresponding to the given proxy URI.
static String	getStaticResolution(String host) Retrieves the resolved name for the passed host.
static boolean	isValidSubnet(String subnet)
static InetSocketAddress	makeSocketAddr(String host, int port) Create a socket address with the given host and port.
static String	normalizeHostName(String name) Given a string representation of a host, return its ip address in textual presentation.
static List<String>	normalizeHostNames(Collection<String> names) Given a collection of string representation of hosts, return a list of corresponding IP addresses in the textual representation.
static void	verifyHostnames(String[] names) Performs a sanity check on the list of hostnames/IPs to verify they at least appear to be valid.

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

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

构造器详细资料

NetUtils

public NetUtils()

方法详细资料

getSocketFactory

public static SocketFactory getSocketFactory(Configuration conf,
                             Class<?> clazz)

Get the socket factory for the given class according to its configuration parameter hadoop.rpc.socket.factory.class.<ClassName>. When no such parameter exists then fall back on the default socket factory as configured by hadoop.rpc.socket.factory.class.default. If this default socket factory is not configured, then fall back on the JVM default socket factory.

参数:

conf - the configuration

clazz - the class (usually a VersionedProtocol)

返回:

a socket factory

getDefaultSocketFactory

public static SocketFactory getDefaultSocketFactory(Configuration conf)

Get the default socket factory as specified by the configuration parameter hadoop.rpc.socket.factory.default

参数:

conf - the configuration

返回:

the default socket factory as specified in the configuration or the JVM default socket factory if the configuration does not contain a default socket factory property.

getSocketFactoryFromProperty

public static SocketFactory getSocketFactoryFromProperty(Configuration conf,
                                         String propValue)

Get the socket factory corresponding to the given proxy URI. If the given proxy URI corresponds to an absence of configuration parameter, returns null. If the URI is malformed raises an exception.

参数:

propValue - the property which is the class name of the SocketFactory to instantiate; assumed non null and non empty.

返回:

a socket factory as defined in the property value.

createSocketAddr

public static InetSocketAddress createSocketAddr(String target)

Util method to build socket addr from either: : ://:/

createSocketAddr

public static InetSocketAddress createSocketAddr(String target,
                                 int defaultPort)

Util method to build socket addr from either: : ://:/

makeSocketAddr

public static InetSocketAddress makeSocketAddr(String host,
                               int port)

Create a socket address with the given host and port. The hostname might be replaced with another host that was set via addStaticResolution(String, String). The value of hadoop.security.token.service.use_ip will determine whether the standard java host resolver is used, or if the fully qualified resolver is used.

参数:

host - the hostname or IP use to instantiate the object

port - the port number

返回:

InetSocketAddress

getCanonicalUri

public static URI getCanonicalUri(URI uri,
                  int defaultPort)

Resolve the uri's hostname and add the default port if not in the uri

参数:

uri - to resolve

defaultPort - if none is given

返回:

URI

抛出:

UnknownHostException

getServerAddress

@Deprecated
public static String getServerAddress(Configuration conf,
                                 String oldBindAddressName,
                                 String oldPortName,
                                 String newBindAddressName)

已过时。

Handle the transition from pairs of attributes specifying a host and port to a single colon separated one.

参数:

conf - the configuration to check

oldBindAddressName - the old address attribute name

oldPortName - the old port attribute name

newBindAddressName - the new combined name

返回:

the complete address from the configuration

addStaticResolution

public static void addStaticResolution(String host,
                       String resolvedName)

Adds a static resolution for host. This can be used for setting up hostnames with names that are fake to point to a well known host. For e.g. in some testcases we require to have daemons with different hostnames running on the same machine. In order to create connections to these daemons, one can set up mappings from those hostnames to "localhost". getStaticResolution(String) can be used to query for the actual hostname.

参数:

host -

resolvedName -

getStaticResolution

public static String getStaticResolution(String host)

Retrieves the resolved name for the passed host. The resolved name must have been set earlier using addStaticResolution(String, String)

参数:

host -

返回:

the resolution

getAllStaticResolutions

public static List<String[]> getAllStaticResolutions()

This is used to get all the resolutions that were added using addStaticResolution(String, String). The return value is a List each element of which contains an array of String of the form String[0]=hostname, String[1]=resolved-hostname

返回:

the list of resolutions

getConnectAddress

public static InetSocketAddress getConnectAddress(Server server)

Returns InetSocketAddress that a client can use to connect to the server. Server.getListenerAddress() is not correct when the server binds to "0.0.0.0". This returns "127.0.0.1:port" when the getListenerAddress() returns "0.0.0.0:port".

参数:

server -

返回:

socket address that a client can use to connect to the server.

getInputStream

public static InputStream getInputStream(Socket socket)
                                  throws IOException

Same as getInputStream(socket, socket.getSoTimeout()).

From documentation for getInputStream(Socket, long):
Returns InputStream for the socket. If the socket has an associated SocketChannel then it returns a SocketInputStream with the given timeout. If the socket does not have a channel, Socket.getInputStream() is returned. In the later case, the timeout argument is ignored and the timeout set with Socket.setSoTimeout(int) applies for reads.

Any socket created using socket factories returned by NetUtils, must use this interface instead of Socket.getInputStream().

参数:

socket -

返回:

InputStream for reading from the socket.

抛出:

IOException

另请参阅:

getInputStream(Socket, long)

getInputStream

public static InputStream getInputStream(Socket socket,
                         long timeout)
                                  throws IOException

Returns InputStream for the socket. If the socket has an associated SocketChannel then it returns a SocketInputStream with the given timeout. If the socket does not have a channel, Socket.getInputStream() is returned. In the later case, the timeout argument is ignored and the timeout set with Socket.setSoTimeout(int) applies for reads.

Any socket created using socket factories returned by NetUtils, must use this interface instead of Socket.getInputStream().

参数:

socket -

timeout - timeout in milliseconds. This may not always apply. zero for waiting as long as necessary.

返回:

InputStream for reading from the socket.

抛出:

IOException

另请参阅:

Socket.getChannel()

getOutputStream

public static OutputStream getOutputStream(Socket socket)
                                    throws IOException

Same as getOutputStream(socket, 0). Timeout of zero implies write will wait until data is available.

From documentation for getOutputStream(Socket, long) :
Returns OutputStream for the socket. If the socket has an associated SocketChannel then it returns a SocketOutputStream with the given timeout. If the socket does not have a channel, Socket.getOutputStream() is returned. In the later case, the timeout argument is ignored and the write will wait until data is available.

Any socket created using socket factories returned by NetUtils, must use this interface instead of Socket.getOutputStream().

参数:

socket -

返回:

OutputStream for writing to the socket.

抛出:

IOException

另请参阅:

getOutputStream(Socket, long)

getOutputStream

public static OutputStream getOutputStream(Socket socket,
                           long timeout)
                                    throws IOException

Returns OutputStream for the socket. If the socket has an associated SocketChannel then it returns a SocketOutputStream with the given timeout. If the socket does not have a channel, Socket.getOutputStream() is returned. In the later case, the timeout argument is ignored and the write will wait until data is available.

Any socket created using socket factories returned by NetUtils, must use this interface instead of Socket.getOutputStream().

参数:

socket -

timeout - timeout in milliseconds. This may not always apply. zero for waiting as long as necessary.

返回:

OutputStream for writing to the socket.

抛出:

IOException

另请参阅:

Socket.getChannel()

connect

public static void connect(Socket socket,
           SocketAddress address,
           int timeout)
                    throws IOException

This is a drop-in replacement for Socket.connect(SocketAddress, int). In the case of normal sockets that don't have associated channels, this just invokes socket.connect(endpoint, timeout). If socket.getChannel() returns a non-null channel, connect is implemented using Hadoop's selectors. This is done mainly to avoid Sun's connect implementation from creating thread-local selectors, since Hadoop does not have control on when these are closed and could end up taking all the available file descriptors.

参数:

socket -

address - the remote address

timeout - timeout in milliseconds

抛出:

IOException

另请参阅:

Socket.connect(java.net.SocketAddress, int)

connect

public static void connect(Socket socket,
           SocketAddress endpoint,
           SocketAddress localAddr,
           int timeout)
                    throws IOException

Like connect(Socket, SocketAddress, int) but also takes a local address and port to bind the socket to.

参数:

socket -

endpoint - the remote address

localAddr - the local address to bind the socket to

timeout - timeout in milliseconds

抛出:

IOException

normalizeHostName

public static String normalizeHostName(String name)

Given a string representation of a host, return its ip address in textual presentation.

参数:

name - a string representation of a host: either a textual representation its IP address or its host name

返回:

its IP address in the string format

normalizeHostNames

public static List<String> normalizeHostNames(Collection<String> names)

Given a collection of string representation of hosts, return a list of corresponding IP addresses in the textual representation.

参数:

names - a collection of string representations of hosts

返回:

a list of corresponding IP addresses in the string format

另请参阅:

normalizeHostName(String)

verifyHostnames

public static void verifyHostnames(String[] names)
                            throws UnknownHostException

Performs a sanity check on the list of hostnames/IPs to verify they at least appear to be valid.

参数:

names - - List of hostnames/IPs

抛出:

UnknownHostException

getLocalInetAddress

public static InetAddress getLocalInetAddress(String host)
                                       throws SocketException

Checks if host is a local host name and return InetAddress corresponding to that address.

参数:

host - the specified host

返回:

a valid local InetAddress or null

抛出:

SocketException - if an I/O error occurs

isValidSubnet

public static boolean isValidSubnet(String subnet)

返回:

true if the given string is a subnet specified using CIDR notation, false otherwise

getIPs

public static List<InetAddress> getIPs(String subnet,
                       boolean returnSubinterfaces)

Return an InetAddress for each interface that matches the given subnet specified using CIDR notation.

参数:

subnet - subnet specified using CIDR notation

returnSubinterfaces - whether to return IPs associated with subinterfaces

抛出:

IllegalArgumentException - if subnet is invalid