Http-клиент Джерси: поместите запрос с пользовательской длиной содержимого - PullRequest
Новая
       21

Http-клиент Джерси: поместите запрос с пользовательской длиной содержимого

0 голосов
/ 16 мая 2019

Хочется поместить данные из InputStream, но Джерси не может автоматически определять длину данных и не задавать заголовок Content-Length.

Response destinationResponse = responseWebTarget
                    .request()
                    .header(HEADER_X_AUTH_TOKEN, cmd.getOptionValue("dat"))
                    .put(Entity.entity(inputStream, MediaType.APPLICATION_OCTET_STREAM))

результат: 

INFO: 2 * Sending client request on thread main
2 > PUT http://192.168.1.10:8080/v1/AUTH_system/08138784704e2/test
2 > Content-Type: application/octet-stream
2 > X-Auth-Token: AUTH_tka2d071e5ba3e46e58cbbc3bdcc57bc70

Я знаю длину данных и пытаюсь добавить заголовок вручную: 

            Object contentLength = sourceResponse.getHeaders().get(HTTP.CONTENT_LEN).get(0);
            Response destinationResponse = responseWebTarget
                    .request()
                    .header(HTTP.CONTENT_LEN, contentLength)
                    .header(HEADER_X_AUTH_TOKEN, cmd.getOptionValue("dat"))
                    .put(Entity.entity(is, MediaType.APPLICATION_OCTET_STREAM))

Теперь запрос выглядит нормально, но Джерси выдает исключение: 

INFO: 2 * Sending client request on thread main
2 > PUT http://192.168.1.10:8080/v1/AUTH_system/08138784704e2/test
2 > Content-Length: 2760033628
2 > Content-Type: application/octet-stream
2 > X-Auth-Token: AUTH_tka2d071e5ba3e46e58cbbc3bdcc57bc70

Exception in thread "main" javax.ws.rs.ProcessingException: org.apache.http.client.ClientProtocolException
    at org.glassfish.jersey.apache.connector.ApacheConnector.apply(ApacheConnector.java:472)
    at org.glassfish.jersey.client.ClientRuntime.invoke(ClientRuntime.java:254)
    at org.glassfish.jersey.client.JerseyInvocation.lambda$invoke$0(JerseyInvocation.java:729)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:205)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:390)
    at org.glassfish.jersey.client.JerseyInvocation.invoke(JerseyInvocation.java:728)
    at org.glassfish.jersey.client.JerseyInvocation$Builder.method(JerseyInvocation.java:421)
    at org.glassfish.jersey.client.JerseyInvocation$Builder.put(JerseyInvocation.java:310)
    at copier.Main.main(Main.java:118)
Caused by: org.apache.http.client.ClientProtocolException
    at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:186)
    at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:71)
    at org.glassfish.jersey.apache.connector.ApacheConnector.apply(ApacheConnector.java:426)
    ... 10 more
Caused by: org.apache.http.ProtocolException: Content-Length header already present
    at org.apache.http.protocol.RequestContent.process(RequestContent.java:96)
    at org.apache.http.protocol.ImmutableHttpProcessor.process(ImmutableHttpProcessor.java:132)
    at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:182)
    at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:88)
    at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
    at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:184)
    ... 12 more

Как это правильно сделать?

1 Ответ

0 голосов
/ 19 мая 2019

Я заменил Джерси на Apache HC, 

    Long contentLength = Long.parseLong(sourceResponse.getHeaders(HTTP.CONTENT_LEN)[0].getValue());
    HttpPut putRequest = new HttpPut(destinationUrl);
    putRequest.addHeader(HEADER_X_AUTH_TOKEN, cmd.getOptionValue("dat"));
    InputStreamEntity entity = new InputStreamEntity(is, contentLength, ContentType.APPLICATION_OCTET_STREAM);
    putRequest.setEntity(entity);

Имеет InputStream упаковщик с возможностью указания длины.

PS ^ Кроме того, Chunked Transfer Encoding правильно работает в Apache HC, но я не смог включить его в Jersey Client.

...