一、POST Filter

后置過濾器一般使用來轉換響應數據的格式，截取請求響應數據進行流量錄制等操作。

Zuul已定義的后置過濾器SendResponseFilter，將代理請求的響應寫入當前響應。

?

二、自定義后置過濾器

本文自定義后置過濾器用來截取響應體的快照文本發送到kafka存儲。

?

三、實現代碼

@Component @Slf4j public class PostFilter extends ZuulFilter {//按類型對過濾器進行分類。Zuul中的標準類型是"pre"用于預路由篩選，"route"用于路由到原點，"post"用于后路由篩選，"error"用于錯誤處理。//我們還支持靜態響應的"static"類型請參閱StaticResponseFilter。可以通過調用FilterProcessor.runFilters(type)//后置過濾器必須返回post@Overridepublic String filterType() {return FilterConstants.POST_TYPE;}//必須為過濾器定義filterOrder。如果優先級對篩選器不重要，則過濾器可能具有相同的過濾器順序//過濾器順序不需要是連續的@Overridepublic int filterOrder() {return FilterConstants.SEND_RESPONSE_FILTER_ORDER - 10;}//默認情況下，zuulfilter是靜態的；它們不攜帶狀態。這可以通過將isStaticFilter屬性重寫為false來重寫@Overridepublic boolean isStaticFilter() {return super.isStaticFilter();}//要禁用此篩選器的Archaius屬性的名稱。默認情況下，它是zuul.[classname].[filtertype].disable@Overridepublic String disablePropertyName() {return super.disablePropertyName();}//如果為true，則過濾器已被archaius禁用，不會運行@Overridepublic boolean isFilterDisabled() {return super.isFilterDisabled();}//此方法返回的"true"表示應該調用run方法//如果應該調用run方法，則返回true。false不會調用run方法@Overridepublic boolean shouldFilter() {RequestContext context = RequestContext.getCurrentContext();return context.getThrowable() == null&& (!context.getZuulResponseHeaders().isEmpty()|| context.getResponseDataStream() != null|| context.getResponseBody() != null);}//如果shouldFilter方法為true，則將調用此方法。這種方法是ZuulFilter的核心方法//返回一些可以返回的任意工件。當前的實現忽略了它。//如果在執行期間發生錯誤，則引發ZuulException@Overridepublic Object run() throws ZuulException {RequestContext context = RequestContext.getCurrentContext();InputStream in = null;try {String responseBody = context.getResponseBody();if (responseBody == null) {in = context.getResponseDataStream();ByteArrayOutputStream output = new ByteArrayOutputStream();IOUtils.copy(in, output);byte[] bodyBytes = output.toByteArray();//回填已讀的流context.setResponseDataStream(new ByteArrayInputStream(bodyBytes));in = new ByteArrayInputStream(bodyBytes);if (context.getResponseGZipped()) {in = new GZIPInputStream(in);}HttpServletResponse servletResponse = context.getResponse();String endcoding = servletResponse.getCharacterEncoding();if (endcoding == null) {endcoding = "UTF-8";}responseBody = StreamUtils.copyToString(in, Charset.forName(endcoding));}//存儲響應數據KafkaUtils.sendResponseDataAsync(context.getRequest().getRequestURI(), responseBody);} catch (Exception e) {log.error("post filter error",e);}finally {if(in!= null){try {in.close();} catch (IOException e) {log.warn("post filter close io error",e);}}}return null;}}

?

總結

以上是生活随笔為你收集整理的SpringCloud Zuul（七）之POST Filter的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。