org.apache.flink.util

Class NetUtils

java.lang.Object

org.apache.flink.util.NetUtils

@Internal
public class NetUtils
extends Object

Utility for various network related tasks (such as finding free ports).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	NetUtils.SocketFactory A factory for a local socket from port number.

Constructor Summary

Constructors

Constructor and Description
NetUtils()

Method Summary

Modifier and Type	Method and Description
static ServerSocket	createSocketFromPorts(Iterator<Integer> portsIterator, NetUtils.SocketFactory factory) Tries to allocate a socket from the given sets of ports.
static int	getAvailablePort() Find a non-occupied port.
static URL	getCorrectHostnamePort(String hostPort) Method to validate if the given String represents a hostname:port.
static String	getHostnameFromFQDN(String fqdn) Turn a fully qualified domain name (fqdn) into a hostname.
static Iterator<Integer>	getPortRangeFromString(String rangeDefinition) Returns an iterator over available ports defined by the range definition.
static String	getWildcardIPAddress() Returns the wildcard address to listen on all interfaces.
static String	hostAndPortToUrlString(String host, int port) Normalizes and encodes a hostname and port to be included in URL.
static String	ipAddressAndPortToUrlString(InetAddress address, int port) Encodes an IP address and port to be included in URL.
static String	ipAddressToUrlString(InetAddress address) Encodes an IP address properly as a URL string.
static String	socketAddressToUrlString(InetSocketAddress address) Encodes an IP address and port to be included in URL.
static String	unresolvedHostAndPortToNormalizedString(String host, int port) Returns a valid address for Akka.
static String	unresolvedHostToNormalizedString(String host) Returns an address in a normalized format for Akka.

Methods inherited from class java.lang.Object

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

Constructor Detail

NetUtils

public NetUtils()

Method Detail

getHostnameFromFQDN

public static String getHostnameFromFQDN(String fqdn)

Turn a fully qualified domain name (fqdn) into a hostname. If the fqdn has multiple subparts (separated by a period '.'), it will take the first part. Otherwise it takes the entire fqdn.

Parameters:

fqdn - The fully qualified domain name.

Returns:

The hostname.

getCorrectHostnamePort

public static URL getCorrectHostnamePort(String hostPort)

Method to validate if the given String represents a hostname:port.

Works also for ipv6.

See: http://stackoverflow.com/questions/2345063/java-common-way-to-validate-and-convert-hostport-to-inetsocketaddress

Returns:

URL object for accessing host and Port

getAvailablePort

public static int getAvailablePort()

Find a non-occupied port.

Returns:

A non-occupied port.

unresolvedHostToNormalizedString

public static String unresolvedHostToNormalizedString(String host)

Returns an address in a normalized format for Akka. When an IPv6 address is specified, it normalizes the IPv6 address to avoid complications with the exact URL match policy of Akka.

Parameters:

host - The hostname, IPv4 or IPv6 address

Returns:

host which will be normalized if it is an IPv6 address

unresolvedHostAndPortToNormalizedString

public static String unresolvedHostAndPortToNormalizedString(String host,
                                                             int port)

Returns a valid address for Akka. It returns a String of format 'host:port'. When an IPv6 address is specified, it normalizes the IPv6 address to avoid complications with the exact URL match policy of Akka.

Parameters:

host - The hostname, IPv4 or IPv6 address

port - The port

Returns:

host:port where host will be normalized if it is an IPv6 address

ipAddressToUrlString

public static String ipAddressToUrlString(InetAddress address)

Encodes an IP address properly as a URL string. This method makes sure that IPv6 addresses have the proper formatting to be included in URLs.

Parameters:

address - The IP address to encode.

Returns:

The proper URL string encoded IP address.

ipAddressAndPortToUrlString

public static String ipAddressAndPortToUrlString(InetAddress address,
                                                 int port)

Encodes an IP address and port to be included in URL. in particular, this method makes sure that IPv6 addresses have the proper formatting to be included in URLs.

Parameters:

address - The address to be included in the URL.

port - The port for the URL address.

Returns:

The proper URL string encoded IP address and port.

socketAddressToUrlString

public static String socketAddressToUrlString(InetSocketAddress address)

Encodes an IP address and port to be included in URL. in particular, this method makes sure that IPv6 addresses have the proper formatting to be included in URLs.

Parameters:

address - The socket address with the IP address and port.

Returns:

The proper URL string encoded IP address and port.

hostAndPortToUrlString

public static String hostAndPortToUrlString(String host,
                                            int port)
                                     throws UnknownHostException

Normalizes and encodes a hostname and port to be included in URL. In particular, this method makes sure that IPv6 address literals have the proper formatting to be included in URLs.

Parameters:

host - The address to be included in the URL.

port - The port for the URL address.

Returns:

The proper URL string encoded IP address and port.

Throws:

UnknownHostException - Thrown, if the hostname cannot be translated into a URL.

getPortRangeFromString

public static Iterator<Integer> getPortRangeFromString(String rangeDefinition)
                                                throws NumberFormatException

Returns an iterator over available ports defined by the range definition.

Parameters:

rangeDefinition - String describing a single port, a range of ports or multiple ranges.

Returns:

Set of ports from the range definition

Throws:

NumberFormatException - If an invalid string is passed.

createSocketFromPorts

public static ServerSocket createSocketFromPorts(Iterator<Integer> portsIterator,
                                                 NetUtils.SocketFactory factory)

Tries to allocate a socket from the given sets of ports.

Parameters:

portsIterator - A set of ports to choose from.

factory - A factory for creating the SocketServer

Returns:

null if no port was available or an allocated socket.

getWildcardIPAddress

public static String getWildcardIPAddress()

Returns the wildcard address to listen on all interfaces.

Returns:

Either 0.0.0.0 or :: depending on the IP setup.