depends.org.apache.http.impl.nio.reactor

类 DefaultConnectingIOReactor

java.lang.Object

depends.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor

depends.org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor

所有已实现的接口:

ConnectingIOReactor, IOReactor

@ThreadSafe
public class DefaultConnectingIOReactor
extends AbstractMultiworkerIOReactor
implements ConnectingIOReactor

Default implementation of ConnectingIOReactor. This class extends AbstractMultiworkerIOReactor with capability to connect to remote hosts.

从以下版本开始:

4.0

字段概要

从类继承的字段 depends.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor

auditLog, config, exceptionHandler, interestOpsQueueing, params, selector, selectTimeout, status

构造器概要

构造器

构造器和说明
DefaultConnectingIOReactor() Creates an instance of DefaultConnectingIOReactor with default configuration.
DefaultConnectingIOReactor(int workerCount, HttpParams params) 已过时。 (4.2) use DefaultConnectingIOReactor(IOReactorConfig)
DefaultConnectingIOReactor(int workerCount, java.util.concurrent.ThreadFactory threadFactory, HttpParams params) 已过时。 (4.2) use DefaultConnectingIOReactor(IOReactorConfig, ThreadFactory)
DefaultConnectingIOReactor(IOReactorConfig config) Creates an instance of DefaultConnectingIOReactor with the given configuration.
DefaultConnectingIOReactor(IOReactorConfig config, java.util.concurrent.ThreadFactory threadFactory) Creates an instance of DefaultConnectingIOReactor with the given configuration.

方法概要

方法

限定符和类型	方法和说明
protected void	cancelRequests() Triggered to cancel pending session requests.
SessionRequest	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, java.lang.Object attachment, SessionRequestCallback callback) Requests a connection to a remote host.
protected void	processEvents(int readyCount) Triggered to process I/O events registered by the main Selector.

从类继承的方法 depends.org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor

addChannel, addExceptionEvent, addExceptionEvent, awaitShutdown, doShutdown, execute, getAuditLog, getStatus, prepareSocket, registerChannel, setExceptionHandler, shutdown, shutdown

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

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

从接口继承的方法 depends.org.apache.http.nio.reactor.IOReactor

execute, getStatus, shutdown, shutdown

构造器详细资料

DefaultConnectingIOReactor

public DefaultConnectingIOReactor(IOReactorConfig config,
                          java.util.concurrent.ThreadFactory threadFactory)
                           throws IOReactorException

Creates an instance of DefaultConnectingIOReactor with the given configuration.

参数:

config - I/O reactor configuration.

threadFactory - the factory to create threads. Can be null.

抛出:

IOReactorException - in case if a non-recoverable I/O error.

从以下版本开始:

4.2

DefaultConnectingIOReactor

public DefaultConnectingIOReactor(IOReactorConfig config)
                           throws IOReactorException

Creates an instance of DefaultConnectingIOReactor with the given configuration.

参数:

config - I/O reactor configuration. Can be null.

抛出:

IOReactorException - in case if a non-recoverable I/O error.

从以下版本开始:

4.2

DefaultConnectingIOReactor

public DefaultConnectingIOReactor()
                           throws IOReactorException

Creates an instance of DefaultConnectingIOReactor with default configuration.

抛出:

IOReactorException - in case if a non-recoverable I/O error.

从以下版本开始:

4.2

DefaultConnectingIOReactor

@Deprecated
public DefaultConnectingIOReactor(int workerCount,
                                     java.util.concurrent.ThreadFactory threadFactory,
                                     HttpParams params)
                           throws IOReactorException

已过时。 (4.2) use DefaultConnectingIOReactor(IOReactorConfig, ThreadFactory)

抛出:

IOReactorException

DefaultConnectingIOReactor

@Deprecated
public DefaultConnectingIOReactor(int workerCount,
                                     HttpParams params)
                           throws IOReactorException

已过时。 (4.2) use DefaultConnectingIOReactor(IOReactorConfig)

抛出:

IOReactorException

方法详细资料

cancelRequests

protected void cancelRequests()
                       throws IOReactorException

从类复制的说明: AbstractMultiworkerIOReactor

Triggered to cancel pending session requests.

Super-classes can implement this method to react to the event.

指定者:

cancelRequests 在类中 AbstractMultiworkerIOReactor

抛出:

IOReactorException - in case if a non-recoverable I/O error.

processEvents

protected void processEvents(int readyCount)
                      throws IOReactorException

从类复制的说明: AbstractMultiworkerIOReactor

Triggered to process I/O events registered by the main Selector.

Super-classes can implement this method to react to the event.

指定者:

processEvents 在类中 AbstractMultiworkerIOReactor

参数:

readyCount - event count.

抛出:

IOReactorException - in case if a non-recoverable I/O error.

connect

public SessionRequest connect(java.net.SocketAddress remoteAddress,
                     java.net.SocketAddress localAddress,
                     java.lang.Object attachment,
                     SessionRequestCallback callback)

从接口复制的说明: ConnectingIOReactor

Requests a connection to a remote host.

Opening a connection to a remote host usually tends to be a time consuming process and may take a while to complete. One can monitor and control the process of session initialization by means of the SessionRequest interface.

There are several parameters one can use to exert a greater control over the process of session initialization:

A non-null local socket address parameter can be used to bind the socket to a specific local address.

An attachment object can added to the new session's context upon initialization. This object can be used to pass an initial processing state to the protocol handler.

It is often desirable to be able to react to the completion of a session request asynchronously without having to wait for it, blocking the current thread of execution. One can optionally provide an implementation SessionRequestCallback instance to get notified of events related to session requests, such as request completion, cancellation, failure or timeout.

指定者:

connect 在接口中 ConnectingIOReactor

参数:

remoteAddress - the socket address of the remote host.

localAddress - the local socket address. Can be null, in which can the default local address and a random port will be used.

attachment - the attachment object. Can be null.

callback - interface. Can be null.

返回:

session request object.