首页 > 基础资料博客日记

/**
 * netty 实现反向代理
 * 
 * @since 0.27.0
 * @author 老马啸西风
 */
public class NginxRequestDispatchProxyPass extends AbstractNginxRequestDispatch {

    private static final Log logger = LogFactory.getLog(NginxRequestDispatchProxyPass.class);

    @Override
    public void doDispatch(NginxRequestDispatchContext context) {
        // 原始的请求
        final FullHttpRequest request = context.getRequest();
        final ChannelHandlerContext ctx = context.getCtx();

        // 创建一个新的 FullHttpRequest 转发到目标服务器
        FullHttpRequest forwardedRequest = new DefaultFullHttpRequest(
                request.protocolVersion(), request.method(), request.uri(), request.content().retainedDuplicate());
        forwardedRequest.headers().set(request.headers());

        final NginxLoadBalanceConfig nginxLoadBalanceConfig = context.getBalanceConfig();

        // 创建一个新的 Bootstrap 进行 HTTP 请求
        Bootstrap b = new Bootstrap();
        b.group(ctx.channel().eventLoop())
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<Channel>() {
                    @Override
                    protected void initChannel(Channel ch) throws Exception {
                        //...

                        ch.pipeline().addLast(new SimpleChannelInboundHandler<FullHttpResponse>() {
                            @Override
                            protected void channelRead0(ChannelHandlerContext clientCtx, FullHttpResponse response) throws Exception {
                                // 将目标服务器的响应写回到客户端
                                FullHttpResponse clientResponse = new DefaultFullHttpResponse(
                                        response.protocolVersion(), response.status(), response.content().retainedDuplicate());

                                clientResponse.headers().set(response.headers());

                                ctx.writeAndFlush(clientResponse).addListener(ChannelFutureListener.CLOSE);
                                clientCtx.close();
                            }

                            @Override
                            public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
                                logger.error("exceptionCaught meet ex", cause);
                                ctx.close();
                            }
                        });
                    }
                });

        // 连接到目标服务器并发送请求
        final IServer server = getActualServer(nginxLoadBalanceConfig);
        b.connect(server.host(), server.port()).addListener((ChannelFutureListener) future -> {
            if (future.isSuccess()) {
                future.channel().writeAndFlush(forwardedRequest);
            } else {
                ctx.close();
            }
        });
    }
}

负载均衡

负载均衡策略，可以看我以前的文章：

从零手写实现 nginx-32-load balance 负载均衡算法 java 实现

小结

到这里开始，我们基本实现了反向代理。

当然，其中还有很多细节需要处理。

文章来源:https://www.cnblogs.com/houbbBlogs/p/18327785
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：jacktools123@163.com进行投诉反馈，一经查实，立即删除！

标签：

上一篇：华为OD机试D卷 --考古学家--24年OD统一考试（Java & JS & Python & C & C++）
下一篇：已解决java.io.EOFException异常的正确解决方法，亲测有效！！！

首页 > 基础资料博客日记

从零手写实现 nginx-35-proxy_pass netty 如何实现？

前言

手写 nginx 系列

netty 如何实现反向代理?

整体思路

实现代码

负载均衡

小结

相关文章

最新发布

点击排行

本站推荐

标签云

首页 > 基础资料 博客日记

从零手写实现 nginx-35-proxy_pass netty 如何实现？

前言

手写 nginx 系列

netty 如何实现反向代理?

整体思路

实现代码

负载均衡

小结

相关文章

最新发布

点击排行

本站推荐

标签云

首页 > 基础资料博客日记