Package org.eclipse.jetty.io

Class ClientConnector

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.io.ClientConnector

All Implemented Interfaces:

Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle

@ManagedObject
public class ClientConnector
extends ContainerLifeCycle

The client-side component that connects to server sockets.

ClientConnector delegates the handling of SocketChannels to a SelectorManager, and centralizes the configuration of necessary components such as the executor, the scheduler, etc.

ClientConnector offers a low-level API that can be used to connect SocketChannels to listening servers via the connect(SocketAddress, Map) method.

However, a ClientConnector instance is typically just configured and then passed to an HttpClient transport, so that applications can use high-level APIs to make HTTP requests to servers:

 // Create a ClientConnector instance.
 ClientConnector connector = new ClientConnector();

 // Configure the ClientConnector.
 connector.setSelectors(1);
 connector.setSslContextFactory(new SslContextFactory.Client());

 // Pass it to the HttpClient transport.
 HttpClientTransport transport = new HttpClientTransportDynamic(connector);
 HttpClient httpClient = new HttpClient(transport);
 httpClient.start();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ClientConnector.ClientSelectorManager
static class	ClientConnector.Configurator	Configures a ClientConnector.

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
static final String	APPLICATION_PROTOCOLS_CONTEXT_KEY
static final String	CLIENT_CONNECTION_FACTORY_CONTEXT_KEY
static final String	CLIENT_CONNECTOR_CONTEXT_KEY
static final String	CONNECTION_PROMISE_CONTEXT_KEY
static final String	REMOTE_SOCKET_ADDRESS_CONTEXT_KEY

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
ClientConnector()
ClientConnector(ClientConnector.Configurator configurator)

Method Summary

Modifier and Type	Method	Description
void	accept(SelectableChannel selectable, Map<String,Object> context)
protected void	configure(SelectableChannel selectable)
void	connect(SocketAddress address, Map<String,Object> context)
protected void	connectFailed(Throwable failure, Map<String,Object> context)
protected void	doStart()	Starts the managed lifecycle beans in the order they were added.
protected void	doStop()	Stops the managed lifecycle beans in the reverse order they were added.
static ClientConnector	forUnixDomain(Path path)	Creates a ClientConnector configured to connect via Unix-Domain sockets to the given Unix-Domain path
SocketAddress	getBindAddress()
ByteBufferPool	getByteBufferPool()
Duration	getConnectTimeout()
Executor	getExecutor()
Duration	getIdleTimeout()
int	getReceiveBufferSize()
boolean	getReuseAddress()
Scheduler	getScheduler()
int	getSelectors()
int	getSendBufferSize()
SslContextFactory.Client	getSslContextFactory()
boolean	isConnectBlocking()
boolean	isIntrinsicallySecure(SocketAddress address)
boolean	isReusePort()
boolean	isTCPNoDelay()
protected Connection	newConnection(EndPoint endPoint, Map<String,Object> context)
protected EndPoint	newEndPoint(SelectableChannel selectable, ManagedSelector selector, SelectionKey selectionKey)
protected SelectorManager	newSelectorManager()
protected SslContextFactory.Client	newSslContextFactory()
void	setBindAddress(SocketAddress bindAddress)	Sets the bind address of sockets before the connect operation.
void	setByteBufferPool(ByteBufferPool byteBufferPool)
void	setConnectBlocking(boolean connectBlocking)
void	setConnectTimeout(Duration connectTimeout)
void	setExecutor(Executor executor)
void	setIdleTimeout(Duration idleTimeout)
void	setReceiveBufferSize(int receiveBufferSize)
void	setReuseAddress(boolean reuseAddress)	Sets whether it is allowed to bind a socket to a socket address that may be in use by another socket in tear-down state, for example in TIME_WAIT state.
void	setReusePort(boolean reusePort)	Sets whether it is allowed to bind multiple sockets to the same socket address (same host and same port).
void	setScheduler(Scheduler scheduler)
void	setSelectors(int selectors)
void	setSendBufferSize(int sendBufferSize)
void	setSslContextFactory(SslContextFactory.Client sslContextFactory)
void	setTCPNoDelay(boolean tcpNoDelay)

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Container

getCachedBeans, getEventListeners

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dumpSelf

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer

isDumpable

Field Details

CLIENT_CONNECTOR_CONTEXT_KEY

public static final String CLIENT_CONNECTOR_CONTEXT_KEY

See Also:

• Constant Field Values

REMOTE_SOCKET_ADDRESS_CONTEXT_KEY

public static final String REMOTE_SOCKET_ADDRESS_CONTEXT_KEY

See Also:

• Constant Field Values

CLIENT_CONNECTION_FACTORY_CONTEXT_KEY

public static final String CLIENT_CONNECTION_FACTORY_CONTEXT_KEY

See Also:

• Constant Field Values

CONNECTION_PROMISE_CONTEXT_KEY

public static final String CONNECTION_PROMISE_CONTEXT_KEY

See Also:

• Constant Field Values

APPLICATION_PROTOCOLS_CONTEXT_KEY

public static final String APPLICATION_PROTOCOLS_CONTEXT_KEY

See Also:

• Constant Field Values

Constructor Details

ClientConnector

public ClientConnector()

ClientConnector

public ClientConnector(ClientConnector.Configurator configurator)

Method Details

forUnixDomain

public static ClientConnector forUnixDomain(Path path)

Creates a ClientConnector configured to connect via Unix-Domain sockets to the given Unix-Domain path

Parameters:

path - the Unix-Domain path to connect to

Returns:

a ClientConnector that connects to the given Unix-Domain path

isIntrinsicallySecure

public boolean isIntrinsicallySecure(SocketAddress address)

Parameters:

address - the SocketAddress to connect to

Returns:

whether the connection to the given SocketAddress is intrinsically secure

See Also:

• ClientConnector.Configurator.isIntrinsicallySecure(ClientConnector, SocketAddress)

getExecutor

public Executor getExecutor()

setExecutor

public void setExecutor(Executor executor)

getScheduler

public Scheduler getScheduler()

setScheduler

public void setScheduler(Scheduler scheduler)

getByteBufferPool

public ByteBufferPool getByteBufferPool()

setByteBufferPool

public void setByteBufferPool(ByteBufferPool byteBufferPool)

getSslContextFactory

public SslContextFactory.Client getSslContextFactory()

setSslContextFactory

public void setSslContextFactory(SslContextFactory.Client sslContextFactory)

getSelectors

@ManagedAttribute("The number of NIO selectors")
public int getSelectors()

Returns:

the number of NIO selectors

setSelectors

public void setSelectors(int selectors)

isConnectBlocking

@ManagedAttribute("Whether connect operations are performed in blocking mode")
public boolean isConnectBlocking()

Returns:

whether connect(SocketAddress, Map) operations are performed in blocking mode

setConnectBlocking

public void setConnectBlocking(boolean connectBlocking)

getConnectTimeout

@ManagedAttribute("The timeout of connect operations")
public Duration getConnectTimeout()

Returns:

the timeout of connect(SocketAddress, Map) operations

setConnectTimeout

public void setConnectTimeout(Duration connectTimeout)

getIdleTimeout

@ManagedAttribute("The duration for which a connection can be idle")
public Duration getIdleTimeout()

Returns:

the max duration for which a connection can be idle (that is, without traffic of bytes in either direction)

setIdleTimeout

public void setIdleTimeout(Duration idleTimeout)

getBindAddress

@ManagedAttribute("The socket address to bind sockets to before the connect operation")
public SocketAddress getBindAddress()

Returns:

the address to bind a socket to before the connect operation

setBindAddress

public void setBindAddress(SocketAddress bindAddress)

Sets the bind address of sockets before the connect operation.

In multi-homed hosts, you may want to connect from a specific address:

 clientConnector.setBindAddress(new InetSocketAddress("127.0.0.2", 0));
 

Note the use of the port 0 to indicate that a different ephemeral port should be used for each different connection.

In the rare cases where you want to use the same port for all connections, you must also call setReusePort(true).

Parameters:

bindAddress - the socket address to bind to before the connect operation

isTCPNoDelay

@ManagedAttribute("Whether small TCP packets are sent without delay")
public boolean isTCPNoDelay()

Returns:

whether small TCP packets are sent without delay

setTCPNoDelay

public void setTCPNoDelay(boolean tcpNoDelay)

getReuseAddress

@ManagedAttribute("Whether rebinding is allowed with sockets in tear-down states")
public boolean getReuseAddress()

Returns:

whether rebinding is allowed with sockets in tear-down states

setReuseAddress

public void setReuseAddress(boolean reuseAddress)

Sets whether it is allowed to bind a socket to a socket address that may be in use by another socket in tear-down state, for example in TIME_WAIT state.

This is useful when ClientConnector is restarted: an existing connection may still be using a network address (same host and same port) that is also chosen for a new connection.

Parameters:

reuseAddress - whether rebinding is allowed with sockets in tear-down states

See Also:

• setReusePort(boolean)

isReusePort

@ManagedAttribute("Whether binding to same host and port is allowed")
public boolean isReusePort()

Returns:

whether binding to same host and port is allowed

setReusePort

public void setReusePort(boolean reusePort)

Sets whether it is allowed to bind multiple sockets to the same socket address (same host and same port).

Parameters:

reusePort - whether binding to same host and port is allowed

getReceiveBufferSize

@ManagedAttribute("The receive buffer size in bytes")
public int getReceiveBufferSize()

Returns:

the receive buffer size in bytes, or -1 for the default value

setReceiveBufferSize

public void setReceiveBufferSize(int receiveBufferSize)

getSendBufferSize

@ManagedAttribute("The send buffer size in bytes")
public int getSendBufferSize()

Returns:

the send buffer size in bytes, or -1 for the default value

setSendBufferSize

public void setSendBufferSize(int sendBufferSize)

doStart

protected void doStart()
                throws Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

Exception - If there was a problem starting. Will cause a transition to FAILED state

doStop

protected void doStop()
               throws Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

Exception - If there was a problem stopping. Will cause a transition to FAILED state

newSslContextFactory

protected SslContextFactory.Client newSslContextFactory()

newSelectorManager

protected SelectorManager newSelectorManager()

connect

public void connect(SocketAddress address,
 Map<String,Object> context)

accept

public void accept(SelectableChannel selectable,
 Map<String,Object> context)

configure

protected void configure(SelectableChannel selectable)
                  throws IOException

Throws:

IOException

newEndPoint

protected EndPoint newEndPoint(SelectableChannel selectable,
 ManagedSelector selector,
 SelectionKey selectionKey)

newConnection

protected Connection newConnection(EndPoint endPoint,
 Map<String,Object> context)
                            throws IOException

Throws:

IOException

connectFailed

protected void connectFailed(Throwable failure,
 Map<String,Object> context)