阿潇个人最懂版本
-
启动类加注解 @EnableZuulProxy
若使用redis则加入（开启spring-session和redis的注解）@EnableRedisHttpSession -
zuul 依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
- zuul 完整的pom.xml
<!--版本控制-->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.3.RELEASE</version>
<relativePath/>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
</properties>
<dependencies>
<!--支持全栈式Web开发，包括Tomcat和spring-webmvc。-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--eureka-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!-- zuul-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
<!--支持常规的测试依赖，包括JUnit、Hamcrest、Mockito以及spring-test模块。-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!--引入spring-session和redis的包，zuul网关和其他模块都需要映入：-->
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
</dependencies>
<!--spring cloud 微服务-->
<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>
<!--Maven插件 能够将Spring Boot应用打包为可执行的jar或war文件，然后以通常的方式运行Spring Boot应用-->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
- application.yml
#注册到eureka
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:8762/eureka/
#端口号
server:
port: 8899
#名字
spring:
application:
name: ec-zuul
#配置redis
redis:
database: 0
host: 127.0.0.1
port: 6379
password: 12345
jedis:
pool:
max-active: 8
timeout: 50000ms
#路由转发
# 结合eureka 使用
zuul:
routes:
# 可以随便起，但是规范是与服务名一样
ec-user:
# 拦截的路径 可以随便起，但是规范是与服务名一样
path: /ec-user/**
# 具体服务可以小写
serviceId: EC-USER
#设置cookie可以传递
sensitive-headers:
- 过滤器创建类AuthFilter（类名必须为AuthFilter）
package com.mengmaec.eczuul;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.apache.commons.lang.StringUtils;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.SERVLET_DETECTION_FILTER_ORDER;
/**
* @Auther: 18358
* @Date: 2018/12/18 15:35
* @Description:
*/
@Component
public class AuthFilter extends ZuulFilter {
// 过滤器类型
@Override
public String filterType() {
return PRE_TYPE;
}
// 过滤的顺序 越小越靠前
@Override
public int filterOrder() {
return SERVLET_DETECTION_FILTER_ORDER - 1;
}
// 是否执行 具体的过滤逻辑 返回true==执行 ，反之
// 默认true 中间可写具体需要拦截的服务
@Override
public boolean shouldFilter() {
// 获取用户请求地址，判断是否是需要过滤的地址
//共享RequestContext，上下文对象
// RequestContext requestContext = RequestContext.getCurrentContext();
// HttpServletRequest request = requestContext.getRequest();
// System.out.println(request.getRequestURI());
// String uri = request.getRequestURI();
// if (uri.equals("/ec-user/user/get_user_info")||uri.equals("/ec-user/user/logout")) {
// return true;
// }
// return false;
return true;
}
// 过滤逻辑
@Override
public Object run() throws ZuulException {
// 判断用户具有什么权限
//JWT
RequestContext requestContext = RequestContext.getCurrentContext();
HttpServletRequest request = requestContext.getRequest();
String uri = request.getRequestURI();
HttpSession session = request.getSession();
//需要权限校验的接口
if (uri.equals("/ec-user/user/get_user_info")||uri.equals("/ec-user/user/logout"))
//空 代表没有登录
if (session.getAttribute("currentUser") == null) {
// 过滤该请求，不对其进行路由
requestContext.setSendZuulResponse(false);
//返回错误代码
requestContext.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());
}
return null;
}
}
网友评论