前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >Spring Security 授权详解

Spring Security 授权详解

原创
作者头像
ruochen
发布2021-12-16 22:16:31
发布2021-12-16 22:16:31
2.7K0
举报

一、搭建注册中心

1.1 需求分析

回顾技术方案如下:

分布式系统认证技术方案

1、UAA认证服务负责认证授权。

2、所有请求经过网关到达微服务。

3、网关负责鉴权客户端以及请求转发。

4、网关将token解析后传递给微服务,微服务进行授权。

1.2 注册中心

所有的微服务的请求都经过网关,网关从认证中心读取微服务的地址,将请求转发至微服务,注册中心采用Eureka。

1、创建maven工程,工程结构如下:

注册中心工程结构

2、pom依赖如下:

代码语言:txt
复制
<?xml version="1.0" encoding="UTF-8"?>
代码语言:txt
复制
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
代码语言:txt
复制
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
代码语言:txt
复制
    <modelVersion>4.0.0</modelVersion>
代码语言:txt
复制
    <parent>
代码语言:txt
复制
        <groupId>com.pengjs.book.admin.distributed.security</groupId>
代码语言:txt
复制
        <artifactId>distributed-security</artifactId>
代码语言:txt
复制
        <version>0.0.1-SNAPSHOT</version>
代码语言:txt
复制
    </parent>
代码语言:txt
复制
    <groupId>com.pengjs.book.admin.distributed.security.discovery</groupId>
代码语言:txt
复制
    <artifactId>distributed-security-discovery</artifactId>
代码语言:txt
复制
    <version>0.0.1-SNAPSHOT</version>
代码语言:txt
复制
    <name>distributed-security-discovery</name>
代码语言:txt
复制
    <description>distributed-security-discovery</description>
代码语言:txt
复制
    <properties>
代码语言:txt
复制
        <java.version>1.8</java.version>
代码语言:txt
复制
    </properties>
代码语言:txt
复制
    <dependencies>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter-test</artifactId>
代码语言:txt
复制
            <scope>test</scope>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter-actuator</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-autoconfigure</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
    </dependencies>
代码语言:txt
复制
    <build>
代码语言:txt
复制
        <plugins>
代码语言:txt
复制
            <plugin>
代码语言:txt
复制
                <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
                <artifactId>spring-boot-maven-plugin</artifactId>
代码语言:txt
复制
            </plugin>
代码语言:txt
复制
        </plugins>
代码语言:txt
复制
    </build>
代码语言:txt
复制
</project>

2、配置文件application.yml

代码语言:txt
复制
spring:
代码语言:txt
复制
  application:
代码语言:txt
复制
    name: distributed-discovery
代码语言:txt
复制
server:
代码语言:txt
复制
  port: 53000
代码语言:txt
复制
eureka:
代码语言:txt
复制
  server:
代码语言:txt
复制
    # 关闭服务自我保护,客户端心跳检测15分钟内错误达到80%的服务会开启保护,导致别人还认为是好用的服务
代码语言:txt
复制
    enable-self-preservation: false
代码语言:txt
复制
    # 清理间隔(单位毫秒,默认60*1000),5秒将客户端剔除的服务在服务注册中心列表中剔除
代码语言:txt
复制
    eviction-interval-timer-in-ms: 10000
代码语言:txt
复制
    # eureka是CAP理论基于AP策略,为了保证一致性,关闭此切换CP,默认不关闭,false关闭
代码语言:txt
复制
    shouldUseReadOnlyResponseCache: true
代码语言:txt
复制
  client:
代码语言:txt
复制
    register-with-eureka: false # false: 不作为一个客户端注册到注册中心
代码语言:txt
复制
    fetch-registry: false # 为true时,可以启动,但是异常:cannot execute request on any known server
代码语言:txt
复制
    instance-info-replication-interval-seconds: 10
代码语言:txt
复制
    service-url:
代码语言:txt
复制
      defaultZone: http://localhost:${server.port}/eureka/
代码语言:txt
复制
  instance:
代码语言:txt
复制
    hostname: ${spring.cloud.client.ip-address}
代码语言:txt
复制
    prefer-ip-address: true
代码语言:txt
复制
    instance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${spring.application.instance-id:${server.port}}

3、注册中心启动类

代码语言:txt
复制
@SpringBootApplication
代码语言:txt
复制
@EnableEurekaServer
代码语言:txt
复制
public class DistributedSecurityDiscoveryApplication {
代码语言:txt
复制
    public static void main(String[] args) {
代码语言:txt
复制
        SpringApplication.run(DistributedSecurityDiscoveryApplication.class, args);
代码语言:txt
复制
    }
代码语言:txt
复制
}

二、搭建网关工程

2.1 角色分析

网关整合OAuth2.0有 两种思路

,一种是认证服务器生成jwt令牌,所有请求统一在网关层验证,判断权限等操作;另外一种是由资源服务器处理,网关只做请求转发。

我们选用第一种,把API网关作为OAuth2.0的资源服务器角色,实现接入客户端权限拦截、令牌解析并转发当前登录用户信息(jsonToken)给微服务,这样下游微服务就不需要关心令牌格式解析以及OAuth2.0相关机制了。

API网关在认证授权体系里主要负责两件事:

(1)作为OAuth2.0的 资源服务器 角色,实现接入方权限拦截。

(2)令牌解析并转发当前登录用户信息(明文token)给微服务。

微服务拿到明文token(明文token中包含登录用户的身份和权限信息)后也需要做两件事:

(1)用户授权拦截(看当前用户是否有权限访问资源)。

(2)将用户信息存储进当前线程上下文(有利于后续业务逻辑随时获取当前用户信息)。

2.2 创建工程

网关工程结构如下:

网关工程结构

1、pom依赖

代码语言:txt
复制
<?xml version="1.0" encoding="UTF-8"?>
代码语言:txt
复制
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
代码语言:txt
复制
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
代码语言:txt
复制
    <modelVersion>4.0.0</modelVersion>
代码语言:txt
复制
    <parent>
代码语言:txt
复制
        <groupId>com.pengjs.book.admin.distributed.security</groupId>
代码语言:txt
复制
        <artifactId>distributed-security</artifactId>
代码语言:txt
复制
        <version>0.0.1-SNAPSHOT</version>
代码语言:txt
复制
    </parent>
代码语言:txt
复制
    <groupId>com.pengjs.book.admin.distributed.security.gateway</groupId>
代码语言:txt
复制
    <artifactId>distributed-security-gateway</artifactId>
代码语言:txt
复制
    <version>0.0.1-SNAPSHOT</version>
代码语言:txt
复制
    <name>distributed-security-gateway</name>
代码语言:txt
复制
    <description>distributed-security-gateway</description>
代码语言:txt
复制
    <properties>
代码语言:txt
复制
        <java.version>1.8</java.version>
代码语言:txt
复制
    </properties>
代码语言:txt
复制
    <dependencies>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter-test</artifactId>
代码语言:txt
复制
            <scope>test</scope>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-openfeign</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>com.netflix.hystrix</groupId>
代码语言:txt
复制
            <artifactId>hystrix-javanica</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.retry</groupId>
代码语言:txt
复制
            <artifactId>spring-retry</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter-actuator</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
            <artifactId>spring-boot-starter-web</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-security</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.cloud</groupId>
代码语言:txt
复制
            <artifactId>spring-cloud-starter-oauth2</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.springframework.security</groupId>
代码语言:txt
复制
            <artifactId>spring-security-jwt</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>javax.interceptor</groupId>
代码语言:txt
复制
            <artifactId>javax.interceptor-api</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>com.alibaba</groupId>
代码语言:txt
复制
            <artifactId>fastjson</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
        <dependency>
代码语言:txt
复制
            <groupId>org.projectlombok</groupId>
代码语言:txt
复制
            <artifactId>lombok</artifactId>
代码语言:txt
复制
        </dependency>
代码语言:txt
复制
    </dependencies>
代码语言:txt
复制
    <build>
代码语言:txt
复制
        <plugins>
代码语言:txt
复制
            <plugin>
代码语言:txt
复制
                <groupId>org.springframework.boot</groupId>
代码语言:txt
复制
                <artifactId>spring-boot-maven-plugin</artifactId>
代码语言:txt
复制
            </plugin>
代码语言:txt
复制
        </plugins>
代码语言:txt
复制
    </build>
代码语言:txt
复制
</project>

2、配置文件application.yml

代码语言:txt
复制
spring:
代码语言:txt
复制
  application:
代码语言:txt
复制
    name: gateway-server
代码语言:txt
复制
  main:
代码语言:txt
复制
    allow-bean-definition-overriding: true
代码语言:txt
复制
server:
代码语言:txt
复制
  port: 53010
代码语言:txt
复制
logging:
代码语言:txt
复制
  level:
代码语言:txt
复制
    root: info
代码语言:txt
复制
    org:
代码语言:txt
复制
      springframework: info
代码语言:txt
复制
zuul:
代码语言:txt
复制
  retryable: true
代码语言:txt
复制
  ignored-services: "*"
代码语言:txt
复制
  add-host-header: true
代码语言:txt
复制
  sensitive-headers: "*"
代码语言:txt
复制
  routes:
代码语言:txt
复制
    uaa-service:
代码语言:txt
复制
      stripPrefix: false
代码语言:txt
复制
      path: /uaa/**
代码语言:txt
复制
    order-service:
代码语言:txt
复制
      stripPrefix: false
代码语言:txt
复制
      path: /order/**
代码语言:txt
复制
eureka:
代码语言:txt
复制
  client:
代码语言:txt
复制
    service-url:
代码语言:txt
复制
      defaultZone: http://localhost:53000/eureka/
代码语言:txt
复制
  instance:
代码语言:txt
复制
    preferIpAddress: true
代码语言:txt
复制
    instance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${spring.application.instance-id:${server.port}}
代码语言:txt
复制
management:
代码语言:txt
复制
  endpoints:
代码语言:txt
复制
    web:
代码语言:txt
复制
      exposure:
代码语言:txt
复制
        include: refresh,health,info,env
代码语言:txt
复制
feign:
代码语言:txt
复制
  hystrix:
代码语言:txt
复制
    enabled: false
代码语言:txt
复制
  compression:
代码语言:txt
复制
    request:
代码语言:txt
复制
      enabled: true
代码语言:txt
复制
      mime-types[0]: text/xml
代码语言:txt
复制
      mime-types[1]: application/xml
代码语言:txt
复制
      mime-types[2]: application/json
代码语言:txt
复制
      min-request-size: 2048
代码语言:txt
复制
    response:
代码语言:txt
复制
      enabled: true

统一认证服务(UAA)与统一订单服务都是网关下微服务,需要在网关上新增路由配置:

代码语言:txt
复制
zuul:
代码语言:txt
复制
  retryable: true
代码语言:txt
复制
  ignored-services: "*"
代码语言:txt
复制
  add-host-header: true
代码语言:txt
复制
  sensitive-headers: "*"
代码语言:txt
复制
  routes:
代码语言:txt
复制
    uaa-service:
代码语言:txt
复制
      stripPrefix: false
代码语言:txt
复制
      path: /uaa/**
代码语言:txt
复制
    order-service:
代码语言:txt
复制
      stripPrefix: false
代码语言:txt
复制
      path: /order/**

上面配置了网关接收的请求url若符合/order/**表达式,则将被转发到order-service(统一订单服务)中。

3、启动类

代码语言:txt
复制
@SpringBootApplication
代码语言:txt
复制
@EnableZuulProxy
代码语言:txt
复制
@EnableDiscoveryClient
代码语言:txt
复制
public class DistributedSecurityGatewayApplication {
代码语言:txt
复制
    public static void main(String[] args) {
代码语言:txt
复制
        SpringApplication.run(DistributedSecurityGatewayApplication.class, args);
代码语言:txt
复制
    }
代码语言:txt
复制
}

三、网关资源服务配置

3.1 配置资源服务

ResourceServerConfig中定义资源服务资源,主要配置的内容就是定义一些匹配规则,描述某个接入客户端需要什么样的权限才能访问某个微服务:

代码语言:txt
复制
@Configuration
代码语言:txt
复制
public class ResourceServerConfig {
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 资源列表,与服务端的resourceIds一致
     */
    private static final String RESOURCE_ID = "res1";
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 从TokenConfig中注入tokenStore
     */
    @Autowired
    private TokenStore tokenStore;
代码语言:txt
复制
    /**
代码语言:txt
复制
     * uaa资源服务配置
     */
    @Configuration
    @EnableResourceServer
    public class UaaServerConfig extends ResourceServerConfigurerAdapter {
代码语言:txt
复制
        @Override
代码语言:txt
复制
        public void configure(ResourceServerSecurityConfigurer resources) throws Exception {
代码语言:txt
复制
            resources.tokenStore(tokenStore).resourceId(RESOURCE_ID)
代码语言:txt
复制
                    .stateless(true);
代码语言:txt
复制
        }
代码语言:txt
复制
        @Override
代码语言:txt
复制
        public void configure(HttpSecurity http) throws Exception {
代码语言:txt
复制
            // uaa认证全部放行
代码语言:txt
复制
            http.authorizeRequests()
代码语言:txt
复制
                    .antMatchers("/uaa/**").permitAll();
代码语言:txt
复制
        }
代码语言:txt
复制
    }
代码语言:txt
复制
    /**
代码语言:txt
复制
     * order资源服务配置
     */
    @Configuration
    @EnableResourceServer
    public class OrderServerConfig extends ResourceServerConfigurerAdapter {
代码语言:txt
复制
        @Override
代码语言:txt
复制
        public void configure(ResourceServerSecurityConfigurer resources) throws Exception {
代码语言:txt
复制
            resources.tokenStore(tokenStore).resourceId(RESOURCE_ID)
代码语言:txt
复制
                    .stateless(true);
代码语言:txt
复制
        }
代码语言:txt
复制
        @Override
代码语言:txt
复制
        public void configure(HttpSecurity http) throws Exception {
代码语言:txt
复制
            // order需要有ROLE_API的scope
代码语言:txt
复制
            http.authorizeRequests()
代码语言:txt
复制
                    .antMatchers("/order/**")
代码语言:txt
复制
                    .access("#oauth2.hasScope('ROLE_API')");
代码语言:txt
复制
        }
代码语言:txt
复制
    }
代码语言:txt
复制
    // 配置其他资源服务。。。
代码语言:txt
复制
}

3.2 安全配置

代码语言:txt
复制
/**
代码语言:txt
复制
 * 安全访问控制
 */
@Configuration
@EnableGlobalMethodSecurity(securedEnabled = true, prePostEnabled = true)
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 安全拦截机制(最重要)
     * @param http
     * @throws Exception
     */
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        // 网关:所有的请求都放行,只在resource config中拦截
        http.authorizeRequests()
                .antMatchers("/**").permitAll()
                .and().csrf().disable();
    }
}

四、转发明文token给微服务

通过Zuul过滤器的方式实现,目的是让上下游微服务能够很方便的获取到当前的登录用户信息(明文token)

(1)实现Zuul前置过滤器,完成当前登录用户信息提取,并放入转发到微服务的request中

代码语言:txt
复制
/**
代码语言:txt
复制
 * token传递拦截
 */
public class AuthFilter extends ZuulFilter {
代码语言:txt
复制
    @Override
代码语言:txt
复制
    public String filterType() {
代码语言:txt
复制
        // 请求之前进行拦截
代码语言:txt
复制
        return "pre";
代码语言:txt
复制
    }
代码语言:txt
复制
    @Override
代码语言:txt
复制
    public int filterOrder() {
代码语言:txt
复制
        // 最优先,数值越小越优先
代码语言:txt
复制
        return 0;
代码语言:txt
复制
    }
代码语言:txt
复制
    @Override
代码语言:txt
复制
    public boolean shouldFilter() {
代码语言:txt
复制
        return true;
代码语言:txt
复制
    }
代码语言:txt
复制
    @Override
代码语言:txt
复制
    public Object run() throws ZuulException {
代码语言:txt
复制
        // 4. 转发给具体的微服务
代码语言:txt
复制
        RequestContext context = RequestContext.getCurrentContext();
代码语言:txt
复制
        // 1. 从安全的上下文中获取当前用户对象
代码语言:txt
复制
        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
代码语言:txt
复制
        // 无token直接访问网关内资源的情况,目前只有uaa服务直接暴露
代码语言:txt
复制
        if (!(authentication instanceof OAuth2Authentication)) {
代码语言:txt
复制
            // 不解析
代码语言:txt
复制
            return null;
代码语言:txt
复制
        }
代码语言:txt
复制
        OAuth2Authentication oAuth2Authentication = (OAuth2Authentication) authentication;
代码语言:txt
复制
        Authentication userAuthentication = oAuth2Authentication.getUserAuthentication();
代码语言:txt
复制
        // 2. 获取当前用户身份信息
代码语言:txt
复制
        String principals = userAuthentication.getName();
代码语言:txt
复制
        // 3. 获取当前用户权限信息
代码语言:txt
复制
        List<String> authorities = new ArrayList<>();
代码语言:txt
复制
        userAuthentication.getAuthorities().forEach(s -> authorities.add(((GrantedAuthority) s).getAuthority()));
代码语言:txt
复制
        OAuth2Request oAuth2Request = oAuth2Authentication.getOAuth2Request();
代码语言:txt
复制
        Map<String, String> requestParameters = oAuth2Request.getRequestParameters();
代码语言:txt
复制
        // 4. 把身份信息和权限信息中,加入到http的header中
代码语言:txt
复制
        // 保留原本的基本信息
代码语言:txt
复制
        Map<String, Object> jsonToken = new HashMap<>(requestParameters);
代码语言:txt
复制
        if (userAuthentication != null) {
代码语言:txt
复制
            jsonToken.put("principal", principals);
代码语言:txt
复制
            jsonToken.put("authorities", authorities);
代码语言:txt
复制
        }
代码语言:txt
复制
        // 5. 组装明文token,转发给微服务。放入header,名称json-token
代码语言:txt
复制
        context.addZuulRequestHeader("json-token", EncryptUtil.encodeUTF8StringBase64(JSON.toJSONString(jsonToken)));
代码语言:txt
复制
        return null;
代码语言:txt
复制
    }
代码语言:txt
复制
}

(2)将Filter纳入到Spring容器

配置AuthFilter

代码语言:txt
复制
@Configuration
代码语言:txt
复制
public class ZuulConfig {
代码语言:txt
复制
    @Bean
代码语言:txt
复制
    public AuthFilter preFilter() {
代码语言:txt
复制
        return new AuthFilter();
代码语言:txt
复制
    }
代码语言:txt
复制
    @Bean
代码语言:txt
复制
    public FilterRegistrationBean corsFilter() {
代码语言:txt
复制
        final UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
代码语言:txt
复制
        final CorsConfiguration config = new CorsConfiguration();
代码语言:txt
复制
        config.setAllowCredentials(true);
代码语言:txt
复制
        config.addAllowedOrigin("*");
代码语言:txt
复制
        config.addAllowedHeader("*");
代码语言:txt
复制
        config.addAllowedMethod("*");
代码语言:txt
复制
        config.setMaxAge(18000L);
代码语言:txt
复制
        source.registerCorsConfiguration("/**", config);
代码语言:txt
复制
        CorsFilter corsFilter = new CorsFilter(source);
代码语言:txt
复制
        FilterRegistrationBean bean = new FilterRegistrationBean(corsFilter);
代码语言:txt
复制
        bean.setOrder(Ordered.HIGHEST_PRECEDENCE);
代码语言:txt
复制
        return bean;
代码语言:txt
复制
    }
代码语言:txt
复制
}

五、微服务解析令牌并鉴权

当微服务收到明文token后,该怎么鉴权拦截呢?自己实现一个Filter?自己解析明文token,自己定义一套资源访问策略?

能不能适配Spring Security呢,是不是突然想起了前面我们实现的Spring

Security基于token认证的例子。咱们还是拿统一订单服务作为网关下游微服务,对它进行改造,增加 微服务用户鉴权拦截 功能。

(1)增加测试资源

OrderController增加以下endpoint:

代码语言:txt
复制
@RestController
代码语言:txt
复制
public class OrderController {
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 流程:当携带token访问这个资源的时候,会通过远程的service去请求地址
     * http://localhost:53020/uaa/oauth/check_token校验token是否合法
     * @return
     */
    @GetMapping(value = "/r1")
    // 拥有p1权限方可访问此URL
    @PreAuthorize("hasAnyAuthority('p1')")
    public String r1() {
        // 通过spring security api获取当前登录用户
        UserDto userDto = (UserDto) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
        // String username = (String) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
        // return username + "访问资源1";
        // return userDto.getUsername() + "访问资源1";
        return JSON.toJSONString(userDto) + "访问资源1";
    }
代码语言:txt
复制
    @GetMapping(value = "/r2")
代码语言:txt
复制
    // 拥有p2权限方可访问此URL
代码语言:txt
复制
    @PreAuthorize("hasAnyAuthority('p2')")
代码语言:txt
复制
    public String r2() {
代码语言:txt
复制
        UserDto userDto = (UserDto) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
代码语言:txt
复制
        // return userDto.getUsername() + "访问资源2";
代码语言:txt
复制
        return JSON.toJSONString(userDto) + "访问资源2";
代码语言:txt
复制
    }
代码语言:txt
复制
}

(2)Spring Security配置

开启方法保护,并增加Spring配置策略,除了/login方法不受保护(统一认证要调用),其他的资源全部需要认证才能访问。

代码语言:txt
复制
@Configuration
代码语言:txt
复制
@EnableResourceServer
代码语言:txt
复制
// 或者是单独配置WebSecurityConfig也可以
代码语言:txt
复制
@EnableGlobalMethodSecurity(prePostEnabled = true)
代码语言:txt
复制
public class ResourceServerConfig extends ResourceServerConfigurerAdapter {
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 资源列表,与服务端的resourceIds一致
     */
    private static final String RESOURCE_ID = "res1";
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 从TokenConfig中注入tokenStore
     */
    @Autowired
    private TokenStore tokenStore;
代码语言:txt
复制
    @Override
代码语言:txt
复制
    public void configure(ResourceServerSecurityConfigurer resources) throws Exception {
代码语言:txt
复制
        // 资源id
代码语言:txt
复制
        resources.resourceId(RESOURCE_ID)
代码语言:txt
复制
                // 验证令牌的服务
代码语言:txt
复制
                // .tokenServices(tokenService())
代码语言:txt
复制
                // 不再使用验证令牌服务,让其自己验证
代码语言:txt
复制
                .tokenStore(tokenStore)
代码语言:txt
复制
                .stateless(true);
代码语言:txt
复制
    }
代码语言:txt
复制
    /**
代码语言:txt
复制
     * 资源访问策略
     * @param http
     * @throws Exception
     */
    @Override
    public void configure(HttpSecurity http) throws Exception {
        http.authorizeRequests()
                .antMatchers("/**")
                // .access("#oauth2.hasScope('all')") // 所有的请求都必须有scope=all,跟服务端一致
                .access("#oauth2.hasScope('ROLE_ADMIN')") // 所有的请求都必须有scope=ROLE_ADMIN,跟服务端一致
                .and().csrf().disable() // 关闭CSRF
                // 基于token的方式,session就不用再记录了
                .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS);
    }
代码语言:txt
复制
}

综合以上配置,共定义了三个资源,拥有p1权限才可以访问r1资源,拥有p2权限才可以访问r2资源。

(3)定义Filter拦截token,并形成Spring Security的Authentication对象

代码语言:txt
复制
@Component
代码语言:txt
复制
public class TokenAuthenticationFilter extends OncePerRequestFilter {
代码语言:txt
复制
    @Override
代码语言:txt
复制
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
代码语言:txt
复制
        String token = request.getHeader("json-token");
代码语言:txt
复制
        if (null != token) {
代码语言:txt
复制
            // 1. 解析token
代码语言:txt
复制
            // 解码
代码语言:txt
复制
            String json = EncryptUtil.decodeUTF8StringBase64(token);
代码语言:txt
复制
            // 将token转成json对象
代码语言:txt
复制
            JSONObject userJson = JSON.parseObject(json);
代码语言:txt
复制
            // UserDto user = new UserDto();
代码语言:txt
复制
            // // 用户身份信息
代码语言:txt
复制
            // user.setUsername(userJson.getString("principal"));
代码语言:txt
复制
            // uaa那边存的是整个用户的信息,这里就可以直接转为UserDto
代码语言:txt
复制
            UserDto user = JSON.parseObject(userJson.getString("principal"), UserDto.class);
代码语言:txt
复制
            // 用户权限
代码语言:txt
复制
            JSONArray authoritiesArray = userJson.getJSONArray("authorities");
代码语言:txt
复制
            String[] authorities = authoritiesArray.toArray(new String[authoritiesArray.size()]);
代码语言:txt
复制
            // 2. 新建并填充authentication(身份信息和权限)
代码语言:txt
复制
            UsernamePasswordAuthenticationToken authentication = new UsernamePasswordAuthenticationToken(user,
代码语言:txt
复制
                    null, AuthorityUtils.createAuthorityList(authorities));
代码语言:txt
复制
            // 设置details
代码语言:txt
复制
            authentication.setDetails(new WebAuthenticationDetailsSource().buildDetails(request));
代码语言:txt
复制
            // 3. 将authentication保存到安全上下文中
代码语言:txt
复制
            SecurityContextHolder.getContext().setAuthentication(authentication);
代码语言:txt
复制
        }
代码语言:txt
复制
        // 过滤器继续往前走
代码语言:txt
复制
        filterChain.doFilter(request, response);
代码语言:txt
复制
    }
代码语言:txt
复制
}

经过上边的过滤器,资源服务中就可以方便的获取到用户的身份信息:

代码语言:txt
复制
UserDto userDto = (UserDto) SecurityContextHolder.getContext().getAuthentication().getPrincipal();

六、集成测试

本案例测试过程描述:

1、采用OAuth2.0的密码模式从UAA中获取token

2、使用该token通过网关访问订单服务的测试资源

(1)通过网关访问UAA的授权获取令牌,获取token,注意网关端口是53010

http://127.0.0.1:53010/uaa/oauth/token

通过网关访问UAA的授权获取令牌

(2)通过网关UAA校验token

http://127.0.0.1:53010/uaa/oauth/check_token

通过网关UAA校验token

(3)带上token访问资源

http://localhost:53010/order/r1

带上token访问资源

七、扩展用户信息

7.1 需求分析

目前jwt令牌存储了用户身份信息、权限信息,网关将token明文转发给微服务使用,目前用户身份信息锦包含了用户的账户,微服务还需要用户的ID、手机号等重要信息。

在认证阶段DaoAuthenticationProvider会调用UserDetailsService查询用户信息,这里是可以获取到齐全的用户信息的。由于JWT令牌中用户身份信息来源于UserDetailsUserDetails中仅定义了username为用户的身份信息,这里有两个思路,第一是可以扩展UserDetails,使之包含更多的自定义属性,第二也可以扩展username的内容,比如存入json数据内容作为username的内容。相比较而言,方案二比较简单还不用破坏UserDetails的结构,我们采用方案二。

7.2 修改UserDetailsService

从数据库查询到user,将整体的user转成json存入到UserDetails对象中。

代码语言:txt
复制
    @Override
代码语言:txt
复制
    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
代码语言:txt
复制
        // 将来连接数据库根据账号查询用户信息
代码语言:txt
复制
        // 登录账号
代码语言:txt
复制
        System.out.println("username=" + username);
代码语言:txt
复制
        UserDto userByUsername = userDao.getUserByUsername(username);
代码语言:txt
复制
        if (null == userByUsername) {
代码语言:txt
复制
            // 如果用户查询不到,返回null,返回给provider,由provider来抛异常
代码语言:txt
复制
            return null;
代码语言:txt
复制
        }
代码语言:txt
复制
        // 根据用户的ID查询用户的权限
代码语言:txt
复制
        List<String> permissions = userDao.findPermissionByUserId(userByUsername.getId());
代码语言:txt
复制
        String[] permissionArray = new String[permissions.size()];
代码语言:txt
复制
        permissions.toArray(permissionArray);
代码语言:txt
复制
        // 将userByUsername转换为json,整体存入到userDetails
代码语言:txt
复制
        String principal = JSON.toJSONString(userByUsername);
代码语言:txt
复制
        UserDetails userDetails = User.withUsername(principal).password(userByUsername.getPassword())
代码语言:txt
复制
                .authorities(permissionArray).build();
代码语言:txt
复制
        return userDetails;
代码语言:txt
复制
    }

7.3 修改资源服务器过滤器

资源服务中的过滤器负责从Header中解析json-token,从中即可拿到网关放入的用户身份信息,代码如下:

代码语言:txt
复制
@Component
代码语言:txt
复制
public class TokenAuthenticationFilter extends OncePerRequestFilter {
代码语言:txt
复制
    @Override
代码语言:txt
复制
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
代码语言:txt
复制
        String token = request.getHeader("json-token");
代码语言:txt
复制
        if (null != token) {
代码语言:txt
复制
            // 1. 解析token
代码语言:txt
复制
            // 解码
代码语言:txt
复制
            String json = EncryptUtil.decodeUTF8StringBase64(token);
代码语言:txt
复制
            // 将token转成json对象
代码语言:txt
复制
            JSONObject userJson = JSON.parseObject(json);
代码语言:txt
复制
            // UserDto user = new UserDto();
代码语言:txt
复制
            // // 用户身份信息
代码语言:txt
复制
            // user.setUsername(userJson.getString("principal"));
代码语言:txt
复制
            // uaa那边存的是整个用户的信息,这里就可以直接转为UserDto
代码语言:txt
复制
            UserDto user = JSON.parseObject(userJson.getString("principal"), UserDto.class);
代码语言:txt
复制
            // 用户权限
代码语言:txt
复制
            JSONArray authoritiesArray = userJson.getJSONArray("authorities");
代码语言:txt
复制
            String[] authorities = authoritiesArray.toArray(new String[authoritiesArray.size()]);
代码语言:txt
复制
            // 2. 新建并填充authentication(身份信息和权限)
代码语言:txt
复制
            UsernamePasswordAuthenticationToken authentication = new UsernamePasswordAuthenticationToken(user,
代码语言:txt
复制
                    null, AuthorityUtils.createAuthorityList(authorities));
代码语言:txt
复制
            // 设置details
代码语言:txt
复制
            authentication.setDetails(new WebAuthenticationDetailsSource().buildDetails(request));
代码语言:txt
复制
            // 3. 将authentication保存到安全上下文中
代码语言:txt
复制
            SecurityContextHolder.getContext().setAuthentication(authentication);
代码语言:txt
复制
        }
代码语言:txt
复制
        // 过滤器继续往前走
代码语言:txt
复制
        filterChain.doFilter(request, response);
代码语言:txt
复制
    }
代码语言:txt
复制
}

八、总结

重点回顾:

什么是认证、授权、会话。undefined Java Servlet为支持http会话做了哪些是儿。undefined 基于Session认证机制的运作流程。undefined 基于token认证机制的运作流程。undefined 理解Spring Security的工作原理,Spring Security结构总览,认证流程和授权,中间涉及到哪些组件,这些组件分别处理什么,如何自定义这些组件满足个性需求。undefined OAuth2.0认证的四种模式?他们的大体流程是什么?undefined Spring Cloud Security OAuth2.0包括哪些组件?自责?undefined 分布式系统认证需要解决的问题?

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
作者已关闭评论
0 条评论
热度
最新
推荐阅读
目录
  • 一、搭建注册中心
    • 1.1 需求分析
    • 1.2 注册中心
  • 二、搭建网关工程
    • 2.1 角色分析
    • 2.2 创建工程
  • 三、网关资源服务配置
    • 3.1 配置资源服务
    • 3.2 安全配置
  • 四、转发明文token给微服务
  • 五、微服务解析令牌并鉴权
  • 六、集成测试
  • 七、扩展用户信息
    • 7.1 需求分析
    • 7.2 修改UserDetailsService
    • 7.3 修改资源服务器过滤器
  • 八、总结
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档