网络代理服务器 免费网络代理服务器
来源： 最后更新：22-12-19 06:08:27
-
简介
爱因斯坦说过:所有的伟大，都产生于简单的细节中。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, 所以服务器端不认识我们的请求，从而报错。
标签: [db:关键词]
免责声明：本文系转载，版权归原作者所有；旨在传递信息，其原创性以及文中陈述文字和内容未经本站证实。
国务院国资委原副部长级干部骆玉林接受中央纪委国家监委审查调查国务院国资委原副部长级干部骆玉林接受中央纪委国家监委审查调查
2023泗水新能源电动车消费券怎么领取（泗水新能源汽车4s店） 关于250省道邳州段对危化品运输车实施限行的通告 夏季宝宝这样吃就不会长痱子 21年，江西女孩在女厕遇歹徒，被挟持时：我给你1千，你去嫖娼
热门标签
热门文章
-
智慧团建系统初始密码是什么 23-05-17
-
2023年5月16日国外天气预报：印度北部部分地区高温依旧 23-05-17
-
八个月的宝宝如何喂养 八个月宝宝喂养指南 23-05-17
-
遇见你之前经典台词（遇见你之前经典台词你是我每天醒来的动力） 23-05-17
-
蜗居台词经典台词（蜗居里的台词太经典了） 23-05-17
-
高温来袭：电动车仪表盘保护膜被晒化 山东高温黄色预警生效中 23-05-17
-
8个月宝宝食谱 8个月宝宝食谱精选推荐 23-05-17
-
四个全面防护，君乐宝告诉你选择奶粉的关键是什么？ 23-05-17
-
奶粉哪个牌子好又安全？君乐宝为你展现中国奶粉好品质！ 23-05-17
-
花千骨流放蛮荒是多少集（花千骨被流放到蛮荒是第几集） 23-05-16
