Wie, um eine Reaktion zu erhalten Körper in Zuul post-filter?

Wie es möglich ist, zu Lesen, eine Antwort-Körpers während der Verwendung Zuul als proxy in post filter?

Ich versuche zu rufen, wird der code wie folgt:

@Component
public class PostFilter extends ZuulFilter {

    private static final Logger log = LoggerFactory.getLogger(PostFilter.class);

    @Override
    public String filterType() {
        return "post";
    }

    @Override
    public int filterOrder() {
        return 2000;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        ctx.getResponseBody(); //null

        //cant't do this, cause input stream is used later in other filters and I got InputStream Closed exception
        //GZIPInputStream gzipInputStream = new GZIPInputStream(stream);
        return null;
    }

}

InformationsquelleAutor Dariusz Mydlarz | 2016-01-29

11

Habe ich es geschafft, dies zu überwinden. Die Lösung besteht aus 4 Schritten:
1. Lesen ctx.getResponseDataStream() in einen ByteArrayOutputStream
2. Kopieren Ausgabestrom zu 2 InputStreams
3. Verwenden es für Ihre individuelle Zwecke.
4. Verwenden Sie die zweite neu zuordnen Kontext: context.setResponseBody(inputStream)
  - reading stream von Punkt 1 würde dazu führen, dass der stream nicht erneut gelesen werden kann, so dass dieser Weg Sie vorbei an einem neuen, frischen Bach, der nicht Lesen noch
Hat es funktioniert mit filterOrder Rückkehr 2000 ?
Erinnere mich nicht genau, aber wahrscheinlich ja. Hast du kopiert inputstream?
Kopieren der InputStream Super geklappt, aber ich musste meinen filter um, bevor org.springframework.cloud.netflix.zuul.filters.post.SendResponseFilter. Mit etwas mehr als 1000 führt zu einer "InputStream bereits geschlossen" - Fehler, weil die Antwort Körper bereits gelesen und zurückgegeben.
Ok, gut. Die Nummer, die ich verwendet, im Beispiel war wohl nicht so wichtig für meine Frage 😉
der filter sollte ein Teil der Antwort. Ich war versucht, für Stunden, wurde nur der filter Nummer 10 und es funktionierte

InformationsquelleAutor Dariusz Mydlarz
3

Wie Sie sehen können, in diesem Beispiel, haben Sie zwei Methoden zur Verfügung zum extrahieren der Antwort der Körper:

1 - ctx.getResponseBody();

2 - ctx.getResponseDataStream();

Müssen Sie überprüfen, welche nicht null sind, und diese verwenden.

Danke, das habe ich schon id hat, aber es war ein bisschen tricky. Ich poste etwas code
in meinem Fall, ctx.getResponseBody(); return null, so dass ich verwendet, ctx.getResponseDataStream(); statt
gerade festgestellt, dass die delete hat ctx.getResponseBody() aber post und put hat getResponseDataStream()

InformationsquelleAutor Pablo Valiente
3

Vielen Dank für die Anregung, das ist der code, den ich verwendet, funktioniert.
```
try (final InputStream responseDataStream = ctx.getResponseDataStream()) {
   final String responseData = CharStreams.toString(new InputStreamReader(responseDataStream, "UTF-8"));
   ctx.setResponseBody(responseData);
} catch (IOException e) {
   logger.warn("Error reading body",e);
}
```
Nice Verwendung von Java 7 try-mit-Ressourcen syntax hier. Falls jemand besorgt ist über CharStreams.toString() wird @Beta (IntelliJ warnt davor, es), könnte man auch verwenden, Spring StreamUtils.copyToString() wenn es eine Abhängigkeit. Auf diese Weise kann man auch weglassen InputStreamReader Instanz. Auch, imho ist es ein bisschen sauberer zu verwenden StandardCharsets.UTF_8 statt "UTF-8".

InformationsquelleAutor codesalsa
1

Vorsichtig sein, die filterNumber

Mit etwas mehr als 1000 führt zu einer "InputStream schon
geschlossen" - Fehler, weil die Antwort Körper bereits gelesen wurden, und

Benutzte ich die Nummer 10 und fein gearbeitet

InformationsquelleAutor Pedro Romão

Wenn jemand kämpft mit komprimierten Antwort, hier die Lösung die ich verwendet habe:

//Read the compressed response
RequestContext ctx = RequestContext.getCurrentContext();
InputStream compressedResponseDataStream = ctx.getResponseDataStream();
try {
    //Uncompress and transform the response
    InputStream responseDataStream = new GZIPInputStream(compressedResponseDataStream);
    String responseAsString = StreamUtils.copyToString(responseDataStream, Charset.forName("UTF-8"));
    //Do want you want with your String response
    ...
    //Replace the response with the modified object
    ctx.setResponseBody(responseAsString);
} catch (IOException e) {
    logger.warn("Error reading body", e);
}

Mann ich habe diesen Kommentar und verbrachte 6 Stunden drauf
Versuchen Sie nie, ein problem zu lösen, bevor die Suche, wenn das problem existiert in SO! 😉 Im ernst, bin froh, dass es geholfen hat!

InformationsquelleAutor VincentS

Keiner der Antworten, die für mich gearbeitet.
1) Reihenfolge der filter muss niedriger sein, 1000 (senden response filter)

2) Code:

 private String getResponseData(RequestContext ctx) throws IOException {
    String responseData = null;

    final InputStream responseDataStream = ctx.getResponseDataStream();
    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    ByteArrayOutputStream copy = new ByteArrayOutputStream();
    int read = 0;
    byte[] buff = new byte[1024];
    while ((read = responseDataStream.read(buff)) != -1) {
        bos.write(buff, 0, read);
        copy.write(buff, 0, read);
    }
    InputStream isFromFirstData = new ByteArrayInputStream(bos.toByteArray());

    boolean responseGZipped = ctx.getResponseGZipped();
    try {
        InputStream zin = null;
        if (responseGZipped) {
            zin = new GZIPInputStream(isFromFirstData);
        } else {
            zin = responseDataStream;
        }
        responseData = CharStreams.toString(new InputStreamReader(zin, "UTF-8"));
        ctx.setResponseDataStream(new ByteArrayInputStream(copy.toByteArray()));

    } catch (IOException e) {
        logger.warn("Error reading body {}", e.getMessage());
    }

    return responseData;
}

InformationsquelleAutor Damian

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.