如何在Jersey客户端中读取有效负载

Question

我这里有个小问题。在触发请求时，我希望使用HMAC对整个消息进行签名，并将生成的签名添加到头中。

所以我实施了

javax.ws.rs.ext.WriterInterceptorContext

在的

public void aroundWriteTo(WriterInterceptorContext context) throws IOException, WebApplicationException

方法I无法访问实体的字符串表示形式。它总是返回一个空字符串。原因似乎是在WriterInterceptor之后执行的MessageBodyWriter。

基本上，我有以下两种情况：

public void aroundWriteTo(WriterInterceptorContext context) throws IOException, WebApplicationException {
    try {
        final ClientOutputStream stream = (ClientOutputStream) requestContext.getProperty(HTTPCLIENT_ENTITY_STREAM);
        String payload = stream.getString(Charset.forName("UTF-8")); // returns alway empty String
        String signature = doSomeSuffWithPayload(payload);

        MultivaluedMap<String, Object> headers = context.getHeaders();
        headers.add(HmacHeaderValue.X_SIGNATURE.headerName(), signature);
        context.proceed();
    } catch (IllegalArgumentException | ParseException | InvalidKeyException | NoSuchAlgorithmException ex) {
        LOGGER.error(ex.getMessage());
    } catch (UnsupportedEncodingException ex) {
        LOGGER.error(ex.getMessage());
    } catch (IOException ex) {
        LOGGER.error(ex.getMessage());
    }
}

在这里，do某位SuffBackPayload（有效载荷）方法不起作用，因为有效载荷总是空的。

我以为一个小把戏就可以了，所以我换了环境。继续（）调用到任何其他位置：

public void aroundWriteTo(WriterInterceptorContext context) throws IOException, WebApplicationException {
    try {
        context.proceed();
        final ClientOutputStream stream = (ClientOutputStream) requestContext.getProperty(HTTPCLIENT_ENTITY_STREAM);
        String payload = stream.getString(Charset.forName("UTF-8")); // returns the right string representation
        String signature = doSomeSuffWithPayload(payload);

        MultivaluedMap<String, Object> headers = context.getHeaders();
        headers.add(HmacHeaderValue.X_SIGNATURE.headerName(), signature); // doesn't add the header
    } catch (IllegalArgumentException | ParseException | InvalidKeyException | NoSuchAlgorithmException ex) {
        LOGGER.error(ex.getMessage());
    } catch (UnsupportedEncodingException ex) {
        LOGGER.error(ex.getMessage());
    } catch (IOException ex) {
        LOGGER.error(ex.getMessage());
    }
}

在这种情况下，实体的字符串表示形式是ok。但是将头添加到请求中不起作用。

因此，atm我可以将（错误的）签名添加到标题和一个总是空的实体，或者使用正确的实体添加正确的签名，但标题没有添加。

我的问题是：有没有人知道一种通过使用WriterInterceptor来获取实体的字符串表示的方法？

伊迪丝说：

我们使用的是2.25版。泽西岛1号客户。2.27也没有解决问题。

Answer 1

在深入搜索API后，我发现实体确实是在MessageBodyWriter中的WriterInterceptor之后写入的。除此之外，在MessageBodyWriter中的过程中也会添加头。这就是上述两种方法都不起作用的原因。

我的解决方案atm是建立正确的MessageBodyWriter，并让它序列化实体，就像在WriterInterceptor之后执行的MessageBodyWriter中一样。如果这种情况下不再需要WriterInterceptor，实现Client刚需过滤器就可以了。

import javax.ws.rs.ext.MessageBodyWriter;
import javax.ws.rs.ext.Providers;

@Context
private Providers providers;

private String getPayloadFromRequest(ClientRequestContext requestContext) throws IOException {
    Object object = requestContext.getEntity();
    if (object != null) {
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        try {
            // buffer into which myBean will be serialized
            Class<Object> type = (Class<Object>) requestContext
                    .getEntityClass();
            GenericType<Object> genericType = new GenericType<Object>(type) {
            };

            // get most appropriate MBW
            final MessageBodyWriter<Object> messageBodyWriter = providers
                    .getMessageBodyWriter(type, type, new Annotation[]{},
                            MediaType.APPLICATION_JSON_TYPE);

            try {
                // use the MBW to serialize myBean into baos
                messageBodyWriter.writeTo(object, object.getClass(),
                        genericType.getType(), new Annotation[]{},
                        MediaType.APPLICATION_JSON_TYPE,
                        new MultivaluedHashMap<String, Object>(), baos);
            } catch (IOException e) {
                throw new RuntimeException(
                        "Error while serializing MyBean.", e);
            }

            return baos.toString();
        } finally {
            baos.close();
        }

    } else {
        return "";
    }
}

代码不是我的，但不幸的是我丢失了源代码。