在Netty中处理HTTP状态码302暂时移动(Moved Temporarily)

Question

在Netty中处理HTTP状态码302暂时移动(Moved Temporarily)

javaredirecthttprequestnettyhttp-status-code-302

3

我正在进行的HTTP请求中得到了302状态码，我希望它由我的Netty代码处理。

我的客户端代码：

      public static void main(String[] args) throws Exception {
           URI uri = new URI("http://myurl.mydomain.com/v1/v2?param1=value1&param2=value2");           
           String host = uri.getHost();
            int port = 80;

         // Configure the client.
            EventLoopGroup group = new NioEventLoopGroup();
            try {
                Bootstrap b = new Bootstrap();
                b.group(group)
                 .channel(NioSocketChannel.class)
                 .handler(new NettyClientInitializer());
                // Make the connection attempt.
                Channel ch = b.connect(host, port).sync().channel();
                // Prepare the HTTP request.
                HttpRequest request = new DefaultHttpRequest(
                        HttpVersion.HTTP_1_1, HttpMethod.GET, uri.toString());
                request.headers().set(HttpHeaders.Names.HOST, host);
                request.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);  
                request.headers().set(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);

                /*// Set some example cookies.
                request.headers().set(
                        HttpHeaders.Names.COOKIE,
                        ClientCookieEncoder.encode(
                                new DefaultCookie("my-cookie", "foo"),
                                new DefaultCookie("another-cookie", "bar")));
*/
                // Send the HTTP request.
                ch.writeAndFlush(request);

                // Wait for the server to close the connection.
                ch.closeFuture().sync();
            } finally {
                // Shut down executor threads to exit.
                group.shutdownGracefully();
            }
      }

我的处理器代码:

public class NettyClientHandler extends SimpleChannelInboundHandler<HttpObject> {
    @Override
    public void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
        if (msg instanceof HttpResponse) {
            HttpResponse response = (HttpResponse) msg;

            System.out.println("STATUS: " + response.getStatus());
            System.out.println("VERSION: " + response.getProtocolVersion());
            System.out.println();

            if (!response.headers().isEmpty()) {
                for (String name: response.headers().names()) {
                    for (String value: response.headers().getAll(name)) {
                        System.out.println("HEADER: " + name + " = " + value);
                    }
                }
                System.out.println();
            }

            if (HttpHeaders.isTransferEncodingChunked(response)) {
                System.out.println("CHUNKED CONTENT {");
            } else {
                System.out.println("CONTENT {");
            }
        }
        if (msg instanceof HttpContent) {
            HttpContent content = (HttpContent) msg;

            System.out.print(content.content().toString(CharsetUtil.UTF_8));
            System.out.flush();

            if (content instanceof LastHttpContent) {
                System.out.println("} END OF CONTENT");
            }
        }
    }

    @Override
    public void exceptionCaught(
            ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }


}

我的初始化代码：

public class NettyClientInitializer extends ChannelInitializer<SocketChannel> {


    @Override
    public void initChannel(SocketChannel ch) throws Exception {
        // Create a default pipeline implementation.
        ChannelPipeline p = ch.pipeline();

        p.addLast("log", new LoggingHandler(LogLevel.INFO));
        // Enable HTTPS if necessary.
        /*
        if (ssl) {
            SSLEngine engine =
                SecureChatSslContextFactory.getClientContext().createSSLEngine();
            engine.setUseClientMode(true);

            p.addLast("ssl", new SslHandler(engine));
        }
*/
        p.addLast("codec", new HttpClientCodec());

        // Remove the following line if you don't want automatic content decompression.
       // p.addLast("inflater", new HttpContentDecompressor());

        // Uncomment the following line if you don't want to handle HttpChunks.
        p.addLast("aggregator", new HttpObjectAggregator(1048576));       
        p.addLast("handler", new NettyClientHandler());

    }
}

我参考了这个链接，它与我的问题相似： redirect - handling http 302 moved temporarily using netty 但是这段代码使用的是 3.x 版本的库，而且目前还没有答案。

我正在使用 Netty 4.0.12 库。

请告诉我如何使用 Netty 处理这个问题。

- Mitaksh Gupta

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Koekiebox · Accepted Answer

你可以修改你的NettyClientHandler来检查302重定向，并打开一个新连接来处理重定向的HTML内容。

对NettyClientHandler所做的更改：

//We know this is a redirect...
            if(response.getStatus().code() == HttpResponseStatus.FOUND.code()){//When its a 302...

                if(response.headers().names().contains("Location"))
                {
                    System.out.println("We have a redirect...");
                    //Now we will do the process over to get the actual content...
                    Main.main(new String[]{response.headers().get("Location")});
                }
            }

以下是对 main() 函数进行更改的示例，以处理重定向内容：

String urlPlace = "http://initial.com";

        if(args != null && args.length > 0)
        {
            urlPlace = args[0];
        }

        URI uri = new URI(urlPlace);
        String host = uri.getHost();
        int port = uri.getPort();
        if(port == -1)
        {
            port = 80;
        }

当我们收到HTTP状态码302时，"服务器"有责任设置新URL位置的Location标头，以便客户端适当处理。

请参见Wikipedia 302。