SpringCloud极简入门-服务网关-spring cloud zuul

/*** 用户的启动类* @EnableEurekaClient： 标记该应用是 Eureka客户端* @EnableZuulProxy ： 开启zuul 可以看做是 @EnableZuulServer 的增强版 ，一般用这个* @EnableZuulServer : 这个标签也可以开启zuul，但是这个标签开启的Filter更少*/@SpringBootApplication@EnableEurekaClient@EnableZuulProxypublicclassZuulServerApplication1060{
publicstaticvoidmain( String[] args )
    {
SpringApplication.run(ZuulServerApplication1060.class);
    }
}

publicabstractclassZuulFilterimplementsIZuulFilter{
abstractpublicStringfilterType();
abstractpublicintfilterOrder();
//下面两个方法是 IZuulFilter 提供的 booleanshouldFilter();
Objectrun() throwsZuulException;
}

packagecn.itsource.springboot.filter;
importcom.alibaba.fastjson.JSON;
importcom.netflix.zuul.ZuulFilter;
importcom.netflix.zuul.context.RequestContext;
importcom.netflix.zuul.exception.ZuulException;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
importorg.springframework.stereotype.Component;
importorg.springframework.util.StringUtils;
importjavax.servlet.http.HttpServletRequest;
importjavax.servlet.http.HttpServletResponse;
importjava.io.IOException;
importjava.util.HashMap;
importjava.util.Map;
@ComponentpublicclassLoginCheckFilterextendsZuulFilter {
privatestaticfinalLoggerlog=LoggerFactory.getLogger(LoginCheckFilter.class);
//执行顺序privatestaticfinalintORDER=1;
//filter类型 : "pre"前置@OverridepublicStringfilterType() {
returnFilterConstants.PRE_TYPE;    //pre    }
//执行顺序@OverridepublicintfilterOrder() {
returnORDER;
    }
//返回结果决定 是否要执行run方法@OverridepublicbooleanshouldFilter() {
// /static/**  ，/login , /register 不需要做登录检查，返回false//1.获取request对象 ， 获取请求中的urlHttpServletRequestrequest=RequestContext.getCurrentContext().getRequest();
Stringurl=request.getRequestURI();
log.info("请求地址："+url);
//2.判断是否包含在： static/**  ，/login , /registerif(url.endsWith("/login ") ||url.endsWith("/register ") ||url.contains("/static/") ){
returnfalse;
        }
//要做登录检查的返回truereturntrue;
    }
//核心业务方法 ： 登录检查 ， 如果请求头中有token，就是登录成功@OverridepublicObjectrun() {
//1.获取请求对象HttpServletRequestrequest=RequestContext.getCurrentContext().getRequest();
//响应对象HttpServletResponseresponse=RequestContext.getCurrentContext().getResponse();
//2.获取请求头中的 tokenStringtoken=request.getHeader("token");
//3.如果没有token，登录检查失败 ，if(!StringUtils.hasLength(token)){
//3.1.返回登录检查失败的错误信息 :{ success:false, message:"登录检查失败，请重新登录"}Map<String,Object>resultMap=newHashMap<>();
resultMap.put("success" , false);
resultMap.put("message" , "登录检查失败，请重新登录");
//中文编码response.setContentType("application/json;charset=utf-8");
//把map转成json字符串，写到浏览器StringresultJsonString=JSON.toJSONString(resultMap);
response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
try {
response.getWriter().print(resultJsonString);
            } catch (IOExceptione) {
e.printStackTrace();
            }
//3.2.阻止filter继续往后执行RequestContext.getCurrentContext().setSendZuulResponse(false);
        }
//这里的返回结果没有任何意义，不用管returnnull;
    }
}

publicinterfaceFallbackProvider {
/*** The route this fallback will be used for.* @return The route the fallback will be used for.*/publicStringgetRoute();
/*** Provides a fallback response based on the cause of the failed execution.** @param route The route the fallback is for* @param cause cause of the main method failure, may be <code>null</code>* @return the fallback response*/ClientHttpResponsefallbackResponse(Stringroute, Throwablecause);
}

importjava.io.ByteArrayInputStream;
importjava.io.IOException;
importjava.io.InputStream;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
importorg.springframework.http.HttpHeaders;
importorg.springframework.http.HttpStatus;
importorg.springframework.http.MediaType;
importorg.springframework.http.client.ClientHttpResponse;
importorg.springframework.stereotype.Component;
@ComponentpublicclassPayServerFallbackimplementsFallbackProvider {
privatefinalLoggerlogger=LoggerFactory.getLogger(FallbackProvider.class);
// 指定要处理的服务。@OverridepublicStringgetRoute() {
return"pay-server";  //"*"代表所有服务都有作用    }
/*** @param route :服务的路由* @param cause ： 异常* @return ClientHttpResponse：熔断后的换回值*/@OverridepublicClientHttpResponsefallbackResponse(Stringroute, Throwablecause) {
returnnewClientHttpResponse() {
@OverridepublicHttpStatusgetStatusCode() throwsIOException {
returnHttpStatus.OK;
            }
@OverridepublicintgetRawStatusCode() throwsIOException {
return200;
            }
@OverridepublicStringgetStatusText() throwsIOException {
return"OK";
            }
@Overridepublicvoidclose() {
            }
@OverridepublicInputStreamgetBody() throwsIOException {
returnnewByteArrayInputStream("抱歉，服务不可用".getBytes());
            }
@OverridepublicHttpHeadersgetHeaders() {
HttpHeadersheaders=newHttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
returnheaders;
            }
        };
    }
}