zuul网关_一、Zuul网关

org.springframework.cloudspring-cloud-starter-netflix-zuul

&＃64;EnableDiscoveryClient&＃64;EnableZuulProxy
&＃64;SpringBootApplicationpublic class QfSpringCloudNetflixZuulApplication {public static void main(String[] args) {SpringApplication.run(QfSpringCloudNetflixZuulApplication.class, args);}}

1&＃xff09;全局路径的设置


1&＃xff09;局部路径的设置


ignored-patterns: /**/admin/**

zuul:routes:api-a:path: /api/a/**serviceId: hello-spring-cloud-web-admin-ribbon# stripPrefix: false
# 是可以携带COOKIE&＃xff0c;如果不加的话&＃xff0c;那COOKIE携带不过来
sensitiveHeaders:

&＃64;Componentpublic class MyGatewayFallback implements FallbackProvider {/*设置要对哪些服务进行错误回调&＃xff0c;return 具体的服务名称&＃xff0c;也可以return "*" 获得return null &＃61;&＃61;>对所有服务进行错误回调*/
&＃64;Overridepublic String getRoute() {return "hello-spring-cloud-web-admin-ribbon";}/*具体的回调内容*/
&＃64;Overridepublic ClientHttpResponse fallbackResponse(String route, Throwable cause) {return new ClientHttpResponse() {/*返回一个状态码*/
&＃64;Overridepublic HttpStatus getStatusCode() throws IOException {return HttpStatus.OK;}&＃64;Overridepublic int getRawStatusCode() throws IOException {return HttpStatus.OK.value();}&＃64;Overridepublic String getStatusText() throws IOException {return HttpStatus.OK.getReasonPhrase();}&＃64;Overridepublic void close() {}&＃64;Overridepublic InputStream getBody() throws IOException {ObjectMapper objectMapper &＃61; new ObjectMapper();Map map &＃61; new HashMap();map.put("status",200);map.put("message","无法连接&＃xff0c;请检查您的网络");return new ByteArrayInputStream(objectMapper.writeValueAsBytes(map));}&＃64;Overridepublic HttpHeaders getHeaders() {HttpHeaders headers &＃61; new HttpHeaders();// 和 getBody 中的内容编码一致
headers.setContentType(MediaType.APPLICATION_JSON_UTF8);return headers;}};}
}

&＃64;Componentpublic class MyZuulFilter extends ZuulFilter {/*配置过滤器类型&＃xff0c;根据生命周期的不同&＃xff0c;有四种类型1.pre: 路由之前2.routing: 路由之时3.post: 路由之后4.error: 在上面三者执行过程中出现了异常就会调用该error过滤器*/
&＃64;Overridepublic String filterType() {return "pre";}//相同过滤器类型之间确定执行的顺序&＃xff0c;0就表示第一个执行。
&＃64;Overridepublic int filterOrder() {return 0;}/*配置是否需要过滤&＃xff1a;true 需要 false 不需要*/
&＃64;Overridepublic boolean shouldFilter() {return true;}/*** 过滤器要执行过滤的具体的内容* 如果这一次请求&＃xff0c;没有携带COOKIE&＃xff0c;那么就不进行路由。* &＃64;return
* &＃64;throws ZuulException*/
&＃64;Overridepublic Object run() throws ZuulException {//得到request的当前的上下文对象
RequestContext ctx &＃61; RequestContext.getCurrentContext();//得到request对象
HttpServletRequest request &＃61; ctx.getRequest();COOKIE[] COOKIEs &＃61; request.getCOOKIEs();if(COOKIEs&＃61;&＃61;null||COOKIEs.length&＃61;&＃61;0){//不进行路由
ctx.setSendZuulResponse(false);//设置返回状态码
ctx.setResponseStatusCode(401);//设置返回体
ctx.setResponseBody("no permission");//设置自定义键值对
ctx.set("isSuccess",false);}else{//进行路由
ctx.setSendZuulResponse(true);ctx.setResponseStatusCode(200);ctx.set("isSuccess",true);}return null;}
}