• Spring Security——基于前后端分离项目的使用(安全框架)

     1.简介

    Spring Security有一个过滤器链，也就是说原本在拦截器和过滤器里面做的事都可以用Spring Security完成，比如验证token和将用户id存入线程上下文局部变量等等。

    入门案例

    创建项目并勾选依赖

    最基本的要这两个依赖即可

    新建一个Controller层的接口

    1. @RestController
    2. public class HelloController {
    3.  
    4.     @RequestMapping("/hello")
    5.     public String hello(){
    6.         return "hello security";
    7.     }
    8. }

    想要访问这个接口的话会自动跳转到spring security自带的一个登录页面，需要登录之后才能访问别的接口.默认的用户名是user,密码会在控制台输出。

    登录之后就可以访问到接口了。 

    然后还有一个默认的登出。 

    2.认证

    登录校验流程

    这里就是前后端分离的项目的一个登录流程，包括这个项目也是这样的.

    除了登录注册接口之后的请求必须都要携带token。

    苍穹外卖day01——项目导入+环境搭建-CSDN博客

    SpringSecurity原理

    图中有三种类型的过滤器，一个是认证，一个是异常处理，一个是授权。授权那个虽然是写着拦截器，实际也是过滤器。

    虽然说这里用的都是过滤器，但是在项目中也是可以拦截器和过滤器一起用的。

     查看具体的过滤器

    启动类里面的run方法返回值就是一个spring容器。用debug可以看见有哪些过滤器。能够看见默认过安全过滤器链中有16个过滤器。

    认证的流程详解

    在认证用的过滤器处理逻辑里面，除了使用了用户名密码认证这个过滤器以外还递归调用了别的一些东西。

    虽然这玩意有点像责任链模式，但是完全不是一个东西。

     层层传递调用，最后一个InMemoryUserDetailsManager是在内存中查询用户信息，是UserDetailsManager接口的一个实现类，这个在后面要改成在数据库查询。

    第三层那里进行密码比对，正确的话就将权限封装返回给第一层，第一层将其存入一个上下文。

    后面的别的过滤器会从上下文获取这个封装信息。

    根据需求进行修改

    登录的时候

    在那个流程图里面最后一层要改成从数据库里面获取用户信息，然后第一层里面也要加多一个响应token的操作，因为这里是前后端分离的项目。所以说要用自定义的Controller代替第一层的默认过滤器。由controller返回token.

    所以要做两件事。

    1.自定义登录接口 

            调用providerManager , 如果认证通过生成jwt

            把用户信息存入redis中。

    2.自定义UserDetailService

            在这个实现类中查询数据库。 

    校验的时候 

    后续非登录请求如下校验

    注意:下面是非登录的请求。

    自定义一个jwt过滤器加入过滤器链中。

     这个jwt里面要根据userID查询用户信息，要到数据库查询，每一次请求都查询数据库的话压力过大，所以将信息存redsi里面，直接查询redis.。

    所以，可以在登录认证通过的时候将用户信息存入redis.

    1.定义jwt认证过滤器

            获取token

            解析token（获取userId）

            从redis获取用户信息

            存入SecurityContextHolder中供别的过滤器使用。

    修改前的准备工作

    导入redis,jwt和fastjson的依赖。

    1.         <dependency>
    2.             <groupId>org.springframework.bootgroupId>
    3.             <artifactId>spring-boot-starter-data-redisartifactId>
    4.         dependency>
    5.         <dependency>
    6.             <groupId>com.alibabagroupId>
    7.             <artifactId>fastjsonartifactId>
    8.             <version>1.2.76version>
    9.         dependency>
    10.         <dependency>
    11.             <groupId>io.jsonwebtokengroupId>
    12.             <artifactId>jjwtartifactId>
    13.             <version>0.9.1version>
    14.         dependency>

    这里配置一下redis的序列化，但是不用fastjson配置,不搞那么麻烦。

    1. @Configuration
    2. @Slf4j
    3. public class RedisConfiguration {
    4.     @Bean
    5.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){
    6.         log.info("开始创建redis模板对象");
    7.         RedisTemplate redisTemplate=new RedisTemplate();
    8.         //设置redis的连接工厂对象
    9.         redisTemplate.setConnectionFactory(redisConnectionFactory);
    10.         //设置Redis key的序列化器
    11.         redisTemplate.setKeySerializer(new StringRedisSerializer());
    12.         return redisTemplate;
    13.     }
    14. }

    配置信息也要写一下。

    1. spring:
    2.   redis:
    3.     host: 
    4.     port: 
    5.     password: 
    6.     database: 1

    再定义一个Result风格的响应类。

    1. /**
    2.  * 后端统一返回结果
    3.  * @param 
    4.  */
    5. @Data
    6. public class Result implements Serializable {
    7.  
    8.     private Integer code; //编码：1成功，0和其它数字为失败
    9.     private String msg; //错误信息
    10.     private T data; //数据
    11.  
    12.     public static  Result success() {
    13.         Result result = new Result();
    14.         result.code = 1;
    15.         return result;
    16.     }
    17.  
    18.     public static  Result success(T object) {
    19.         Result result = new Result();
    20.         result.data = object;
    21.         result.code = 1;
    22.         return result;
    23.     }
    24.  
    25.     public static  Result error(String msg) {
    26.         Result result = new Result();
    27.         result.msg = msg;
    28.         result.code = 0;
    29.         return result;
    30.     }
    31.  
    32. }

    再加上一个jwt和一个响应的工具类。

    1. public class JwtUtil {
    2.     /**
    3.      * 生成jwt
    4.      * 使用Hs256算法, 私匙使用固定秘钥
    5.      *
    6.      * @param secretKey jwt秘钥
    7.      * @param ttlMillis jwt过期时间(毫秒)
    8.      * @param claims    设置的信息
    9.      * @return
    10.      */
    11.     public static String createJWT(String secretKey, long ttlMillis, Map claims) {
    12.         // 指定签名的时候使用的签名算法，也就是header那部分
    13.         SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256;
    14.  
    15.         // 生成JWT的时间
    16.         long expMillis = System.currentTimeMillis() + ttlMillis;
    17.         Date exp = new Date(expMillis);
    18.  
    19.         // 设置jwt的body
    20.         JwtBuilder builder = Jwts.builder()
    21.                 // 如果有私有声明，一定要先设置这个自己创建的私有的声明，这个是给builder的claim赋值，一旦写在标准的声明赋值之后，就是覆盖了那些标准的声明的
    22.                 .setClaims(claims)
    23.                 // 设置签名使用的签名算法和签名使用的秘钥
    24.                 .signWith(signatureAlgorithm, secretKey.getBytes(StandardCharsets.UTF_8))
    25.                 // 设置过期时间
    26.                 .setExpiration(exp);
    27.  
    28.         return builder.compact();
    29.     }
    30.  
    31.     /**
    32.      * Token解密
    33.      *
    34.      * @param secretKey jwt秘钥 此秘钥一定要保留好在服务端, 不能暴露出去, 否则sign就可以被伪造, 如果对接多个客户端建议改造成多个
    35.      * @param token     加密后的token
    36.      * @return
    37.      */
    38.     public static Claims parseJWT(String secretKey, String token) {
    39.         // 得到DefaultJwtParser
    40.         Claims claims = Jwts.parser()
    41.                 // 设置签名的秘钥
    42.                 .setSigningKey(secretKey.getBytes(StandardCharsets.UTF_8))
    43.                 // 设置需要解析的jwt
    44.                 .parseClaimsJws(token).getBody();
    45.         return claims;
    46.     }
    47.  
    48. }
    1. public class WebUtil {
    2.     public static String readerString(HttpServletResponse response,String string){
    3.         try{
    4.             response.setStatus(1);
    5.             response.setContentType("application/json");
    6.             response.setCharacterEncoding("utf-8");
    7.             response.getWriter().print(string);
    8.         }catch(IOException e){
    9.             e.printStackTrace();
    10.         }
    11.         return null;
    12.     }
    13. }

     jwt还需要设定一些参数，这里通过读取配置文件的方式传进来

    1. @Component
    2. @ConfigurationProperties(prefix = "sky.jwt")
    3. @Data
    4. public class JwtProperties {
    5.  
    6.     /**
    7.      * 用户生成jwt令牌相关配置
    8.      */
    9.     private String secretKey;
    10.     private long ttl;
    11.     private String tokenName;
    12. }
    1. sky:
    2.   jwt:
    3.     # 设置jwt签名加密时使用的秘钥
    4.     secret-key: yhy
    5.     # 设置jwt过期时间
    6.     ttl: 7200000
    7.     # 设置前端传递过来的令牌名称
    8.     token-name: token

    然后再根据数据库用户表准备一个实体类。

    1. @Data
    2. @AllArgsConstructor
    3. @NoArgsConstructor
    4. public class User   implements Serializable {
    5.     private  int id;
    6.     private String username;
    7.     private String password;
    8.     private int role;
    9. }

    这里根据实体类去建表，不再提供建表语句。

    再次导入依赖

    1.         <dependency>
    2.             <groupId>org.mybatis.spring.bootgroupId>
    3.             <artifactId>mybatis-spring-boot-starterartifactId>
    4.             <version>2.3.1version>
    5.         dependency>
    6.         <dependency>
    7.             <groupId>com.mysqlgroupId>
    8.             <artifactId>mysql-connector-jartifactId>
    9.             <scope>runtimescope>
    10.         dependency>

    最后在启动类加上开启注解式缓存的注解。

    1. @SpringBootApplication
    2. @EnableCaching //开启缓存注解的功能
    3. public class SpringSecurityDemoApplication {
    4.  
    5.     public static void main(String[] args) {
    6.         ConfigurableApplicationContext run = SpringApplication.run(SpringSecurityDemoApplication.class, args);
    7.         System.out.println("——————————————");
    8.     }
    9.  
    10. }

    核心代码实现

    数据库校验用户 

    Pojo层如下 

    实现指定的UserDetailService接口，实现要用的方法。

    这里因为返回的是一个UserDetail对象，所以要实现一个这个接口，把上面写的User封装进去

    1. @Data
    2. @AllArgsConstructor
    3. @NoArgsConstructor
    4. public class LoginUser implements UserDetails {
    5.     private User user;
    6.     @Override
    7.     public Collectionextends GrantedAuthority> getAuthorities() {
    8.         return null;
    9.     }
    10.  
    11.     @Override
    12.     public String getPassword() {
    13.         return user.getPassword();
    14.     }
    15.  
    16.     @Override
    17.     public String getUsername() {
    18.         return user.getUsername();
    19.     }
    20.  
    21.     @Override
    22.     public boolean isAccountNonExpired() {
    23.         return true;
    24.     }
    25.  
    26.     @Override
    27.     public boolean isAccountNonLocked() {
    28.         return true;
    29.     }
    30.  
    31.     @Override
    32.     public boolean isCredentialsNonExpired() {
    33.         return true;
    34.     }
    35.  
    36.     @Override
    37.     public boolean isEnabled() {
    38.         return true;
    39.     }
    40. }

    Service层如下 

    然后Service实现UserDetailService接口如下所示

    1. @Service
    2. public class UserDetailServiceImpl implements UserDetailsService {
    3.  
    4.     @Autowired
    5.     private UserMapper userMapper;
    6.  
    7.     @Override
    8.     public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
    9.         //查询用户信息
    10.         User user=userMapper.selectByUsername(username);
    11.         //如果没有查询到用户就抛出异常。
    12.         if(Objects.isNull(user)){
    13.             throw new RuntimeException("用户不存在或者密码错误");
    14.         }
    15.         //TODO 查询对应的权限信息
    16.  
    17.         //把数据封装UserDetail返回
    18.         return new LoginUser(user);
    19.     }
    20. }

    mapper层如下

    1. @Mapper
    2. public interface UserMapper {
    3.  
    4.     @Select("select * from user where username = #{username}")
    5.      User selectByUsername(String usename);
    6. }

    现在已经替换了流程图的最后一个部分，前面的登录页面还是默认的，也是可以使用的.

    但是登录的话会报错如下。

    这里会使用一个默认的PasswordEncoder进行密码，它要求查询得到的密码要在密码前面加上{},括号里面写上标识，如果写上noop的话就说明密码是原文存储。将数据库里面的密码加上{noop}再次登录就可以成功。

    密码加密存储 

    流程图里面有说到过会通过PasswordEncoder比较两个密码。

    所以这里要重写一个配置类替换IOC容器里面默认的PasswordEncoder的Bean对象。

    1. @Configuration
    2. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
    3.     @Bean
    4.     public PasswordEncoder passwordEncoder(){
    5.         return new BCryptPasswordEncoder();
    6.     }
    7. }

    在测试类里面输出可以看见两次的加密密码不一样,因为它会生成一个随机的盐和原文进行一系列随机的处理之后再进行加密。

    1. @SpringBootTest
    2. public class MapperTest {
    3.     @Test
    4.     void test(){
    5.         BCryptPasswordEncoder bCryptPasswordEncoder = new BCryptPasswordEncoder();
    6.         System.out.println(bCryptPasswordEncoder.encode("123456"));//密码加密
    7.         System.out.println(bCryptPasswordEncoder.encode("123456"));//密码加密
    8.     }
    9.  
    10. }

      然后再看看另一个方法，原文和密文的密码比对

    1. @SpringBootTest
    2. public class MapperTest {
    3.     @Test
    4.     void test(){
    5.         BCryptPasswordEncoder bCryptPasswordEncoder = new BCryptPasswordEncoder();
    6.         //$2a$10$zG/hDdGw5U6RDG.EgFqhXeb92ErzfvgpghiykM3xSGA9CJtc6Cezm
    7.         //密码比对
    8.         System.out.println(bCryptPasswordEncoder.matches("123456", "$2a$10$zG/hDdGw5U6RDG.EgFqhXeb92ErzfvgpghiykM3xSGA9CJtc6Cezm"));
    9.     }
    10. }

    修改数据库里面的密码之后再次尝试去登录也可以登陆进去了

    登陆接口

     在配置类当中

    新增一个Bean对象,并重写一个configure方法自定义规则。

    1. @Configuration
    2. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
    3.     @Bean
    4.     public PasswordEncoder passwordEncoder(){
    5.         return new BCryptPasswordEncoder();
    6.     }
    7.     @Bean
    8.     @Override
    9.     public AuthenticationManager authenticationManager()throws Exception{
    10.         return super.authenticationManager();
    11.     }
    12.  
    13.     @Override
    14.     protected void configure(HttpSecurity http) throws Exception {
    15.             http
    16.                 //关闭csrf
    17.                 .csrf().disable()
    18.                 //不通过Session获取SecurityContext
    19.                 .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
    20.                 .and()
    21.                 .authorizeRequests()
    22.                 // 对于登录接口 允许匿名访问
    23.                 .antMatchers("/user/login").anonymous()
    24.                 // 除上面外的所有请求全部需要鉴权认证
    25.                 .anyRequest().authenticated();
    26.     }
    27. }

    Controller中

    1. @RestController
    2. public class LoginController {
    3. @Autowired
    4.     private LoginService loginService;
    5.     @PostMapping("/user/login")
    6.     public Result login(@RequestBody User user){
    7.         //登录
    8.         String token = loginService.login(user);
    9.         return Result.success(token);
    10.     }
    11. }

    Service中

    1. @Service
    2. public class LoginServiceImpl implements LoginService {
    3.  
    4.     @Autowired
    5.     private AuthenticationManager authenticationManager;
    6.     @Autowired
    7.     private JwtProperties jwtProperties;
    8.     @Autowired
    9.     private RedisTemplate redisTemplate;
    10.  
    11.     @Override
    12.     public String login(User user) {
    13.         //使用AuthenticationManager进行用户认证
    14.             //先将用户名和密码封装进authentication对象。
    15.         UsernamePasswordAuthenticationToken authenticationToken=new UsernamePasswordAuthenticationToken(user.getUsername(),user.getPassword());
    16.             //封装完传进来继续调用下一层进行认证。
    17.         Authentication authenticate = authenticationManager.authenticate(authenticationToken);
    18.         //认证没通过，给出相应提示
    19.         if(Objects.isNull(authenticate))
    20.         {
    21.             throw new RuntimeException("登录失败");
    22.         }
    23.         //认证通过，用jwt生成token,将其直接返回。
    24.         LoginUser loginUser = (LoginUser) authenticate.getPrincipal();
    25.         Integer userid=loginUser.getUser().getId();
    26.         String id=userid.toString();
    27.         Map claims = new HashMap<>();
    28.         claims.put("id", id);
    29.         String token = JwtUtil.createJWT(
    30.                 jwtProperties.getSecretKey(),
    31.                 jwtProperties.getTtl(),
    32.                 claims);
    33.         //将完整的用户信息存入redis, id作为key
    34.         updateCache(id,loginUser);
    35.         //返回token给前端
    36.         return token;
    37.     }
    38.     /**
    39.      * 插入和更新缓存数据
    40.      * @param
    41.      */
    42.     private void updateCache(String id,LoginUser loginUser){
    43.         String key="login::"+id;
    44.         redisTemplate.opsForValue().set(key,loginUser);
    45.     }
    46. }

    使用postman测试没有问题 

    redis里面也正常存入数据 

    token认证过滤器实现

    这个自定义token过滤器是最先执行的，然后才到spring security的过滤器链，最后才去到Controller控制器方法里面。

    1. @Component
    2. @Slf4j
    3. //默认的过滤器接口有问题，可能会调用多次，所以这里选择继承类
    4. public class JwtAuthenticationTokenFilter extends OncePerRequestFilter {
    5.     @Autowired
    6.     private JwtProperties jwtProperties;
    7.     @Autowired
    8.     private RedisTemplate redisTemplate;
    9.     @Override
    10.     protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
    11.         //获取token
    12.         String token = request.getHeader("token");
    13.         if(!StringUtils.hasText(token)){
    14.             //放行
    15.             filterChain.doFilter(request,response); //可能是登录也可能不是，需要放行后交给后面去判断。
    16.             return; //这里是为了获取结果返回的时候不往下执行。
    17.         }
    18.         // 解析token
    19.         int id;
    20.         try {
    21.             Claims claims = JwtUtil.parseJWT(jwtProperties.getSecretKey(),token);
    22.              id = Integer.parseInt(claims.get("id").toString());
    23.             log.info("用户id为:{}",id);
    24.         } catch (Exception e) {
    25.             e.printStackTrace();
    26.             throw new RuntimeException(e);
    27.         }
    28.         //从redis获取认证用户信息。
    29.         String redisey="login::"+id;
    30.         LoginUser loginUser=(LoginUser) getValue(redisey);
    31.         System.out.println(loginUser);
    32.         if(Objects.isNull(loginUser)){
    33.             throw new RuntimeException("用户未登录");
    34.         }
    35.         //存入SecurityContextHolder
    36.         //TODO 获取权限信息封装到authentication中
    37.         UsernamePasswordAuthenticationToken authenticationToken =
    38.                 new UsernamePasswordAuthenticationToken(loginUser,null,null);
    39.         SecurityContextHolder.getContext().setAuthentication(authenticationToken);
    40.         //放行
    41.         filterChain.doFilter(request,response);
    42.     }
    43.     private Object getValue(String key){
    44.       return  redisTemplate.opsForValue().get(key);
    45.     }
    46. }

    配置认证过滤器

    上面写好的过滤器要放到过滤器链最前面的位置。

    1. @Configuration
    2. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
    3.  
    4.     @Autowired
    5.     private JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;
    6.     @Bean
    7.     public PasswordEncoder passwordEncoder(){
    8.         return new BCryptPasswordEncoder();
    9.     }
    10.     @Bean
    11.     @Override
    12.     public AuthenticationManager authenticationManager()throws Exception{
    13.         return super.authenticationManager();
    14.     }
    15.  
    16.     @Override
    17.     protected void configure(HttpSecurity http) throws Exception {
    18.             http
    19.                 //关闭csrf
    20.                 .csrf().disable()
    21.                 //不通过Session获取SecurityContext
    22.                 .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
    23.                 .and()
    24.                 .authorizeRequests()
    25.                 // 对于登录接口 允许匿名访问
    26.                 .antMatchers("/user/login").anonymous()
    27.                 // 除上面外的所有请求全部需要鉴权认证
    28.                 .anyRequest().authenticated();
    29.  
    30.             //两个参数，一个是过滤器，一个是要添加之前到的过滤器的字节码对象。
    31.             http.addFilterBefore(jwtAuthenticationTokenFilter,UsernamePasswordAuthenticationFilter.class);
    32.  
    33.     }
    34. }

    退出登录

    获取SecurityContextHolder当中的认证信息，删除redis中对应数据

    Controller中

    1.     @RequestMapping("/user/logout")
    2.     public Result logout(){
    3.         loginService.logout();
    4.         return Result.success();
    5.     }

    Service中

    1.     @Override
    2.     public void logout() {
    3.         //获取SecurityContextHolder中的用户id
    4.         UsernamePasswordAuthenticationToken authentication = (UsernamePasswordAuthenticationToken)SecurityContextHolder.getContext().getAuthentication();
    5.         LoginUser loginUser = (LoginUser)authentication.getPrincipal();
    6.         int id = loginUser.getUser().getId();
    7.         //删除redis中的值
    8.         String key="login::"+id;
    9.         redisTemplate.delete(key);
    10.     }

     先退出再访问正常资源就会爆出之前自定义的异常

    3. 授权

    授权基本流程

    设置资源所需权限

    有基于注解和基于配置两种方法，基于配置的主要用于配置静态资源，在前后端分离项目的后端中已经没有什么静态资源了。

     封装权限信息

    在之前写的jwt的token过滤器里面之前只是封装了用户信息，没有权限信息

    在启动类上加上注解开启注解配置权限

    @EnableGlobalMethodSecurity(prePostEnabled = true)

    这里先用硬编码的方式在Controller方法上加上权限注解

    1.  
    2. @RestController
    3. public class HelloController {
    4.  
    5.     @RequestMapping("/hello")
    6.     @PreAuthorize("hasAuthority('test')") //调用了一个hasAuthority方法，参数是test,返回值是boolean
    7.     public String hello(){
    8.         return "hello security";
    9.     }
    10. }

     在用户信息的封装对象里面加上权限属性数组permissions，authorities是里面的getAuthorities方法是spring Security在进行权限校验时会自动调用的方法的返回值。

    1. @Data
    2. @NoArgsConstructor
    3. public class LoginUser implements UserDetails {
    4.     private User user;
    5.  
    6.     private List permissions;
    7.  
    8.     @JSONField(serialize = false) //这个权限信息不能存进redis,会报错
    9.     private List authorities;
    10.  
    11.     public LoginUser(User user, List permissions) {
    12.         this.user = user;
    13.         this.permissions = permissions;
    14.     }
    15.  
    16.     @Override
    17.     public Collectionextends GrantedAuthority> getAuthorities() {
    18.         //把permissions中String类型的权限信息封装成SimpleGrantedAuthority对象，是GrantedAuthority的一个实现类
    19.  
    20.         if(authorities!=null)
    21.         {
    22.             return authorities;
    23.         }
    24.         //普通实现
    25. //         authorities = new ArrayList<>();
    26. //        for (String permission : permissions) {
    27. //            SimpleGrantedAuthority simpleGrantedAuthority = new SimpleGrantedAuthority(permission);
    28. //            authorities.add(simpleGrantedAuthority);
    29. //        }
    30.         //函数式编程
    31.             authorities = permissions.stream()
    32.                 .map(SimpleGrantedAuthority::new)
    33.                 .collect(Collectors.toList());
    34.         return authorities;
    35.     }
    36.  
    37.     @Override
    38.     public String getPassword() {
    39.         return user.getPassword();
    40.     }
    41.  
    42.     @Override
    43.     public String getUsername() {
    44.         return user.getUsername();
    45.     }
    46.  
    47.     @Override
    48.     public boolean isAccountNonExpired() {
    49.         return true;
    50.     }
    51.  
    52.     @Override
    53.     public boolean isAccountNonLocked() {
    54.         return true;
    55.     }
    56.  
    57.     @Override
    58.     public boolean isCredentialsNonExpired() {
    59.         return true;
    60.     }
    61.  
    62.     @Override
    63.     public boolean isEnabled() {
    64.         return true;
    65.     }
    66. }

     在登录时的最后将权限封装进去。

    1. @Service
    2. public class UserDetailServiceImpl implements UserDetailsService {
    3.  
    4.     @Autowired
    5.     private UserMapper userMapper;
    6.  
    7.     @Override
    8.     public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
    9.         //查询用户信息
    10.         User user=userMapper.selectByUsername(username);
    11.         //如果没有查询到用户就抛出异常。
    12.         if(Objects.isNull(user)){
    13.             throw new RuntimeException("用户不存在或者密码错误");
    14.         }
    15.         //TODO 查询对应的权限信息
    16.         ArrayList strings = new ArrayList<>(Arrays.asList("test", "admin"));
    17.         //把数据封装UserDetail返回
    18.         return new LoginUser(user,strings);
    19.     }
    20. }

    在jwt的token过滤器里面获取权限信息封装到authentication中

     

    测试需要权限的hello接口,成功拿到响应
     

     

    将接口上需要的权限改一改，这次就没有响应了
     

     

    从数据库查询权限信息
     

    RBAC权限模型
     

    RBAC权限模型(Role-Based Access (ontrol) 即:基于色的权限控制。这是目前最常被开发者使用也是相对易用、通用权限模型.
     

    会有一个用户表，一个权限表，还有一个角色表。不同角色对应的权限都在角色权限关联表
     

    用户和角色的表的关联也有一个用户角色关联表
     

     

    好麻烦。不想定义这么多表了。 
     

     

    这里不去实现这部分代码，将来有机会用的时候再来做吧
     

    4.自定义失败处理
     

     

    将springSecurity的过滤器链中出现的异常一起捕获以固定风格的响应传回前端。
     

    用之前准备的工具类帮助解决
     

    1. public class WebUtil {
    2.     public static String readerString(HttpServletResponse response,String string){
    3.         try{
    4.             response.setStatus(200);
    5.             response.setContentType("application/json");
    6.             response.setCharacterEncoding("utf-8");
    7.             response.getWriter().print(string);
    8.         }catch(IOException e){
    9.             e.printStackTrace();
    10.         }
    11.         return null;
    12.     }
    13. }
     

    认证的异常方法
     

    1. @Component
    2. public class AuthenticationEntryPointImpl implements AuthenticationEntryPoint {
    3.  
    4.     @Override
    5.     public void commence(HttpServletRequest request, HttpServletResponse response, AuthenticationException authException) throws IOException, ServletException {
    6.         Result result= Result.error("用户认证失败请查询登录");
    7.         String json = JSON.toJSONString(result);
    8.         //处理异常
    9.         WebUtil.readerString(response,json); //Result风格数据写进response
    10.  
    11.     }
    12. }
     

    授权的异常方法
     

    1. @Component
    2. public class AccessDeniedHandlerImpl implements AccessDeniedHandler {
    3.     @Override
    4.     public void handle(HttpServletRequest request, HttpServletResponse response, AccessDeniedException accessDeniedException) throws IOException, ServletException {
    5.         Result result= Result.error("权限不足");
    6.         String json = JSON.toJSONString(result);
    7.         //处理异常
    8.         WebUtil.readerString(response,json); //Result风格数据写进response
    9.  
    10.     }
    11. }
     

    配置异常处理器
     

    回到WebSecurityConfigurerAdapter里面替换默认的两个异常处理器.
     

    1. @Configuration
    2. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
    3.  
    4.     @Autowired
    5.     private AuthenticationEntryPoint authenticationEntryPoint;
    6.  
    7.     @Autowired
    8.     private AccessDeniedHandler accessDeniedHandler;
    9.     @Autowired
    10.     private JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;
    11.     @Bean
    12.     public PasswordEncoder passwordEncoder(){
    13.         return new BCryptPasswordEncoder();
    14.     }
    15.     @Bean
    16.     @Override
    17.     public AuthenticationManager authenticationManager()throws Exception{
    18.         return super.authenticationManager();
    19.     }
    20.  
    21.     @Override
    22.     protected void configure(HttpSecurity http) throws Exception {
    23.             http
    24.                 //关闭csrf
    25.                 .csrf().disable()//返回一个HttpSecurity对象
    26.                 //不通过Session获取SecurityContext
    27.                 .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
    28.                 .and() //返回一个authorizeRequests对象
    29.                 .authorizeRequests()
    30.                 // 对于登录接口 允许匿名访问
    31.                 .antMatchers("/user/login").anonymous()
    32.                 // 除上面外的所有请求全部需要鉴权认证
    33.                 .anyRequest().authenticated();
    34.  
    35.             //两个参数，一个是过滤器，一个是要添加之前到的过滤器的字节码对象。
    36.             http.addFilterBefore(jwtAuthenticationTokenFilter,UsernamePasswordAuthenticationFilter.class);
    37.  
    38.             //配置异常处理器
    39.             http.exceptionHandling()
    40.                     //配置认证授权失败处理器
    41.                     .authenticationEntryPoint(authenticationEntryPoint)
    42.                     .accessDeniedHandler(accessDeniedHandler);
    43.     }
    44. }
     

    测试两个异常处理器都能正常工作。 
     

     

     

    5. 跨域问题解决
     

    微服务项目下一般使用网关做跨域处理
     

     

    1. @Configuration
    2. public class CorsConfig implements WebMvcConfigurer {
    3.     @Override
    4.     public void addCorsMappings(CorsRegistry registry) {
    5.         //设置运行跨域的路径
    6.         registry.addMapping("/**")
    7.                 //设置允许跨域请求的域名
    8.                 .allowedOriginPatterns("*")
    9.                 //是否允许cookie
    10.                 .allowCredentials(true)
    11.                 //设置允许的请求方式
    12.                 .allowedMethods("GET","POST","DELETE","PUT")
    13.                 //设置允许的header属性
    14.                 .allowedHeaders("*")
    15.                 //跨域允许时间
    16.                 .maxAge(3600);
    17.     }
    18. }
     

     然后在SecurityConfiguration要像自定义的token过滤器和异常处理器一样要进行注册使用。
     

     

    6.其他问题
     

     其它的权限校验方法
     

        @PreAuthorize("hasAuthority('test2222')") //调用了一个hasAuthority方法，参数是test,返回值是boolean

     

     

     hasAnyAuthority方法传的是一个权限的String数组，用户存在任意一个都可以通过认证。hasAuthority方法内部也是调用的上面的方法，只是它只能传一个权限。
     

     

     用法如下
     

        @PreAuthorize("hasAnyAuthority('admin','test')")

     

    hasRole方法和hasAnyRole是联系起来的，分别是单个角色满足和多个角色，满足其一都可以通过认证。然后调用一个hasAnyAuthorityName方法。 
     

     

     hasAnyAuthorityName方法传进去一个默认前缀和定义的权限，需要拼接之后再判断是否有这个权限。默认前缀如下。
     

     
     

     然后就要求访问者的权限集合里面也有对应的前缀，这些前缀一般是代表了角色。
     

    1.     @PreAuthorize("hasRole('test')")
    2.     @PreAuthorize("hasAnyRole('test','admin')")
     

    自定义权限校验方法
     

    在@PreAuthorize方法中返回自定义的权限校验方法，只需要保持方法返回值是true或者false即可
     

    为了能让注解调用到我们自定义的方法，好像要用到一个什么SPEL表达式？
     

    如下定义一个校验方法，从上下文获取用户权限
     

    1. @Component("ex")
    2. public class YHYExpressionRoot {
    3.     public boolean hasAuthority(String authority){
    4.         //获取当前用户权限
    5.         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
    6.         LoginUser  loginUser = (LoginUser)authentication.getPrincipal();
    7.         List permissions = loginUser.getPermissions();
    8.         //判断用户权限集合中是否存在authority
    9.         return permissions.contains(authority);
    10.     }
    11. }
     

    然后 在Controller层里面如下访问。
     

    在SPEL表达式中使用@ex相当于获取容器中名字为ex的bean对象。然后.可以调用对象方法.
     

    1. @RestController
    2. public class HelloController {
    3.  
    4.     @RequestMapping("/hello")
    5.     @PreAuthorize("@ex. hasAuthority('test2222')")
    6.     public String hello(){
    7.         return "hello security";
    8.     }
    9. }
     

    基于配置的权限控制
     

    在WebSecurityConfigurerAdapter类继承类SecurityConfiguration里面进行配置。
     

    先写接口方法的路径，然后再写权限，这里后面调用的方法跟用注解时调用的方法是一模一样的。
     

     

    CSRF
     

     

     什么玩意？
     

    登陆成功处理器
     

     

    前面的代码已经用了自定义的Jwt过滤器完成了用户认证，所以这里就已经不会再执行了这个登录成功处理器了。需要新建一个项目。
     

    1.  
    2. @Component
    3. public class AuthenticationSuccessHandlerImpl implements AuthenticationSuccessHandler {
    4.     @Override
    5.     public void onAuthenticationSuccess(HttpServletRequest request, HttpServletResponse response, Authentication authentication) throws IOException, ServletException {
    6.         System.out.println("认证成功");
    7.     }
    8. }
     

     定义好之后和之前定义的两个异常处理器一样，也要去到WebSecurityConfigurerAdapter进行配置。 
     

    1. @Configuration
    2. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
    3.     @Autowired
    4.     private JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;
    5.  
    6.     @Override
    7.     protected void configure(HttpSecurity http) throws Exception {
    8.             //所有请求都要鉴权认证
    9.         http.authorizeRequests().anyRequest().authenticated();
    10.  
    11.             //配置认证成功处理器
    12.         http.formLogin().successHandler(authenticationSuccessHandler);
    13.     }
    14. }
     

    认证失败处理器
     

     

    和上面流程一模一样 
     

    1. @Component
    2. public class AuthenticationFailureHandlerImpl implements AuthenticationFailureHandler {
    3.     @Override
    4.     public void onAuthenticationFailure(HttpServletRequest request, HttpServletResponse response, AuthenticationException exception) throws IOException, ServletException {
    5.         System.out.println("认证失败");
    6.     }
    7. }
     

    1. @Configuration
    2. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
    3.     @Autowired
    4.     private AuthenticationFailureHandler authenticationFailureHandler;
    5.  
    6.     @Override
    7.     protected void configure(HttpSecurity http) throws Exception {
    8.             //所有请求都要鉴权认证
    9.         http.authorizeRequests().anyRequest().authenticated();
    10.  
    11.             //配置认证成功处理器
    12.         http.formLogin().failureHandler(authenticationFailureHandler);
    13.     }
    14. }
     

    登出成功处理器
     

    一模一样的流程。
     

    1. @Component
    2. public class LogoutSuccessHandlerImpl implements LogoutSuccessHandler {
    3.     @Override
    4.     public void onLogoutSuccess(HttpServletRequest request, HttpServletResponse response, Authentication authentication) throws IOException, ServletException {
    5.         System.out.println("注销成功");
    6.     }
    7. }
     

    1.         //配置注销成功的处理器
    2.         http.logout().logoutSuccessHandler(logoutSuccessHandler);
     

    上面说到的三个处理器都要在使用spring Security的认证方案时才能生效.
     

    其他认证方案畅想
     

    如果还有验证码环节的话可以在最前面再加上一个过滤器。
     

    
                
    
                    
    
                
    • 

                
  • 

                    相关阅读:
    
                    
现阶段的主流数据库分别是哪几种？                            
    
手机app控制esp32-cam拍照上传，tcp和mqtt协议                            
    
实例解读：Python量化分析在投资中的应用                            
    
第五章：抽象类                            
    
Hexagon IDE使用手册 ---创建新项目                            
    
数据库的操作                            
    
vue.js之组件（component）                            
    
从零实现Web框架Geo教程-中间件-05                            
    
php毕业设计美食菜谱网站                            
    
DateUtils 和 CalendarUtil 类来执行日期处理操作使用说明书                            
    
                        
                
    • 
                
  • 
                    原文地址：https://blog.csdn.net/m0_62327332/article/details/133593934
                
    •