org.apache.mina.proxy

类 ProxyConnector

java.lang.Object

org.apache.mina.core.service.AbstractIoService

org.apache.mina.core.service.AbstractIoConnector

org.apache.mina.proxy.ProxyConnector

所有已实现的接口:

IoConnector, IoService

public class ProxyConnector
extends AbstractIoConnector

ProxyConnector.java - Decorator for SocketConnector to provide proxy support, as suggested by MINA list discussions.

Operates by intercepting connect requests and replacing the endpoint address with the proxy address, then adding a ProxyFilter as the first IoFilter which performs any necessary handshaking with the proxy before allowing data to flow normally. During the handshake, any outgoing write requests are buffered.

从以下版本开始:

MINA 2.0.0-M3

作者:

Apache MINA Project

另请参阅:

Proxy reconnection, Proxy support

嵌套类概要

从类继承的嵌套类/接口 org.apache.mina.core.service.AbstractIoService

AbstractIoService.ServiceOperationFuture

字段概要

从类继承的字段 org.apache.mina.core.service.AbstractIoService

disposalLock, sessionConfig

构造器概要

构造器

构造器和说明
ProxyConnector() Creates a new proxy connector.
ProxyConnector(SocketConnector connector) Creates a new proxy connector.
ProxyConnector(SocketConnector connector, IoSessionConfig config, java.util.concurrent.Executor executor) Creates a new proxy connector.

方法概要

方法

限定符和类型	方法和说明
void	cancelConnectFuture() Cancels the real connection when reconnection is in use.
protected ConnectFuture	connect0(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer) Connects to the specified address.
protected void	dispose0() Implement this method to release any acquired resources.
protected ConnectFuture	fireConnected(IoSession session) Fires the connection event on the real future to notify the client.
SocketConnector	getConnector()
ProxyIoSession	getProxyIoSession()
IoSessionConfig	getSessionConfig()
TransportMetadata	getTransportMetadata()
void	setProxyIoSession(ProxyIoSession proxyIoSession) Sets the proxy session object of this connector.

从类继承的方法 org.apache.mina.core.service.AbstractIoConnector

connect, connect, connect, connect, connect, connect, finishSessionInitialization0, getConnectTimeout, getConnectTimeoutCheckInterval, getConnectTimeoutMillis, getDefaultLocalAddress, getDefaultRemoteAddress, setConnectTimeout, setConnectTimeoutCheckInterval, setConnectTimeoutMillis, setDefaultLocalAddress, setDefaultRemoteAddress, toString

从类继承的方法 org.apache.mina.core.service.AbstractIoService

addListener, broadcast, dispose, dispose, executeWorker, executeWorker, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

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

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

从接口继承的方法 org.apache.mina.core.service.IoService

addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

构造器详细资料

ProxyConnector

public ProxyConnector()

Creates a new proxy connector.

ProxyConnector

public ProxyConnector(SocketConnector connector)

Creates a new proxy connector.

参数:

connector - Connector used to establish proxy connections.

ProxyConnector

public ProxyConnector(SocketConnector connector,
              IoSessionConfig config,
              java.util.concurrent.Executor executor)

Creates a new proxy connector.

参数:

connector - The Connector used to establish proxy connections.

config - The session confiugarion to use

executor - The associated executor

方法详细资料

getSessionConfig

public IoSessionConfig getSessionConfig()

返回:

the default configuration of the new IoSessions created by this service.

getProxyIoSession

public ProxyIoSession getProxyIoSession()

返回:

the ProxyIoSession linked with this connector.

setProxyIoSession

public void setProxyIoSession(ProxyIoSession proxyIoSession)

Sets the proxy session object of this connector.

参数:

proxyIoSession - the configuration of this connector.

connect0

protected ConnectFuture connect0(java.net.SocketAddress remoteAddress,
                     java.net.SocketAddress localAddress,
                     IoSessionInitializer<? extends ConnectFuture> sessionInitializer)

Connects to the specified address. If communication starts successfully, events are fired to the connector's handler.

指定者:

connect0 在类中 AbstractIoConnector

参数:

remoteAddress - the remote address to connect to

localAddress - the local address

sessionInitializer - the session initializer

返回:

ConnectFuture that will tell the result of the connection attempt

cancelConnectFuture

public void cancelConnectFuture()

Cancels the real connection when reconnection is in use.

fireConnected

protected ConnectFuture fireConnected(IoSession session)

Fires the connection event on the real future to notify the client.

参数:

session - the current session

返回:

the future holding the connected session

getConnector

public final SocketConnector getConnector()

返回:

the SocketConnector to be used for connections to the proxy server.

dispose0

protected void dispose0()
                 throws java.lang.Exception

Implement this method to release any acquired resources. This method is invoked only once by AbstractIoService.dispose().

指定者:

dispose0 在类中 AbstractIoService

抛出:

java.lang.Exception - If the dispose failed

getTransportMetadata

public TransportMetadata getTransportMetadata()

返回:

the TransportMetadata that this service runs on.