JAX-RS 2 drucken JSON-Anfrage

Deshalb gibt es ein paar Dinge zu beachten, wenn Sie versuchen, dies umzusetzen

1. Für die request-entity, werden Sie wollen, dass die Serialisierung zu werden, Griff durch den Rahmen, das heißt, Sie nicht wollen, etwas zu tun, wie

   @Override
   public void filter(ClientRequestContext requestContext) {
       Object entity = requestContext.getEntity();
       String serialized = serializeEntity(entity);
       log(serialized);

   Hier sind Sie serialisieren es selbst, vielleicht mit Hilfe von Jackson ObjectMapper oder so etwas. Sie könnte tun es auf diese Weise, aber es ist eine Art beschränkt, in der Art damit umgehen kann. Wenn Sie lassen Sie das Objekt serialisiert werden, wie es bereits gehandhabt, indem der Rahmen, der Rahmen wird in der Lage sein, zu unterstützen, viel mehr Arten als nur JSON.

   Lassen, Rahmen Griff der Serialisierung, und noch in der Lage sein serialisiert die Daten, die wir benötigen, um ein WriterInterceptor. Was wir tun können, ist legen Sie die entity-output-stream zu einem ByteArrayOutputStream, und lassen Sie dann das framework serialisiert die Anfrage Objekt unsere ByteArrayOutputStream dann anschliessend melden Sie diese bytes. Dies ist, wie das Trikot LoggingFilter diese verarbeitet.

2. Für die Antwort, in unserem filter, müssen wir extrahieren Sie die Daten aus dem response-stream, aber auch wir müssen sicherstellen, dass der stream noch Daten, es wurde nicht deserialisiert noch für den Kunden. Um dies zu tun mark() und reset() den Strom, vorausgesetzt, die Kennzeichnung unterstützt wird. Wenn nicht, wickeln Sie es in ein BufferedOutputStream. Wieder, dies ist, wie das Trikot LoggingFilter diese verarbeitet.

Unten ist eine komplette einfache Umsetzung. Das meiste davon ist gerade von der Jersey LoggingFilter, wenn es abgespeckte nur für Ihren Fall. Das Trikot LoggingFilter meldet eine Menge von anderen Informationen, abgesehen von den nur die Einheit. Eine Sache, die ich ging, ist die Prüfung für das charset. Ich habe gerade verwendet eine hart codierte UTF-8, wie die MessageUtil verwendete Klasse von Jersey, Jersey ist spezifisch. Wenn Sie wollen, um den filter ist universeller für andere Zeichensätze, möchten Sie vielleicht zu suchen in der Festsetzung.

import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.FilterOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.logging.Logger;
import javax.annotation.Priority;
import javax.ws.rs.WebApplicationException;
import javax.ws.rs.client.ClientRequestContext;
import javax.ws.rs.client.ClientRequestFilter;
import javax.ws.rs.client.ClientResponseContext;
import javax.ws.rs.client.ClientResponseFilter;
import javax.ws.rs.ext.WriterInterceptor;
import javax.ws.rs.ext.WriterInterceptorContext;

@Priority(Integer.MIN_VALUE)
public class EntityLoggingFilter implements ClientRequestFilter, ClientResponseFilter, WriterInterceptor {

    private static final Logger logger = Logger.getLogger(EntityLoggingFilter.class.getName());
    private static final String ENTITY_STREAM_PROPERTY = "EntityLoggingFilter.entityStream";
    private static final Charset DEFAULT_CHARSET = StandardCharsets.UTF_8;
    private final int maxEntitySize = 1024 * 8;

    private void log(StringBuilder sb) {
        logger.info(sb.toString());
    }

    private InputStream logInboundEntity(final StringBuilder b, InputStream stream, final Charset charset) throws IOException {
        if (!stream.markSupported()) {
            stream = new BufferedInputStream(stream);
        }
        stream.mark(maxEntitySize + 1);
        final byte[] entity = new byte[maxEntitySize + 1];
        final int entitySize = stream.read(entity);
        b.append(new String(entity, 0, Math.min(entitySize, maxEntitySize), charset));
        if (entitySize > maxEntitySize) {
            b.append("...more...");
        }
        b.append('\n');
        stream.reset();
        return stream;
    }

    @Override
    public void filter(ClientRequestContext requestContext) throws IOException {
        if (requestContext.hasEntity()) {
            final OutputStream stream = new LoggingStream(requestContext.getEntityStream());
            requestContext.setEntityStream(stream);
            requestContext.setProperty(ENTITY_STREAM_PROPERTY, stream);
        }
    }

    @Override
    public void filter(ClientRequestContext requestContext,
            ClientResponseContext responseContext) throws IOException {
        final StringBuilder sb = new StringBuilder();
        if (responseContext.hasEntity()) {
            responseContext.setEntityStream(logInboundEntity(sb, responseContext.getEntityStream(),
                    DEFAULT_CHARSET));
            log(sb);
        }

    }

    @Override
    public void aroundWriteTo(WriterInterceptorContext context)
            throws IOException, WebApplicationException {
        final LoggingStream stream = (LoggingStream) context.getProperty(ENTITY_STREAM_PROPERTY);
        context.proceed();
        if (stream != null) {
            log(stream.getStringBuilder(DEFAULT_CHARSET));
        }
    }

    private class LoggingStream extends FilterOutputStream {

        private final StringBuilder sb = new StringBuilder();
        private final ByteArrayOutputStream baos = new ByteArrayOutputStream();

        LoggingStream(OutputStream out) {
            super(out);
        }

        StringBuilder getStringBuilder(Charset charset) {
            //write entity to the builder
            final byte[] entity = baos.toByteArray();

            sb.append(new String(entity, 0, entity.length, charset));
            if (entity.length > maxEntitySize) {
                sb.append("...more...");
            }
            sb.append('\n');

            return sb;
        }

        @Override
        public void write(final int i) throws IOException {
            if (baos.size() <= maxEntitySize) {
                baos.write(i);
            }
            out.write(i);
        }
    }
}

Siehe Auch:

• Quellcode für Jersey LoggingFilter