SpringCloud系列之API網(wǎng)關(guān)(Gateway)服務(wù)Zuul

<dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-zuul</artifactId>        </dependency>

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
@SpringBootApplication@EnableZuulProxypublic class SpringcloudZuulApplication {
    public static void main(String[] args) {        SpringApplication.run(SpringcloudZuulApplication.class, args);    }}

server:  port: 8082# 指定application name，這個(gè)是微服務(wù)注冊(cè)的serviceIdspring:  application:    name: zuul-api-gateway
eureka:  client:    # 服務(wù)注冊(cè)中心url    service-url:      defaultZone: http://localhost:8761/eureka/     # 網(wǎng)關(guān)服務(wù)注冊(cè)、發(fā)現(xiàn)都開放，所以 register-with-eureka、fetch-registry都是true    register-with-eureka: true    fetch-registry: true  instance:    status-page-url-path: http://localhost:8761/actuator/info    health-check-url-path: http://localhost:8761/actuator/health    prefer-ip-address: true    instance-id: zuul-api-gateway8082

zuul:  routes:    provider: # 路由標(biāo)識(shí)，可以自己定義      service-id: eureka-service-provider # 服務(wù)id(必須配置)      path: /provider/** # 映射的路徑，一般和routes.provider一致      url: http://localhost:8083 # 路由到的url，可以不配置

zuul:  # 配置前綴  prefix: /api-gateway

zuul: # 配置過(guò)濾敏感的請(qǐng)求頭信息，設(shè)置為空就不會(huì)過(guò)濾  sensitive-headers: Cookie,Set-Cookie,Authorization

zuul:# 重定向會(huì)添加host請(qǐng)求頭  add-proxy-headers: true

zuul:  host:    # 配置連接超時(shí)時(shí)間    connect-timeout-millis: 15000    # socker發(fā)送超時(shí)時(shí)間    socket-timeout-millis: 60000

zuul:  # 配置前綴  prefix: /api-gateway  routes:    provider: # 路由標(biāo)識(shí)，可以自己定義      service-id: eureka-service-provider # 服務(wù)id      path: /provider/** # 映射的路徑，一般和routes.provider一致      url: http://localhost:8083 # 路由到的url  host:    # 配置連接超時(shí)時(shí)間    connect-timeout-millis: 15000    # socker發(fā)送超時(shí)時(shí)間    socket-timeout-millis: 60000  # 請(qǐng)求url編碼  decode-url: true  # 查詢字符串編碼  force-original-query-string-encoding: false  # 配置過(guò)濾敏感的請(qǐng)求頭信息，設(shè)置為空就不會(huì)過(guò)濾  sensitive-headers: Cookie,Set-Cookie,Authorization  # 重定向會(huì)添加host請(qǐng)求頭  add-proxy-headers: true

zuul:  host:    connect-timeout-millis: 15000    socket-timeout-millis: 60000

package com.example.springcloud.zuul.web.filter;
import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import lombok.extern.slf4j.Slf4j;import org.apache.http.HttpHeaders;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;
import javax.servlet.http.HttpServletRequest;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.FORWARD_TO_KEY;import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.SERVICE_ID_KEY;
/** * <pre> *  API網(wǎng)關(guān)預(yù)過(guò)濾器 * </pre> * * <pre> * @author mazq * 修改記錄 *    修改后版本:     修改人：修改日期: 2020/08/05 18:08  修改內(nèi)容: * </pre> */@Slf4j//@Componentpublic class ZuulApiGatewayPreFilter extends ZuulFilter {
    @Override    public String filterType() {        return PRE_TYPE;    }
    @Override    public int filterOrder() {        return 0;    }
    @Override    public boolean shouldFilter() {        return true;    }
    @Override    public Object run() throws ZuulException {        RequestContext ctx = RequestContext.getCurrentContext();        HttpServletRequest request = ctx.getRequest();        String accessToken = request.getParameter("token");        if (StringUtils.isEmpty(accessToken)) {            // zuul過(guò)濾該請(qǐng)求，不進(jìn)行路由            ctx.setSendZuulResponse(false);            // 設(shè)置返回的錯(cuò)誤碼            ctx.setResponseStatusCode(403);            ctx.setResponseBody("AccessToken is Invalid ");            return null;        }        log.info("accessToken: {}",accessToken);        // 否則業(yè)務(wù)繼續(xù)執(zhí)行        return null;    }}

package com.example.springcloud.zuul.web.filter;
import com.google.common.io.CharStreams;import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import lombok.extern.slf4j.Slf4j;import org.apache.http.protocol.RequestContent;import org.springframework.stereotype.Component;
import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.POST_TYPE;import static org.springframework.http.HttpStatus.INTERNAL_SERVER_ERROR;
/** * <pre> *      API Gateway后置過(guò)濾器 * </pre> * * <pre> * @author mazq * 修改記錄 *    修改后版本:     修改人：修改日期: 2020/08/06 10:05  修改內(nèi)容: * </pre> */@Slf4j//@Componentpublic class ZuulApiGatewayPostFilter extends ZuulFilter {    @Override    public String filterType() {        return POST_TYPE;    }
    @Override    public int filterOrder() {        return 0;    }
    @Override    public boolean shouldFilter() {        return true;    }
    @Override    public Object run() throws ZuulException {        RequestContext context = RequestContext.getCurrentContext();        try (final InputStream responseDataStream = context.getResponseDataStream()) {            if(responseDataStream == null) {                log.warn("RESPONSE BODY: {}", "");                return null;            }            String responseData = CharStreams.toString(new InputStreamReader(responseDataStream, "UTF-8"));            log.info("RESPONSE BODY: {}", responseData);            context.setResponseBody(responseData);        }        catch (Exception e) {            throw new ZuulException(e, INTERNAL_SERVER_ERROR.value(), e.getMessage());        }        return null;    }}

package com.example.springcloud.zuul;
import com.example.springcloud.zuul.web.filter.ZuulApiGatewayErrFilter;import com.example.springcloud.zuul.web.filter.ZuulApiGatewayPostFilter;import com.example.springcloud.zuul.web.filter.ZuulApiGatewayPreFilter;import com.example.springcloud.zuul.web.filter.ZuulApiGatewayRouteFilter;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;import org.springframework.context.annotation.Bean;
@SpringBootApplication@EnableZuulProxypublic class SpringcloudZuulApplication {
    public static void main(String[] args) {        SpringApplication.run(SpringcloudZuulApplication.class, args);    }
    @Bean    public ZuulApiGatewayPreFilter zuulApiGatewayPreFilter(){        return new ZuulApiGatewayPreFilter();    }    @Bean    public ZuulApiGatewayPostFilter zuulApiGatewayPostFilter(){        return new ZuulApiGatewayPostFilter();    }    @Bean    public ZuulApiGatewayRouteFilter zuulApiGatewayRouteFilter(){        return new ZuulApiGatewayRouteFilter();    }    @Bean    public ZuulApiGatewayErrFilter zuulApiGatewayErrFilter(){        return new ZuulApiGatewayErrFilter();    }}

<dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-actuator</artifactId>        </dependency>

management:  endpoints:    web:      exposure:        # 默認(rèn)只支持info,health，開啟對(duì)routes的監(jiān)控        include: info,health,routes  # 開啟健康檢查詳細(xì)信息  endpoint:    health:      show-details: always

{    "/api-gateway/provider/**":"eureka-service-provider",    "/api-gateway/eureka-service-provider/**":"eureka-service-provider"}

{    "/api-gateway/provider/**":{        "id":"provider",        "fullPath":"/api-gateway/provider/**",        "location":"eureka-service-provider",        "path":"/**",        "prefix":"/api-gateway/provider",        "retryable":false,        "customSensitiveHeaders":false,        "prefixStripped":true    },    "/api-gateway/eureka-service-provider/**":{        "id":"eureka-service-provider",        "fullPath":"/api-gateway/eureka-service-provider/**",        "location":"eureka-service-provider",        "path":"/**",        "prefix":"/api-gateway/eureka-service-provider",        "retryable":false,        "customSensitiveHeaders":false,        "prefixStripped":true    }}