SpringCloud详细教程 | 第五篇：路由器和过滤器Zuul(Greenwich版本)

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

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <parent>        <groupId>com.li</groupId>        <artifactId>SpringCloudLearn</artifactId>        <version>1.0-SNAPSHOT</version>        <relativePath>../</relativePath>    </parent>    <artifactId>zuul-server</artifactId>    <version>0.0.1-SNAPSHOT</version>    <name>zuul-server</name>    <description>Demo project for Spring Boot</description>
    <properties>        <java.version>1.8</java.version>        <spring-cloud.version>Greenwich.SR1</spring-cloud.version>    </properties>
    <dependencies>        <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>    </dependencies>
    <dependencyManagement>        <dependencies>            <dependency>                <groupId>org.springframework.cloud</groupId>                <artifactId>spring-cloud-dependencies</artifactId>                <version>${spring-cloud.version}</version>                <type>pom</type>                <scope>import</scope>            </dependency>        </dependencies>    </dependencyManagement>
    <build>        <plugins>            <plugin>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-maven-plugin</artifactId>            </plugin>        </plugins>    </build>
</project>

package com.li.zuulserver;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.EnableEurekaClient;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
@EnableZuulProxy@EnableEurekaClient@SpringBootApplicationpublic class ZuulServerApplication {
    public static void main(String[] args) {        SpringApplication.run(ZuulServerApplication.class, args);    }
}

# 端口号server.port=8767# 需要指明spring.application.name 这个很重要# 这在以后的服务与服务之间相互调用一般都是根据这个namespring.application.name=zuul-server#服务注册中心实例的主机名eureka.instance.hostname=localhost#服务注册中心端口号eureka.port=8761#在此指定服务注册中心地址eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${eureka.port}/eureka/# 创建两个路由转发# ribbon转ribbon-server服务zuul.routes.ribbon.service-id=ribbon-serverzuul.routes.ribbon.path=/ribbon/**
# feign转feign-server服务zuul.routes.feign.service-id=feign-serverzuul.routes.feign.path=/feign/**

package com.li.zuulserver.filter;
import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.http.HttpStatus;import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;import java.io.IOException;
/** * @Classname MyFilter * @Description TODO * @Author 李号东 lihaodongmail@163.com * @Date 2019-03-31 08:20 * @Version 1.0 */
@Component // 注入beanpublic class RoutingFilter extends ZuulFilter {
    private static Logger log = LoggerFactory.getLogger(RoutingFilter.class);

    /**     * 过滤器的类型     * pre：可以在请求被路由之前调用。我们可利用这种过滤器实现身份验证、在集群中选择请求的微服务、记录调试信息等。     * roting：在路由请求时候被调用。这种过滤器用于构建发送给微服务的请求，并使用Apache HttpClient或Netfilx Ribbon请求微服务。     * post：在routing和error过滤器之后被调用。这种过滤器可用来为响应添加标准的HTTP Header、收集统计信息和指标、将响应从微服务发送给客户端等。     * error：处理请求时发生错误时被调用     *     * @return     */    @Override    public String filterType() {        return "pre";    }
    /**     * 过滤的顺序 越小越先很执行     *     * @return     */    @Override    public int filterOrder() {        return 0;    }
    /**     * 是否过滤 true 过滤 false 不执行过滤器     *     * @return     */    @Override    public boolean shouldFilter() {        return true;    }
    /**     * 过滤器的具体逻辑     *     * @return     * @throws ZuulException     */
    @Override    public Object run() throws ZuulException {        // 获取请求的上下文类 注意是：com.netflix.zuul.context包下的        RequestContext ctx = RequestContext.getCurrentContext();        //避免中文乱码        ctx.addZuulResponseHeader("Content-type", "text/json;charset=UTF-8");        ctx.getResponse().setCharacterEncoding("UTF-8");        //获取request对象        HttpServletRequest request = ctx.getRequest();        log.info("请求方式：{},地址：{}", request.getMethod(), request.getRequestURL().toString());        // 获取token参数        Object accessToken = request.getParameter("token");        if (accessToken == null) {            // 使其不进行转发 自定义route类型时，在shouldFilter中也需要进行此参数判断            ctx.setSendZuulResponse(false);            ctx.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());            try {                ctx.getResponse().getWriter().write("非法访问");            } catch (Exception e) {            }            return null;        } else {            if ("123".equals(accessToken)) {                try {                    ctx.getResponse().getWriter().write("token is error");                } catch (IOException e) {                    e.printStackTrace();                }                return null;            }        }        return null;    }}