io.netty.handler.proxy

类 ProxyHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.netty.handler.proxy.ProxyHandler

所有已实现的接口:

ChannelHandler, ChannelInboundHandler, ChannelOutboundHandler

直接已知子类:

HttpProxyHandler, Socks4ProxyHandler, Socks5ProxyHandler

public abstract class ProxyHandler
extends ChannelDuplexHandler

A common abstraction for protocols that establish blind forwarding proxy tunnels.

嵌套类概要

从接口继承的嵌套类/接口 io.netty.channel.ChannelHandler

ChannelHandler.Sharable

构造器概要

构造器

限定符	构造器和说明
protected	ProxyHandler(java.net.SocketAddress proxyAddress)

方法概要

限定符和类型	方法和说明
protected abstract void	addCodec(ChannelHandlerContext ctx) Adds the codec handlers required to communicate with the proxy server.
abstract java.lang.String	authScheme() Returns the name of the authentication scheme in use.
void	channelActive(ChannelHandlerContext ctx) Calls ChannelHandlerContext.fireChannelActive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelInactive(ChannelHandlerContext ctx) Calls ChannelHandlerContext.fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelRead(ChannelHandlerContext ctx, java.lang.Object msg) Calls ChannelHandlerContext.fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	channelReadComplete(ChannelHandlerContext ctx) Calls ChannelHandlerContext.fireChannelReadComplete() to forward to the next ChannelInboundHandler in the ChannelPipeline.
void	connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) Calls ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.
Future<Channel>	connectFuture() Returns a Future that is notified when the connection to the destination has been established or the connection attempt has failed.
long	connectTimeoutMillis() Returns the connect timeout in millis.
<T extends java.net.SocketAddress> T	destinationAddress() Returns the address of the destination to connect to via the proxy server.
void	exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) Calls ChannelHandlerContext.fireExceptionCaught(Throwable) to forward to the next ChannelHandler in the ChannelPipeline.
protected java.lang.String	exceptionMessage(java.lang.String msg) Decorates the specified exception message with the common information such as the current protocol, authentication scheme, proxy address, and destination address.
void	flush(ChannelHandlerContext ctx) Calls ChannelHandlerContext.flush() to forward to the next ChannelOutboundHandler in the ChannelPipeline.
void	handlerAdded(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.
protected abstract boolean	handleResponse(ChannelHandlerContext ctx, java.lang.Object response) Handles the message received from the proxy server.
boolean	isConnected() Returns true if and only if the connection to the destination has been established successfully.
protected abstract java.lang.Object	newInitialMessage(ChannelHandlerContext ctx) Returns a new message that is sent at first time when the connection to the proxy server has been established.
abstract java.lang.String	protocol() Returns the name of the proxy protocol in use.
<T extends java.net.SocketAddress> T	proxyAddress() Returns the address of the proxy server.
protected abstract void	removeDecoder(ChannelHandlerContext ctx) Removes the decoders added in addCodec(ChannelHandlerContext).
protected abstract void	removeEncoder(ChannelHandlerContext ctx) Removes the encoders added in addCodec(ChannelHandlerContext).
protected void	sendToProxyServer(java.lang.Object msg) Sends the specified message to the proxy server.
void	setConnectTimeoutMillis(long connectTimeoutMillis) Sets the connect timeout in millis.
void	write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) Calls ChannelOutboundInvoker.write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.

从类继承的方法 io.netty.channel.ChannelDuplexHandler

bind, close, deregister, disconnect, read

从类继承的方法 io.netty.channel.ChannelInboundHandlerAdapter

channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

从类继承的方法 io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

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

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

从接口继承的方法 io.netty.channel.ChannelHandler

handlerRemoved

构造器详细资料

ProxyHandler

protected ProxyHandler(java.net.SocketAddress proxyAddress)

方法详细资料

protocol

public abstract java.lang.String protocol()

Returns the name of the proxy protocol in use.

authScheme

public abstract java.lang.String authScheme()

Returns the name of the authentication scheme in use.

proxyAddress

public final <T extends java.net.SocketAddress> T proxyAddress()

Returns the address of the proxy server.

destinationAddress

public final <T extends java.net.SocketAddress> T destinationAddress()

Returns the address of the destination to connect to via the proxy server.

isConnected

public final boolean isConnected()

Returns true if and only if the connection to the destination has been established successfully.

connectFuture

public final Future<Channel> connectFuture()

Returns a Future that is notified when the connection to the destination has been established or the connection attempt has failed.

connectTimeoutMillis

public final long connectTimeoutMillis()

Returns the connect timeout in millis. If the connection attempt to the destination does not finish within the timeout, the connection attempt will be failed.

setConnectTimeoutMillis

public final void setConnectTimeoutMillis(long connectTimeoutMillis)

Sets the connect timeout in millis. If the connection attempt to the destination does not finish within the timeout, the connection attempt will be failed.

handlerAdded

public final void handlerAdded(ChannelHandlerContext ctx)
                        throws java.lang.Exception

从类复制的说明: ChannelHandlerAdapter

Do nothing by default, sub-classes may override this method.

指定者:

handlerAdded 在接口中 ChannelHandler

覆盖:

handlerAdded 在类中 ChannelHandlerAdapter

抛出:

java.lang.Exception

addCodec

protected abstract void addCodec(ChannelHandlerContext ctx)
                          throws java.lang.Exception

Adds the codec handlers required to communicate with the proxy server.

抛出:

java.lang.Exception

removeEncoder

protected abstract void removeEncoder(ChannelHandlerContext ctx)
                               throws java.lang.Exception

Removes the encoders added in addCodec(ChannelHandlerContext).

抛出:

java.lang.Exception

removeDecoder

protected abstract void removeDecoder(ChannelHandlerContext ctx)
                               throws java.lang.Exception

Removes the decoders added in addCodec(ChannelHandlerContext).

抛出:

java.lang.Exception

connect

public final void connect(ChannelHandlerContext ctx,
                          java.net.SocketAddress remoteAddress,
                          java.net.SocketAddress localAddress,
                          ChannelPromise promise)
                   throws java.lang.Exception

从类复制的说明: ChannelDuplexHandler

Calls ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

connect 在接口中 ChannelOutboundHandler

覆盖:

connect 在类中 ChannelDuplexHandler

参数:

ctx - the ChannelHandlerContext for which the connect operation is made

remoteAddress - the SocketAddress to which it should connect

localAddress - the SocketAddress which is used as source on connect

promise - the ChannelPromise to notify once the operation completes

抛出:

java.lang.Exception - thrown if an error occurs

channelActive

public final void channelActive(ChannelHandlerContext ctx)
                         throws java.lang.Exception

从类复制的说明: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireChannelActive() to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

channelActive 在接口中 ChannelInboundHandler

覆盖:

channelActive 在类中 ChannelInboundHandlerAdapter

抛出:

java.lang.Exception

newInitialMessage

protected abstract java.lang.Object newInitialMessage(ChannelHandlerContext ctx)
                                               throws java.lang.Exception

Returns a new message that is sent at first time when the connection to the proxy server has been established.

返回:

the initial message, or null if the proxy server is expected to send the first message instead

抛出:

java.lang.Exception

sendToProxyServer

protected final void sendToProxyServer(java.lang.Object msg)

Sends the specified message to the proxy server. Use this method to send a response to the proxy server in handleResponse(ChannelHandlerContext, Object).

channelInactive

public final void channelInactive(ChannelHandlerContext ctx)
                           throws java.lang.Exception

从类复制的说明: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

channelInactive 在接口中 ChannelInboundHandler

覆盖:

channelInactive 在类中 ChannelInboundHandlerAdapter

抛出:

java.lang.Exception

exceptionCaught

public final void exceptionCaught(ChannelHandlerContext ctx,
                                  java.lang.Throwable cause)
                           throws java.lang.Exception

从类复制的说明: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireExceptionCaught(Throwable) to forward to the next ChannelHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

exceptionCaught 在接口中 ChannelHandler

指定者:

exceptionCaught 在接口中 ChannelInboundHandler

覆盖:

exceptionCaught 在类中 ChannelInboundHandlerAdapter

抛出:

java.lang.Exception

channelRead

public final void channelRead(ChannelHandlerContext ctx,
                              java.lang.Object msg)
                       throws java.lang.Exception

从类复制的说明: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

channelRead 在接口中 ChannelInboundHandler

覆盖:

channelRead 在类中 ChannelInboundHandlerAdapter

抛出:

java.lang.Exception

handleResponse

protected abstract boolean handleResponse(ChannelHandlerContext ctx,
                                          java.lang.Object response)
                                   throws java.lang.Exception

Handles the message received from the proxy server.

返回:

true if the connection to the destination has been established, false if the connection to the destination has not been established and more messages are expected from the proxy server

抛出:

java.lang.Exception

exceptionMessage

protected final java.lang.String exceptionMessage(java.lang.String msg)

Decorates the specified exception message with the common information such as the current protocol, authentication scheme, proxy address, and destination address.

channelReadComplete

public final void channelReadComplete(ChannelHandlerContext ctx)
                               throws java.lang.Exception

从类复制的说明: ChannelInboundHandlerAdapter

Calls ChannelHandlerContext.fireChannelReadComplete() to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

channelReadComplete 在接口中 ChannelInboundHandler

覆盖:

channelReadComplete 在类中 ChannelInboundHandlerAdapter

抛出:

java.lang.Exception

write

public final void write(ChannelHandlerContext ctx,
                        java.lang.Object msg,
                        ChannelPromise promise)
                 throws java.lang.Exception

从类复制的说明: ChannelDuplexHandler

Calls ChannelOutboundInvoker.write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

write 在接口中 ChannelOutboundHandler

覆盖:

write 在类中 ChannelDuplexHandler

参数:

ctx - the ChannelHandlerContext for which the write operation is made

msg - the message to write

promise - the ChannelPromise to notify once the operation completes

抛出:

java.lang.Exception - thrown if an error occurs

flush

public final void flush(ChannelHandlerContext ctx)
                 throws java.lang.Exception

从类复制的说明: ChannelDuplexHandler

Calls ChannelHandlerContext.flush() to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

指定者:

flush 在接口中 ChannelOutboundHandler

覆盖:

flush 在类中 ChannelDuplexHandler

参数:

ctx - the ChannelHandlerContext for which the flush operation is made

抛出:

java.lang.Exception - thrown if an error occurs