# Zuul Filter
又是我，今天乾脆就寫一寫好了，Zuul 到底能不能攔截 post 來測試看看大牛寫的
這篇寫得很好
https://blog.csdn.net/q1009020096/article/details/86313601


  @Override
    public Object run() {
    	//sendRequest();
	
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
      
        System.out.println(request.getMethod());
        System.out.println( request.getRequestURL().toString());
        System.out.println( request.getHeader("Authorization"));
        System.out.println(request.getParameter("test"));
        HttpServletRequestWrapper httpServletRequestWrapper = (HttpServletRequestWrapper) request;
       String token2 = httpServletRequestWrapper.getRequest().getParameter("test");
      
        String token = request.getParameter("token");// 获取请求的参数
//        try {
//			System.out.println(sendGet(token));
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
        try {
			if (sendGet(token)) {
			    ctx.setSendZuulResponse(true); //对请求进行路由
			    ctx.setResponseStatusCode(200);
			    ctx.set("isSuccess", true);
			    return null;
			} else {
			    ctx.setSendZuulResponse(false); //不对其进行路由
			    ctx.setResponseStatusCode(400);
			    ctx.setResponseBody("token is empty");
			    ctx.set("isSuccess", false);
			    return null;
			}
		} catch (ClientProtocolException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
        return null;
    }

這樣就可以來區分到底要在Zuul 邏輯和 要在 service 寫邏輯的問題了。

那麼帳號密碼的流程也很簡單
既然我們可以在 filter 攔截到 post 帳號密碼那麼就簡單一點了

public class TokenFilter extends ZuulFilter {
	private final static CloseableHttpClient httpClient = HttpClients.createDefault();
    

    @Override
    public String filterType() {
        return "pre"; // 可以在请求被路由之前调用
    }

    @Override
    public int filterOrder() {
        return 0; // filter执行顺序，通过数字指定 ,优先级为0，数字越大，优先级越低
    }

    @Override
    public boolean shouldFilter() {
        return true;// 是否执行该过滤器，此处为true，说明需要过滤
    }

    @Override
    public Object run() {
    	//sendRequest();
	
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
      
        System.out.println(request.getMethod());
        System.out.println( request.getRequestURL().toString());
        System.out.println( request.getHeader("Authorization"));
        System.out.println(request.getParameter("test"));
        HttpServletRequestWrapper httpServletRequestWrapper = (HttpServletRequestWrapper) request;
        String username = httpServletRequestWrapper.getRequest().getParameter("username");
        String password = httpServletRequestWrapper.getRequest().getParameter("password");
      
        String token = request.getParameter("token");// 获取请求的参数
//        try {
//			System.out.println(sendGet(token));
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
        
        if(StringUtils.isNotBlank(username)&& StringUtils.isNotBlank(password) && request.getRequestURL().toString().indexOf("login") >0)
        {
        	try {
				if(sendRequest(username,password))
				{
				    ctx.setSendZuulResponse(true); //对请求进行路由
				    ctx.setResponseStatusCode(200);
					ctx.setResponseBody("123");
				    ctx.set("isSuccess", true);
				 
				    return null;
				}
				else
				{
					ctx.setSendZuulResponse(false); //不对其进行路由
					ctx.setResponseStatusCode(400);
					ctx.setResponseBody("驗證帳號密碼成失敗");
					ctx.set("isSuccess", false);
					
					 return null;
				}
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
        }else {
        	
        try {
			if (sendGet(token)) {
			    ctx.setSendZuulResponse(true); //对请求进行路由
			    ctx.setResponseStatusCode(200);
			    ctx.set("isSuccess", true);
			    return null;
			} else {
			    ctx.setSendZuulResponse(false); //不对其进行路由
			    ctx.setResponseStatusCode(400);
			    ctx.setResponseBody("token is empty");
			    ctx.set("isSuccess", false);
			    return null;
			}
		} catch (ClientProtocolException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
        }
        return null;
    }

	 // one instance, reuse
    

    private static boolean sendRequest(String username,String password) throws Exception{
    	  HttpPost post = new HttpPost("http://192.168.0.146:8080/login");

          // add request parameter, form parameters
          List<NameValuePair> urlParameters = new ArrayList<>();
          urlParameters.add(new BasicNameValuePair("username", username));
          urlParameters.add(new BasicNameValuePair("password", password));
          //urlParameters.add(new BasicNameValuePair("custom", "secret"));

          post.setEntity(new UrlEncodedFormEntity(urlParameters));

          try (CloseableHttpClient httpClient = HttpClients.createDefault();
               CloseableHttpResponse response = httpClient.execute(post)) {
        	  String result = EntityUtils.toString(response.getEntity());
              System.out.println();
              httpClient.close();
              response.close();
              return readjson(result);
          }
    }
    private static  boolean sendGet(String token) throws ClientProtocolException, IOException  {

    	  HttpGet request = new HttpGet("http://192.168.0.146:8080/user");

          // add request headers
          request.addHeader("Authorization",token);
        //  request.addHeader(HttpHeaders.USER_AGENT, "Googlebot");

          try (CloseableHttpResponse response = httpClient.execute(request)) {

              // Get HttpResponse Status
              //System.out.println(response.getStatusLine().toString());

              HttpEntity entity = response.getEntity();
              Header headers = entity.getContentType();
             // System.out.println(headers);

              if (entity != null) {
                  // return it as a String
                  String result = EntityUtils.toString(entity);
                
                  System.out.println(result);
                  //readjson(result);
                  response.close();
                  
                return readjson(result);
                  //readjson(result);
              }

          }
          return false;
    }
    public static boolean readjson (String tmp)
    {     
    	
        //原数据
        String data=tmp;
        //创建一个ObjectMapper对象
        ObjectMapper objectMapper=new ObjectMapper();
        //读取json数据,返回一个JsonNode对象指向根节点
        try {
            JsonNode jsonNode=objectMapper.readTree(data);
            //利用JsonNode的path方法获取子节点,path方法的返回值也是JsonNode
            //JsonNode subNode=jsonNode.path("details");//得到details节点
            //JsonNode对象的asInt(),asText()等方法用于获取值
            
            System.out.println(jsonNode.path("status").asText());//返回字符串,韩超
            System.out.println(jsonNode.path("msg").asText());//返回整形数据,18
            System.out.println(jsonNode.path("data").asText());//返回长整型数据,1507030123
            if(jsonNode.path("status").asText().equals("200")==true)
            	return true;
//            //对于数组,可以使用size方法获取数组长度,get(index)获取索取为index的值
//            for(int i=0;i<jsonNode.path("hobbies").size();i++)
//                System.out.println(jsonNode.path("hobbies").get(i).asText());//输出hobbies对应的数组
//            
//            //获取details.birthday
//            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd-HH-mm");  
//            sdf.setTimeZone(TimeZone.getTimeZone("GMT+8"));
//            System.out.println(sdf.format(new Date(subNode.path("birthday").asLong()*1000)));
//            
//            for(int i=0;i<subNode.path("extar").size();i++)
//                System.out.println(subNode.path("extar").get(i).asText());//输出details.extar对应的数组
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }   
        return false;
        }
    	
    
}

不負責任埋坑
比較關鍵的點就是

if(StringUtils.isNotBlank(username)&& StringUtils.isNotBlank(password) && request.getRequestURL().toString().indexOf("login") >0)

你路由規則 我還沒看 Zuul 應該是攔截不到除非你真的有這個服務，要不然就要寫成註冊中心了，那就會變成微服務版
這裡主要就是看我們的路由規則
我們幾乎是攔下所有的eureka-provider
裡面的路徑，因為我們每一個服務要進行註冊，
怎麼換掉呢?
更改 驗證中心 post 那個路徑這個應該也沒什麼用 因為我們主要請求是先經過 Zuul，目前想不到 先用路徑判斷吧哈哈 實戰應該不能這樣用。

# 運行
登入成功
當然你也可以直接返回token
Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJleHAiOjE1Nzc1NTAxMTIsInVzZXJuYW1lIjoiamFjayJ9.WMYt2CPXuXtpem9Tb6VLG6l6IPd-Osfb73d3i-GaMAc
登入失敗

攜帶token 請求
攜帶錯誤token 請求

最後又再亂測試
我們的認證中心是獨立服務要測試也只能這樣測試了

我買的ai 開發版記憶體只有 4g xd，這也考慮到很多因素像數據機傳輸速度也有關係，我相信這種業界應該不是用這種方法應該是走 rpc 或者 驗證邏輯不使用框架也說不定 ，不過考慮分布式的話，這又關連到 分布式鎖的問題了。