實現過濾器很簡單，只需要繼承ZuulFilter,并實現ZuulFilter中的抽象方法。

filterType()：定義過濾器的類型，它有4種類型，分別是pre、post、routing和error

filterOrder()：過濾順序，它是一個Int類型的值，值越小，越早執行該過濾器

shouldFilter()：表示該過濾器是否過濾邏輯，如果為true，則執行run方法，如果為false，則不執行run方法

Object run()：寫具體的過濾邏輯

注意重要說明,有些版本在轉發post時,文件上傳無法轉法。只要升級下版本就可以了。

本示中使用的是 springcloud? ? Edgware.RELEASE 對應springboot1.5.9

Spring Boot

Spring Cloud

1.2.x

Angel版本

1.3.x

Brixton版本

1.4.xstripes

Camden版本

1.5.x

Dalston版本、Edgware版本

2.0.x

Finchley版本

2.1.x

Greenwich.SR2

示例

1.pom中引用

4.0.0

com.company

zuuldemo

0.0.1-SNAPSHOT

jar

zuuldemo

http://maven.apache.org

UTF-8

1.8

1.8

org.springframework.cloud

spring-cloud-starter-parent

Edgware.RELEASE

org.springframework.boot

spring-boot-starter-web

org.springframework.cloud

spring-cloud-starter-zuul

commons-codec

commons-codec

org.apache.httpcomponents

httpclient

junit

junit

test

com.google.guava

guava

com.alibaba

fastjson

1.2.58

2.springcloud項目

2.1 src/main/resources/application.yml

server:

port: 80

spring:

application:

name: api-geteway

http:

multipart:

enabled: true # 使用http multipart上傳處理

file-size-threshold: 1MB # 當上傳文件達到1MB的時候進行磁盤寫入

max-request-size: 10MB # 設置最大的請求文件的大小

max-file-size: 10MB # 設置單個文件的最大長度

zuul:

routes:

weixin:

path: /mypath/**

url: https://www.baidu.com

2.2 App.java

packagecom.company.zuuldemo;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.zuul.EnableZuulProxy;importorg.springframework.context.annotation.Bean;importcom.company.zuuldemo.filter.MyFilter;/*** Hello world!

**/@EnableZuulProxy

@SpringBootApplicationpublic classZuulApp {//使用filter

@BeanpublicMyFilter myFilter() {return newMyFilter();

}//@Bean//public FirstFilter firstFilter() {//return new FirstFilter();//}//

//@Bean//public SecondFilter secondFilter() {//return new SecondFilter();//}

public static voidmain(String[] args) {//System.out.println( "Hello World!" );

SpringApplication.run(ZuulApp.class);

}

}

2.3 MyFilter.java

packagecom.company.zuuldemo.filter;importjava.util.Arrays;importjava.util.Date;importjava.util.HashMap;importjava.util.List;importjava.util.Map;importorg.slf4j.Logger;importorg.slf4j.LoggerFactory;importcom.netflix.zuul.ZuulFilter;importcom.netflix.zuul.context.RequestContext;public class MyFilter extendsZuulFilter {final static Logger logger = LoggerFactory.getLogger(FirstFilter.class);//這里可以依據url規則判斷是否需要進行過濾 true需要過濾進入run方法 ,false直接忽略

public booleanshouldFilter() {

RequestContext ctx=RequestContext.getCurrentContext();

logger.info(ctx.getRequest().getRequestURI()+ " get request path info");

String url=ctx.getRequest().getRequestURI().toLowerCase();//這里判斷url邏輯

if (url.startsWith("/login")) {return false;

}return true;

}publicObject run() {

RequestContext ctx=RequestContext.getCurrentContext();//通過其它業務生成token

String access_token = "user_name_token";//使用1 ：向request的header中增加參數access_token

ctx.addZuulRequestHeader("access_token", access_token);//使用2：向request的url里增加參數,示例增加 access_token

Map> requestQueryParams =ctx.getRequestQueryParams();if (requestQueryParams == null) {

requestQueryParams= new HashMap<>();

}

requestQueryParams.put("access_token", Arrays.asList(access_token));

ctx.setRequestQueryParams(requestQueryParams);//使用3 ：:判斷是否登錄,如果未登錄直接返回404

if (access_token == null || access_token.trim().length() == 0) {//過濾該請求，不對其進行路由(直接輸入返回)

ctx.setSendZuulResponse(false);//返回錯誤碼

ctx.setResponseStatusCode(401);//返回錯誤內容

ctx.setResponseBody("{\"result\":\"access_token is not correct!\"}");//讓下一個Filter看到上一個Filter的狀態用于過濾器間的協調

ctx.set("my_filter_is_success", false);return null;

}//對該請求進行路由(默認就是true)//ctx.setSendZuulResponse(true);//ctx.setResponseStatusCode(200);//讓下一個Filter看到上一個Filter的狀態用于過濾器間的協調

ctx.set("my_filter_is_success", false);return null; //直接返回null即可

}

@OverridepublicString filterType() {//前置過濾器//pre：可以在請求被路由之前調用//route：在路由請求時候被調用//post：在route和error過濾器之后被調用//error：處理請求時發生錯誤時被調用

return "pre";

}

@Overridepublic intfilterOrder() {//優先級為0，數字越大，優先級越低

return 0;

}

}

總結

以上是生活随笔為你收集整理的zuulfilter添加例外_SpringCloud之Zuul 自定义filter的全部內容，希望文章能夠幫你解決所遇到的問題。

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