简介
上一篇文章,咱们讲到了 netty 对 SOCKS 音讯提供了 SocksMessage 对象的封装,并且辨别 SOCKS4 和 SOCKS5,同时提供了连贯和响应的各种状态。
有了 SOCKS 音讯的封装之后,咱们还须要做些什么工作能力搭建一个 SOCKS 服务器呢?
应用 SSH 搭建 SOCKS 服务器
其实最简略的方法就是应用 SSH 工具来建设 SOCKS 代理服务器。
先看下 SSH 建设 SOCKS 服务的命令:
ssh -f -C -N -D bindaddress:port name@server
-f 示意 SSH 作为守护过程进入后盾执行。
-N 示意不执行近程命令, 只用于端口转发。
-D 示意是端口上的动静转发。这个命令反对 SOCKS4 和 SOCKS5。
-C 示意发送前压缩数据。
bindaddress 本地服务器的绑定地址。
port 示意本地服务器的指定侦听端口。
name 示意 ssh 服务器登录名。
server 示意 ssh 服务器地址。
下面命令的意思是,在本机建设端口绑定,而后将其转发到近程的代理服务器上。
比方咱们能够在本机开一个 2000 的端口,将其转发到近程 168.121.100.23 这台机子上:
ssh -f -N -D 0.0.0.0:2000 root@168.121.100.23
有了代理服务器之后,就能够应用了,首先介绍一个怎么在 curl 命令中应用 SOCKS 代理。
咱们想通过代理服务器,拜访 www.flydean.com,该怎么做呢?
curl -x socks5h://localhost:2000 -v -k -X GET http://www.flydean.com:80
要想检测 SOCKS 的连贯,还能够应用 netcat 命令如下:
ncat –proxy 127.0.0.1:2000 –proxy-type socks5 www.flydean.com 80 -nv
应用 netty 搭建 SOCKS 服务器
应用 netty 搭建 SOCKS 服务器的要害是应用 netty 服务器做中继,它须要建设两个连贯,一个是客户端到代理服务器的连贯,一个是代理服务器到指标地址的连贯。接下来,咱们一步一步探讨如何在 netty 中构建 SOCKS 服务器。
搭建服务器的根本步骤和一般的服务器基本一致,要留神的就是对音讯的编码、解码和在音讯读取处理过程中的转发。
encoder 和 decoder
对于一种协定来说,最终要的就是对应的 encoder 和 decoder,用于协定对象和 ByteBuf 之间进行转换。
netty 提供的 SOCKS 转换器叫做 SocksPortUnificationServerHandler。先看下它的定义:
public class SocksPortUnificationServerHandler extends ByteToMessageDecoder
它继承自 ByteToMessageDecoder 示意是 ByteBuf 和 Socks 对象之间的转换。
所以咱们在 ChannelInitializer 中只须要加上 SocksPortUnificationServerHandler 和自定义的处 Socks 音讯的 handler 即可:
public void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG),
new SocksPortUnificationServerHandler(),
SocksServerHandler.INSTANCE);
}
等等,不对呀! 有仔细的小伙伴可能发现了,SocksPortUnificationServerHandler 只是一个 decoder,咱们还短少一个 encoder,用来将 Socks 对象转换老本 ByteBuf,这个 encoder 在哪里呢?
别急,咱们再回到 SocksPortUnificationServerHandler 中,在它的 decode 办法中,有这样一段代码:
case SOCKS4a:
logKnownVersion(ctx, version);
p.addAfter(ctx.name(), null, Socks4ServerEncoder.INSTANCE);
p.addAfter(ctx.name(), null, new Socks4ServerDecoder());
break;
case SOCKS5:
logKnownVersion(ctx, version);
p.addAfter(ctx.name(), null, socks5encoder);
p.addAfter(ctx.name(), null, new Socks5InitialRequestDecoder());
break;
原来是在 decode 办法外面,依据 Socks 的版本不同,给 ctx 增加了对应的 encoder 和 decoder,十分的奇妙。
对应的 encoder 别离是 Socks4ServerEncoder 和 Socks5ServerEncoder。
建设连贯
对于 Socks4 来说,只有一个建设连贯的申请类型,在 netty 中用 Socks4CommandRequest 来示意。
所以咱们只须要在 channelRead0 中判断申请的版本即可:
case SOCKS4a:
Socks4CommandRequest socksV4CmdRequest = (Socks4CommandRequest) socksRequest;
if (socksV4CmdRequest.type() == Socks4CommandType.CONNECT) {ctx.pipeline().addLast(new SocksServerConnectHandler());
ctx.pipeline().remove(this);
ctx.fireChannelRead(socksRequest);
} else {ctx.close();
}
这里咱们增加了一个自定义的 SocksServerConnectHandler,用来解决 Socks 连贯,这个自定义 handler 会在前面进行具体解说,这里大家晓得它应用来建设连贯即可。
对于 Socks5 来说,就比较复杂点,蕴含了初始化申请、认证申请和建设连贯三个局部,所以须要别离解决:
case SOCKS5:
if (socksRequest instanceof Socks5InitialRequest) {ctx.pipeline().addFirst(new Socks5CommandRequestDecoder());
ctx.write(new DefaultSocks5InitialResponse(Socks5AuthMethod.NO_AUTH));
} else if (socksRequest instanceof Socks5PasswordAuthRequest) {ctx.pipeline().addFirst(new Socks5CommandRequestDecoder());
ctx.write(new DefaultSocks5PasswordAuthResponse(Socks5PasswordAuthStatus.SUCCESS));
} else if (socksRequest instanceof Socks5CommandRequest) {Socks5CommandRequest socks5CmdRequest = (Socks5CommandRequest) socksRequest;
if (socks5CmdRequest.type() == Socks5CommandType.CONNECT) {ctx.pipeline().addLast(new SocksServerConnectHandler());
ctx.pipeline().remove(this);
ctx.fireChannelRead(socksRequest);
} else {ctx.close();
}
留神,这里咱们的认证申请只反对用户名明码认证。
ConnectHandler
既然是作为一个代理服务器,就须要建设两个连贯,一个是客户端到代理服务器的连贯,一个是代理服务器到指标服务器的连贯。
对于 netty 来说,这两个连贯能够用两个 Bootstrap 来建设。
其中客户端到代理服务器端的连贯咱们在启动 netty 服务器的时候曾经建设了,所以须要在 ConnectHandler 中,建设一个新的代理服务器到指标服务器的连贯:
private final Bootstrap b = new Bootstrap();
Channel inboundChannel = ctx.channel();
b.group(inboundChannel.eventLoop())
.channel(NioSocketChannel.class)
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
.option(ChannelOption.SO_KEEPALIVE, true)
.handler(new ClientPromiseHandler(promise));
b.connect(request.dstAddr(), request.dstPort()).addListener(future -> {if (future.isSuccess()) {// 胜利建设连贯} else {
// 敞开连贯
ctx.channel().writeAndFlush(new DefaultSocks4CommandResponse(Socks4CommandStatus.REJECTED_OR_FAILED)
);
closeOnFlush(ctx.channel());
}
});
新的 Bootstrap 须要从接管到的 Socks 音讯中取出指标服务器的地址和端口,而后建设连贯。
而后判断新建设连贯的状态,如果胜利则增加一个转发器将 outboundChannel 的音讯转发到 inboundChannel 中,同时将 inboundChannel 的音讯转发到 outboundChannel 中,从而达到服务器代理的目标。
final Channel outboundChannel = future.getNow();
if (future.isSuccess()) {ChannelFuture responseFuture = ctx.channel().writeAndFlush(new DefaultSocks4CommandResponse(Socks4CommandStatus.SUCCESS));
// 胜利建设连贯,删除 SocksServerConnectHandler,增加 RelayHandler
responseFuture.addListener(channelFuture -> {ctx.pipeline().remove(SocksServerConnectHandler.this);
outboundChannel.pipeline().addLast(new RelayHandler(ctx.channel()));
ctx.pipeline().addLast(new RelayHandler(outboundChannel));
});
} else {ctx.channel().writeAndFlush(new DefaultSocks4CommandResponse(Socks4CommandStatus.REJECTED_OR_FAILED));
closeOnFlush(ctx.channel());
}
总结
说白了,代理服务器就是建设两个连贯,将其中一个连贯的音讯转发给另外一个连贯。这种操作在 netty 中是十分简便的。
本文的例子能够参考:learn-netty4
本文已收录于 http://www.flydean.com/37-netty-cust-socks-server/
最艰深的解读,最粗浅的干货,最简洁的教程,泛滥你不晓得的小技巧等你来发现!
欢送关注我的公众号:「程序那些事」, 懂技术,更懂你!