简介
爱因斯坦说过:所有的伟大,都产生于简单的细节中。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, 所以服务器端不认识我们的请求,从而报错。
索尼笔记本重装系统教程(索尼笔记本老款型号大全)
笔记本如何重装系统?今天我就教下大家怎么把这个u盘的系统装在笔记本里面 首先第一步我们需要把这个u盘插在电脑上的任意一个usb接口 笔记本电脑都有一个快捷启动哈就是快速地启动u盘不用这么繁(0)人阅读时间:2023-06-15索尼笔记本口碑怎么样(索尼笔记本性价比怎么样)
对于这时代的人来说,笔记本已成为了人们生活中必不可少的电子装备,日常休头娱乐都会用到它。而轻薄本凭借着其出色的便携性和不俗的性能,已成为笔记本电脑中最重要的一个品类,以下为大家介绍十款颜值超高的笔(0)人阅读时间:2023-06-152023年青岛市计划实施公共停车场项目最新消息
2023年全市计划实施公共停车场项目95个,包括40个续建项目和55个新建项目,年内新增泊位2万个以上。(0)人阅读时间:2023-06-15笔记本内置无线网卡推荐(笔记本内置无线网卡哪个好)
一款笔记本的无线性能(包括Wi-Fi和蓝牙),取决于其内置的无线网卡型号。那么,笔记本的无线网卡都存在哪些类别?又该如何区分高下?有没有升级的可能呢? 在笔记本领域,内置无线网卡的品牌主要以英特(0)人阅读时间:2023-06-15网络代理服务器 网络代理服务器拒绝连接
简介 爱因斯坦说过:所有的伟大,都产生于简单的细节中。netty为我们提供了如此强大的eventloop、channel通过对这些简单东西的有效利用,可以得到非常强大的应用程序,比如今天要讲的代..2023-06-15电磁铁的优点 电磁铁的优点是
1、电磁铁有许多优点:电磁铁的磁性有无可以用通、断电流控制;磁性的大小可以用电流的强弱或线圈的匝数多少来控制;也可通过改变电阻控制电流大小来控制磁性大小;它的磁极可以由改变电流的方向来控制,等等。即:磁性的强弱可以改变、..2023-06-15手机内存满了怎么办 手机内存满了怎么解决
1、现在大多数手机都配备清理功能,使用手机的清理功能能够去除掉一些没有用的数据文件,以达到释放内存的目的。2、如果手机内存满了,而手机又有sd卡槽,可以考虑加装sd卡槽扩展内存容量。3、手机内存满了,可能是手机内app太..2023-06-15如何将网络音乐导入荔枝中(怎样将音乐添加到荔枝播放器中)
使用荔枝时,我们可以将自己喜欢的网络音乐导入应用中。那么,如何将网络音乐导入荔枝中?下面我使用苹果手机来分享一下具体的操作流程。..2023-06-15