netty 系列之: 小白福利！手把手教你做一个简单的代理服务器

作者：程序那些事

2021 年 12 月 15 日
本文字数：2306 字
阅读完需：约 8 分钟

简介

爱因斯坦说过:所有的伟大，都产生于简单的细节中。netty 为我们提供了如此强大的 eventloop、channel 通过对这些简单东西的有效利用，可以得到非常强大的应用程序，比如今天要讲的代理。

代理和反向代理

相信只要是程序员应该都听过 nginx 服务器了，这个超级优秀 nginx 一个很重要的功能就是做反向代理。那么有小伙伴要问了，有反向代理肯定就有正向代理，那么他们两个有什么区别呢？

先讲一下正向代理，举个例子，最近流量明星备受打击，虽然被打压，但是明星就是明星，一般人是见不到的，如果有人需要跟明星对话的话，需要首先经过明星的经纪人，有经纪人将话转达给明星。这个经纪人就是正向代理。我们通过正向代理来访问要访问的对象。

那么什么是反向代理呢？比如现在出现了很多人工智能，假如我们跟智能机器人 A 对话，然后 A 把我们之间的对话转给了后面的藏着的人，这个人用他的智慧，回答了我们的对话，交由智能机器人 A 输出，最终实现了人工智能。这个过程就叫做反向代理。

netty 实现代理的原理

那么在 netty 中怎么实现这个代理服务器呢？

首选我们首先代理服务器是一个服务器，所以我们需要在 netty 中使用 ServerBootstrap 创建一个服务器：

EventLoopGroup bossGroup = new NioEventLoopGroup(1);        EventLoopGroup workerGroup = new NioEventLoopGroup();        try {            ServerBootstrap b = new ServerBootstrap();            b.group(bossGroup, workerGroup)             .channel(NioServerSocketChannel.class)             .handler(new LoggingHandler(LogLevel.INFO))             .childHandler(new SimpleDumpProxyInitializer(REMOTE_HOST, REMOTE_PORT))             .childOption(ChannelOption.AUTO_READ, false)             .bind(LOCAL_PORT).sync().channel().closeFuture().sync();

复制代码

在这个 local 服务器中，我们传入 ProxyInitializer。在这个 handler 初始化器中，我们传入自定义的 handler：

    public void initChannel(SocketChannel ch) {        ch.pipeline().addLast(                new LoggingHandler(LogLevel.INFO),                new SimpleDumpProxyInboundHandler(remoteHost, remotePort));    }

复制代码

在自定义的 handler 中，我们使用 Bootstrap 创建一个 client，用来连接远程要代理的服务器，我们将这个 client 端的创建放在 channelActive 方法中：

// 开启outbound连接        Bootstrap b = new Bootstrap();        b.group(inboundChannel.eventLoop())         .channel(ctx.channel().getClass())         .handler(new SimpleDumpProxyOutboundHandler(inboundChannel))         .option(ChannelOption.AUTO_READ, false);        ChannelFuture f = b.connect(remoteHost, remotePort);

复制代码

然后在 client 建立好连接之后，就可以从 inboundChannel 中读取数据了：

outboundChannel = f.channel();        f.addListener(future -> {            if (future.isSuccess()) {                // 连接建立完毕，读取inbound数据                inboundChannel.read();            } else {                // 关闭inbound channel                inboundChannel.close();            }        });

复制代码

因为是代理服务，所以需要将 inboundChannel 读取的数据，转发给 outboundChannel，所以在 channelRead 中我们需要这样写：

    public void channelRead(final ChannelHandlerContext ctx, Object msg) {        // 将inboundChannel中的消息读取，并写入到outboundChannel        if (outboundChannel.isActive()) {            outboundChannel.writeAndFlush(msg).addListener((ChannelFutureListener) future -> {                if (future.isSuccess()) {                    // flush成功，读取下一个消息                    ctx.channel().read();                } else {                    future.channel().close();                }            });        }    }

复制代码

当 outboundChannel 写成功之后，再继续 inboundChannel 的读取工作。

同样对于 client 的 outboundChannel 来说，也有一个 handler，在这个 handler 中，我们需要将 outboundChannel 读取到的数据反写会 inboundChannel 中：

    public void channelRead(final ChannelHandlerContext ctx, Object msg) {        // 将outboundChannel中的消息读取，并写入到inboundChannel中        inboundChannel.writeAndFlush(msg).addListener((ChannelFutureListener) future -> {            if (future.isSuccess()) {                ctx.channel().read();            } else {                future.channel().close();            }        });    }

复制代码

当 inboundChannel 写成功之后，再继续 outboundChannel 的读取工作。

如此一个简单的代理服务器就完成了。

实战

如果我们将本地的 8000 端口，代理到 www.163.com 的 80 端口，会发生什么情况呢？运行我们的程序，访问 http://localhost:8000, 我们会看到下面的页面：

为什么没有如我们想象的那样展示正常的页面呢？那是因为我们代理过去之后的域名是 localhost，而不是正常的 www.163.com, 所以服务器端不认识我们的请求，从而报错。

总结

本文的代理服务器之间简单的转发请求，并不能够处理上述的场景，那么该怎么解决上面的问题呢？敬请期待我的后续文章！

本文的例子可以参考：learn-netty4

本文已收录于 http://www.flydean.com/35-netty-simple-proxy/
最通俗的解读，最深刻的干货，最简洁的教程，众多你不知道的小技巧等你来发现！
欢迎关注我的公众号:「程序那些事」,懂技术，更懂你！

发布于: 6 小时前阅读数: 38

原文链接:【http://xie.infoq.cn/article/2d42d9b8e82549fa89c28c38f】。文章转载请联系作者。

程序那些事

关注

关注公众号：程序那些事，更多精彩等着你！ 2020.06.07 加入

最通俗的解读，最深刻的干货，最简洁的教程，众多你不知道的小技巧，尽在公众号：程序那些事！

发布

暂无评论

创作场景

netty 系列之: 小白福利！手把手教你做一个简单的代理服务器

简介

代理和反向代理

netty 实现代理的原理

实战

总结

程序那些事

评论