我正在使用 Zuul post filter 來攔截響應(yīng)。我的要求是向響應(yīng) json 添加一個新字段。我能夠攔截響應(yīng)并對其進行編輯。但是，無法將更新后的響應(yīng)設(shè)置為 RequestContext。在后過濾器中使用 Zuul 作為代理時，如何讀取響應(yīng)主體、編輯并將其更新回 RequestContext？請找到我正在使用的以下代碼。private void updateResponseBody(RequestContext ctx) throws IOException, JSONException { final InputStream responseDataStream = ctx.getResponseDataStream(); String responseData = CharStreams.toString(new InputStreamReader(responseDataStream, "UTF-8")); JSONObject jsonObj = new JSONObject(responseData); JSONArray groupsArray = jsonObj.getJSONArray("list"); for (int i = 0; i < groupsArray.length(); i++) { JSONObject groupId = groupsArray.getJSONObject(i); groupId.accumulate("new_json_field_name", "new_json_field_value"); } String updatedResponse = jsonObj.toString(); // ctx.setResponseBody(body); // also not working ctx.setResponseDataStream(org.apache.commons.io.IOUtils.toInputStream(updatedResponse, "UTF-8"));}我得到的錯誤是：Error while sending response to client: java.io.IOException: An existing connection was forcibly closed by the remote host.誰能幫我解決這個問題。
2 回答
藍山帝景
TA貢獻1843條經(jīng)驗 獲得超7個贊
我遇到了同樣的錯誤，瘋狂地修改了How to get response body in Zuul post filter? 中描述的代碼。嘗試不同的可能性。最后，我在這篇文章中找到了解決方案，方法是在OutputStreamfromservletResponse.getOutputStream()而不是 中寫下答案ctx.setResponseDataStream()：
HttpServletResponse servletResponse = ctx.getResponse();
...
String updatedResponse = jsonObj.toString();
try {
OutputStream outStream = servletResponse.getOutputStream();
outStream.write(updatedResponse.getBytes(), 0, updatedResponse.length());
outStream.flush();
outStream.close();
} catch (IOException e) {
log.warn("Error reading body", e);
}
泛舟湖上清波郎朗
TA貢獻1818條經(jīng)驗 獲得超3個贊
我有一個類似的任務(wù)，并試圖通過寫入 OutputStream 來完成。這有效，但有一個奇怪的副作用，它使響應(yīng)中的 HttpHeaders 被刪除或損壞。這使得調(diào)用在生產(chǎn)中產(chǎn)生 CORS 錯誤，即使它通過 Postman 在本地運行良好。
我編寫了以下方法，我從我的 Post Zuul 過濾器的 run() 方法調(diào)用該方法以將單個節(jié)點/值添加到返回的 Json。
private void addJsonNode(RequestContext requestContext,String name, String id) {
HttpServletResponse servletResponse = requestContext.getResponse();
try {
final InputStream responseDataStream = requestContext.getResponseDataStream();
String responseData = CharStreams.toString(new InputStreamReader(responseDataStream, "UTF-8"));
JSONObject jsonObject = new JSONObject(responseData);
jsonObject.put(name, id);
String updatedResponse = jsonObject.toString(4);
requestContext.setResponseBody(updatedResponse);
} catch (IOException e) {
log.warn("Error reading body", e);
} catch (JSONException e) {
log.warn("Error reading body", e);
}
}
添加回答
舉報
0/150
提交
取消