Package io.netty.handler.proxy
Class Socks5ProxyHandler
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.channel.ChannelDuplexHandler
-
- io.netty.handler.proxy.ProxyHandler
-
- io.netty.handler.proxy.Socks5ProxyHandler
-
- All Implemented Interfaces:
ChannelHandler,ChannelInboundHandler,ChannelOutboundHandler
public final class Socks5ProxyHandler extends ProxyHandler
Handler that establishes a blind forwarding proxy tunnel using SOCKS Protocol Version 5.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
-
Constructor Summary
Constructors Constructor Description Socks5ProxyHandler(java.net.SocketAddress proxyAddress)Socks5ProxyHandler(java.net.SocketAddress proxyAddress, byte privateAuthMethod, byte[] privateToken, Socks5ClientEncoder customEncoder)Creates a new SOCKS5 proxy handler with a custom private authentication method.Socks5ProxyHandler(java.net.SocketAddress proxyAddress, java.lang.String username, java.lang.String password)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidaddCodec(ChannelHandlerContext ctx)Adds the codec handlers required to communicate with the proxy server.java.lang.StringauthScheme()Returns the name of the authentication scheme in use.protected booleanhandleResponse(ChannelHandlerContext ctx, java.lang.Object response)Handles the message received from the proxy server.protected java.lang.ObjectnewInitialMessage(ChannelHandlerContext ctx)Returns a new message that is sent at first time when the connection to the proxy server has been established.java.lang.Stringpassword()java.lang.Stringprotocol()Returns the name of the proxy protocol in use.protected voidremoveDecoder(ChannelHandlerContext ctx)Removes the decoders added inProxyHandler.addCodec(ChannelHandlerContext).protected voidremoveEncoder(ChannelHandlerContext ctx)Removes the encoders added inProxyHandler.addCodec(ChannelHandlerContext).java.lang.Stringusername()-
Methods inherited from class io.netty.handler.proxy.ProxyHandler
channelActive, channelInactive, channelRead, channelReadComplete, connect, connectFuture, connectTimeoutMillis, destinationAddress, exceptionCaught, exceptionMessage, flush, handlerAdded, isConnected, proxyAddress, sendToProxyServer, setConnectTimeoutMillis, write
-
Methods inherited from class io.netty.channel.ChannelDuplexHandler
bind, close, deregister, disconnect, read
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerRemoved, isSharable
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.netty.channel.ChannelHandler
handlerRemoved
-
-
-
-
Constructor Detail
-
Socks5ProxyHandler
public Socks5ProxyHandler(java.net.SocketAddress proxyAddress)
-
Socks5ProxyHandler
public Socks5ProxyHandler(java.net.SocketAddress proxyAddress, java.lang.String username, java.lang.String password)
-
Socks5ProxyHandler
public Socks5ProxyHandler(java.net.SocketAddress proxyAddress, byte privateAuthMethod, byte[] privateToken, Socks5ClientEncoder customEncoder)Creates a new SOCKS5 proxy handler with a custom private authentication method.- Parameters:
proxyAddress- The address of the SOCKS5 proxy serverprivateAuthMethod- The private authentication method code (must be in range 0x80-0xFE)privateToken- The token to use for private authenticationcustomEncoder- The custom encoder to use for encoding SOCKS5 messages, ifnulltheSocks5ClientEncoder.DEFAULTwill be used- Throws:
java.lang.IllegalArgumentException- If privateAuthMethod is not in the valid range
-
-
Method Detail
-
protocol
public java.lang.String protocol()
Description copied from class:ProxyHandlerReturns the name of the proxy protocol in use.- Specified by:
protocolin classProxyHandler
-
authScheme
public java.lang.String authScheme()
Description copied from class:ProxyHandlerReturns the name of the authentication scheme in use.- Specified by:
authSchemein classProxyHandler
-
username
public java.lang.String username()
-
password
public java.lang.String password()
-
addCodec
protected void addCodec(ChannelHandlerContext ctx) throws java.lang.Exception
Description copied from class:ProxyHandlerAdds the codec handlers required to communicate with the proxy server.- Specified by:
addCodecin classProxyHandler- Throws:
java.lang.Exception
-
removeEncoder
protected void removeEncoder(ChannelHandlerContext ctx) throws java.lang.Exception
Description copied from class:ProxyHandlerRemoves the encoders added inProxyHandler.addCodec(ChannelHandlerContext).- Specified by:
removeEncoderin classProxyHandler- Throws:
java.lang.Exception
-
removeDecoder
protected void removeDecoder(ChannelHandlerContext ctx) throws java.lang.Exception
Description copied from class:ProxyHandlerRemoves the decoders added inProxyHandler.addCodec(ChannelHandlerContext).- Specified by:
removeDecoderin classProxyHandler- Throws:
java.lang.Exception
-
newInitialMessage
protected java.lang.Object newInitialMessage(ChannelHandlerContext ctx) throws java.lang.Exception
Description copied from class:ProxyHandlerReturns a new message that is sent at first time when the connection to the proxy server has been established.- Specified by:
newInitialMessagein classProxyHandler- Returns:
- the initial message, or
nullif the proxy server is expected to send the first message instead - Throws:
java.lang.Exception
-
handleResponse
protected boolean handleResponse(ChannelHandlerContext ctx, java.lang.Object response) throws java.lang.Exception
Description copied from class:ProxyHandlerHandles the message received from the proxy server.- Specified by:
handleResponsein classProxyHandler- Returns:
trueif the connection to the destination has been established,falseif the connection to the destination has not been established and more messages are expected from the proxy server- Throws:
java.lang.Exception
-
-