通过zuul进行服务过滤

Author: enjoyCoding666

zuul/src/main/java/com/example/demo/ZuulApplication.java

@@ -1,14 +1,21 @@
 package com.example.demo;
 
+import com.example.demo.filter.AccessFilter;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.SpringCloudApplication;
 import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
+import org.springframework.context.annotation.Bean;
 
 @EnableZuulProxy
 @SpringCloudApplication
 public class ZuulApplication {
 
+    @Bean
+    public AccessFilter  accessFilter() {
+        return new AccessFilter();
+    }
+
     public static void main(String[] args) {
         SpringApplication.run(ZuulApplication.class, args);
     }

zuul/src/main/java/com/example/demo/filter/AccessFilter.java

@@ -0,0 +1,51 @@
+package com.example.demo.filter;
+
+import com.netflix.zuul.ZuulFilter;
+import com.netflix.zuul.context.RequestContext;
+import org.apache.log4j.Logger;
+
+
+import javax.servlet.http.HttpServletRequest;
+
+
+public class AccessFilter extends ZuulFilter {
+    private static Logger log=Logger.getLogger(AccessFilter.class);
+
+    @Override
+    public String filterType() {
+        return "pre";
+    }
+
+    @Override
+    public int filterOrder() {
+        return 0;
+    }
+
+
+    @Override
+    public boolean shouldFilter() {
+        return true;
+    }
+
+    /**
+     * 设置过滤。url只有带有有效参数才可以访问。
+     * @return
+     */
+    @Override
+    public Object run() {
+        RequestContext ctx = RequestContext.getCurrentContext();
+        HttpServletRequest request = ctx.getRequest();
+
+        log.info(String.format("%s request to %s", request.getMethod(), request.getRequestURL().toString()));
+
+        Object accessToken = request.getParameter("accessToken");
+        if(accessToken == null) {
+            log.warn("access token is empty");
+            ctx.setSendZuulResponse(false);
+            ctx.setResponseStatusCode(401);
+            return null;
+        }
+        log.info("access token ok");
+        return null;
+    }
+}