组件启动顺序_SpringCloud微服务：Zuul组件，实现路由网关控制

阅读本文前&＃xff0c;你可能需要了解以下内容&＃xff0c;如果熟悉的话&＃xff0c;直接略过。

SpringCloud微服务&＃xff1a;Eureka组件之服务注册与发现

SpringCloud微服务&＃xff1a;Ribbon和Feign组件&＃xff0c;实现服务调用的负载均衡

SpringCloud微服务&＃xff1a;Hystrix组件&＃xff0c;实现服务熔断

SpringCloud微服务&＃xff1a;Turbine组件&＃xff0c;实现微服务集群监控

1、基础概念

Zuul 网关主要提供动态路由&＃xff0c;监控&＃xff0c;弹性&＃xff0c;安全管控等功能。在分布式的微服务系统中&＃xff0c;系统被拆为了多个微服务模块&＃xff0c;通过zuul网关对用户的请求进行路由&＃xff0c;转发到具体的后微服务模块中。

2、Zuul的作用

1)按照不同策略&＃xff0c;将请求转发到不同的服务上去&＃xff1b;2)聚合API接口&＃xff0c;统一对外暴露&＃xff0c;提高系统的安全性&＃xff1b;3)实现请求统一的过滤&＃xff0c;以及服务的熔断降级&＃xff1b;

3、案例结构

启动顺序如下&＃xff1a;

# 注册中心node05-eureka-7001# 两个服务提供者node05-provider-6001node05-provider-6002# 网关控制node05-zuul-7002

启动成功后&＃xff0c;注册中心展示如下&＃xff1a;

1、核心依赖

org.springframework.cloud spring-cloud-starter-zuul

2、核心配置文件

server: port: 7002spring: application: name: cloud-node05-parenteureka: instance: prefer-ip-address: true client: service-url: defaultZone: http://registry01.com:7001/eureka/zuul: # 前缀&＃xff0c;可以用来做版本控制 prefix: /v1 # 禁用默认路由&＃xff0c;执行配置的路由 ignored-services: "*" routes: # 配置6001接口微服务 pro6001: serviceId: node05-provider-6001 path: /api-6001/** # 配置6002接口微服务 pro6002: serviceId: node05-provider-6002 path: /api-6002/**

• 启动类注解&＃xff1a;&＃64;EnableZuulProxy

3、统一服务降级

实现FallbackProvider接口&＃xff0c;自定义响应提示。

&＃64;Componentpublic class FallBackConfig implements FallbackProvider { private static final Logger LOGGER &＃61; LoggerFactory.getLogger(FallBackConfig.class) ; &＃64;Override public ClientHttpResponse fallbackResponse(Throwable cause) { // 捕获超时异常&＃xff0c;返回自定义信息 if (cause instanceof HystrixTimeoutException) { return response(HttpStatus.GATEWAY_TIMEOUT); } else { return fallbackResponse(); } } private ClientHttpResponse response(final HttpStatus status) { return new ClientHttpResponse() { &＃64;Override public HttpStatus getStatusCode() { return status; } &＃64;Override public int getRawStatusCode() { return status.value(); } &＃64;Override public String getStatusText() { return status.getReasonPhrase(); } &＃64;Override public void close() { LOGGER.info("close"); } &＃64;Override public InputStream getBody() { String message &＃61; "{" &＃43; ""code": 200," &＃43; ""message": "微服务飞出了地球"" &＃43; "}"; return new ByteArrayInputStream(message.getBytes()); } &＃64;Override public HttpHeaders getHeaders() { HttpHeaders headers &＃61; new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); return headers; } }; } &＃64;Override public String getRoute() { return "*"; } &＃64;Override public ClientHttpResponse fallbackResponse() { return response(HttpStatus.INTERNAL_SERVER_ERROR); }}

4、统一过滤器

继承ZuulFilter类&＃xff0c;自定义过滤动作。

&＃64;Componentpublic class FilterConfig extends ZuulFilter { private static final Logger LOGGER &＃61; LoggerFactory.getLogger(FilterConfig.class) ; &＃64;Override public String filterType() { return "pre"; } &＃64;Override public int filterOrder() { return 0; } &＃64;Override public boolean shouldFilter() { return true; } &＃64;Override public Object run() { RequestContext requestContext &＃61; RequestContext.getCurrentContext() ; try { doBizProcess(requestContext); } catch (Exception e){ LOGGER.info("异常&＃xff1a;{}