Netty HttpRequest, включая Json

Я пытаюсь создать HTTP-запрос к нашему CDN Rackspace

Мне нужно добавить строку Json в качестве содержимого, чтобы дать инструкции по входу

Я использовал curl для проверки информации, и он работает, но через Netty я получаю ответ 400 Bad Request, который говорит мне, что я не передаю Json правильно, все примеры на Github чрезмерно свернуты, а те, что в переполнении стека, предназначены для версии 3, любая помощь будет буду очень признателен вот мой код Я использую Netty 4.1.0Beta5

URI uri = new URI("https://identity.api.rackspacecloud.com");
HttpDataFactory factory = new DefaultHttpDataFactory( 
                              DefaultHttpDataFactory.MINSIZE);
HttpPostRequestEncoder bodyRequestEncoder = new 
HttpPostRequestEncoder(factory, request, false);
HttpHeaders headers = request.headers();
headers.set(HttpHeaderNames.HOST, 
"https://identity.api.rackspacecloud.com/v2.0/tokens");
            headers.set(HttpHeaderNames.CONTENT_TYPE, new   
AsciiString("application/json"));
String json = "{\"auth\":{\"RAX-KSKEY:apiKeyCredentials\":{\"username
          \":\"AAsdFrank\",\"apiKey\":\"adfadfdadsf33434fdfdfdfaf\"}}}";
ByteBuf buffer= Unpooled.copiedBuffer(json, CharsetUtil.UTF_8);
headers.set(HttpHeaderNames.CONTENT_LENGTH,  
                  String.valueOf(buffer.readableBytes()));
bodyRequestEncoder.addBodyAttribute("json", json);
request = bodyRequestEncoder.finalizeRequest();
io.netty.channel.Channel channel =  
cdnBootstrap.connect("identity.api.rackspacecloud.com", 
443).sync().channel();
channel.writeAndFlush(request);

И я получаю следующий ответ, в котором говорится, что я подключился к серверу, но мой запрос не был правильно сформирован.

STATUS: 400 Bad Request
VERSION: HTTP/1.1
HEADER: Connection = close
HEADER: Content-Length = 166
HEADER: Content-Type = text/html
HEADER: Date = Thu, 25 Jun 2015 22:10:20 GMT
HEADER: Server = nginx
CONTENT {
<html>
<head><title>400 Bad Request</title></head>
<body bgcolor="white">
<center><h1>400 Bad Request</h1></center>
<hr><center>nginx</center>
</body>
</html>

Все предложения приветствуются


json httprequest netty httpcontent
person Louis Biron    schedule 25.06.2015    source источник

Ответы (1)


arrow_upward
1
arrow_downward

После обычного слишком большого количества часов я нашел решение здесь, оно работает с Netty 4.1.0.Beta5 Состав запроса

String json = "{\"auth\":{\"RAX-KSKEY:apiKeyCredentials\":{\"username
\":\"\ADDHDD",\"apiKey\":\"adfasdfasdfasdfasdfasdfsdf\"}}}";
         URI uri = new URI("https://identity.api.rackspacecloud.com/v2.0/tokens");
         DefaultFullHttpRequest request = new 
DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST,  
uri.getRawPath());
         request.headers().set(HttpHeaderNames.CONTENT_TYPE, 
"application/json");
         request.headers().set(HttpHeaderNames.ACCEPT_ENCODING, 
HttpHeaderValues.GZIP);
         request.headers().set(HttpHeaderNames.HOST, 
"identity.api.rackspacecloud.com:443");
         ByteBuf buffer = request.content().clear();
         int p0 = buffer.writerIndex();
         buffer.writeBytes(json.getBytes(CharsetUtil.UTF_8));
         int p1 = buffer.writerIndex();
         request.headers().set(HttpHeaderNames.CONTENT_LENGTH,  
Integer.toString(p1 - p0));
         io.netty.channel.Channel channel =  
dnBootstrap.connect("identity.api.rackspacecloud.com", 
443).sync().channel();
        channel.writeAndFlush(request);

и вот Инициализатор

ChannelPipeline pipeline = ch.pipeline();
        if (sslCtx != null) {
            pipeline.addLast("ssl", sslCtx.newHandler(ch.alloc()));
        }
        pipeline.addLast("codec", new HttpClientCodec());
        pipeline.addLast("inflater", new HttpContentDecompressor());
        pipeline.addLast("chunkedWriter", new ChunkedWriteHandler());
        pipeline.addLast("ResponseDecoder",new HttpResponseDecoder());
        pipeline.addLast("aggregator",new 
              HttpObjectAggregator(512*1024));
        pipeline.addLast("handler", new CdnClientHandler());
person Louis Biron    schedule 26.06.2015