使用Netty搭建http代理服务器的简单方法？答案

【问题标题】：Simple way to use Netty to build an http proxy server?使用Netty搭建http代理服务器的简单方法？
【发布时间】：2020-02-13 13:51:26
【问题描述】：

我是 Netty 的新手，正在考虑使用它来制作一个简单的 http 代理服务器，该服务器接收来自客户端的请求，将请求转发到另一台服务器，然后将响应复制回原始请求的响应.一个额外的要求是我能够支持超时，这样如果代理服务器响应时间过长，代理将自行响应并关闭与代理服务器的连接。

我已经使用 Jetty 实现了这样一个应用程序，但是使用 Jetty 我需要使用太多线程来防止入站请求被阻塞（这是一个轻量级应用程序，它使用非常少的内存或 cpu，但是代理服务器足够高，流量突发导致代理服务器排队或需要太多线程）。

根据我的理解，我可以使用 Netty 构建一个管道，其中每个阶段执行少量计算，然后释放它的线程并等待直到数据准备好等待管道中的下一个阶段执行。

我的问题是，有这样的应用程序的简单示例吗？到目前为止，我对基本 Netty 教程的服务器代码进行了简单修改，但它缺乏对客户端的所有支持。我看到了 netty 客户端教程，但不知道如何混合两者的代码来创建一个简单的代理应用程序。

public static void main(String[] args) throws Exception {
    ChannelFactory factory =
            new NioServerSocketChannelFactory(
                    Executors.newCachedThreadPool(),
                    Executors.newCachedThreadPool());

    ServerBootstrap bootstrap = new ServerBootstrap(factory);

    bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
        public ChannelPipeline getPipeline() {
            return Channels.pipeline(
                    new HttpRequestDecoder(),
                    new HttpResponseEncoder(),
                    /* 
                     * Is there something I can put here to make a
                     * request to another server asynchronously and
                     * copy the result to the response inside
                     * MySimpleChannelHandler?
                     */
                    new MySimpleChannelHandler()
                    );
        }
    });

    bootstrap.setOption("child.tcpNoDelay", true);
    bootstrap.setOption("child.keepAlive", true);

    bootstrap.bind(new InetSocketAddress(8080));
}

private static class MySimpleChannelHandler extends SimpleChannelHandler {

    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
        HttpRequest request = (HttpRequest) e.getMessage();
        HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
        response.setContent(request.getContent());

        Channel ch = e.getChannel();
        ChannelFuture f = ch.write(response);
        f.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future) {
                Channel ch = future.getChannel();
                ch.close();
            }
        });
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
        e.getCause().printStackTrace();

        Channel ch = e.getChannel();
        ch.close();
    }
}

【问题讨论】：

标签： java netty

【解决方案1】：

您必须查看 LittleProxy 以了解他们是如何做到的，因为它是在 Netty 之上编写的。

【讨论】：

链接失效