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

类 DefaultListeningIOReactor

java.lang.Object

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

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

所有已实现的接口:

IOReactor, ListeningIOReactor

@ThreadSafe
public class DefaultListeningIOReactor
extends AbstractMultiworkerIOReactor
implements ListeningIOReactor

Default implementation of ListeningIOReactor. This class extends AbstractMultiworkerIOReactor with capability to listen for incoming connections.

从以下版本开始:

4.0

字段概要

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

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

构造器概要

构造器

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

方法概要

方法

限定符和类型	方法和说明
protected void	cancelRequests() Triggered to cancel pending session requests.
java.util.Set<ListenerEndpoint>	getEndpoints() Returns a set of endpoints for this I/O reactor.
ListenerEndpoint	listen(java.net.SocketAddress address) Opens a new listener endpoint with the given socket address.
void	pause() Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.
protected void	processEvents(int readyCount) Triggered to process I/O events registered by the main Selector.
void	resume() Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.

从类继承的方法 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

构造器详细资料

DefaultListeningIOReactor

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

Creates an instance of DefaultListeningIOReactor 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

DefaultListeningIOReactor

public DefaultListeningIOReactor(IOReactorConfig config)
                          throws IOReactorException

Creates an instance of DefaultListeningIOReactor with the given configuration.

参数:

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

抛出:

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

从以下版本开始:

4.2

DefaultListeningIOReactor

public DefaultListeningIOReactor()
                          throws IOReactorException

Creates an instance of DefaultListeningIOReactor with default configuration.

抛出:

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

从以下版本开始:

4.2

DefaultListeningIOReactor

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

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

抛出:

IOReactorException

DefaultListeningIOReactor

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

已过时。 (4.2) use DefaultListeningIOReactor(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.

listen

public ListenerEndpoint listen(java.net.SocketAddress address)

从接口复制的说明: ListeningIOReactor

Opens a new listener endpoint with the given socket address. Once the endpoint is fully initialized it starts accepting incoming connections and propagates I/O activity notifications to the I/O event dispatcher.

ListenerEndpoint.waitFor() can be used to wait for the listener to be come ready to accept incoming connections.

ListenerEndpoint.close() can be used to shut down the listener even before it is fully initialized.

指定者:

listen 在接口中 ListeningIOReactor

参数:

address - the socket address to listen on.

返回:

listener endpoint.

getEndpoints

public java.util.Set<ListenerEndpoint> getEndpoints()

从接口复制的说明: ListeningIOReactor

Returns a set of endpoints for this I/O reactor.

指定者:

getEndpoints 在接口中 ListeningIOReactor

返回:

set of endpoints.

pause

public void pause()
           throws java.io.IOException

从接口复制的说明: ListeningIOReactor

Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.

指定者:

pause 在接口中 ListeningIOReactor

抛出:

java.io.IOException - in case of an I/O error.

resume

public void resume()
            throws java.io.IOException

从接口复制的说明: ListeningIOReactor

Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.

指定者:

resume 在接口中 ListeningIOReactor

抛出:

java.io.IOException - in case of an I/O error.