通过springboot整合jwt和security,以用户名/密码的方式进行认证和授权。认证通过jwt+数据库的,授权这里使用了两种方式,分别是SpringSecurity自带的hasRole方法+SecurityConfig 和 我们自定义的permission+@PreAuthorize注解。
用来存储和获取当前线程关联的 SecurityContext 对象的类。
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第1张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ku2An95n-1683728698707)(E:/Blog/lansg/source/img/1683186758072-ccd6a67a-c2c5-4ec7-aca3-b42404ce8277.png)],第1张](/upload/website_attach/202312/1_KHQ6GU2WWQNYQP5T.jpeg)
其中有两种 SecurityContext 模式:
表示用户已通过身份验证的最简单方法就是设置 SecurityContextHolder!
用来存储当前已经被认证的用户,包含了当前执行操作的线程上下文信息以及用户认证和授权信息。包含Authentication。
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第2张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-KFfG9auG-1683728698708)(E:/Blog/lansg/source/img/1683186616655-7d1408b0-f5aa-4a06-ae7e-417d63c3fe94.png)],第2张](/upload/website_attach/202312/1_N6PYK6MDFKSS5R57.jpeg)
存储了当前正在执行操作的用户的身份验证信息,包括用户名、密码、权限,可以作为AuthenticationManager的输入,它包含principal、credentials、authorities。
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第3张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Sq1BhhWT-1683728698716)(E:/Blog/lansg/source/img/1683187131663-71356d21-a5e4-498c-b268-0e2620bdd1af.png)],第3张](/upload/website_attach/202312/1_AWTPJRTK483X2424.jpeg)
Authentication 接口的常用实现类有以下几种:
通常情况下,用户在进行登录时需要通过身份验证,当身份验证成功时,就会通过 Authentication 接口封装用户的身份信息。在后续的操作中,认证后的用户可以通过 SecurityContextHolder 获取 Authentication 对象,并根据其中的信息获得用户的身份信息及相应的权限等。
对比SecurityContext和Authentication:
Authentication 是一个封装了用户身份认证信息的对象,表示用户已经通过了验证。
SecurityContext 则是一个上下文类对象,用于保存和获取当前线程关联的上下文信息,包括了 Authentication 对象。
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第4张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-QYXpz36P-1683728698716)(E:/Blog/lansg/source/img/1682596753963-e83a6ebf-2ca0-414c-9601-22ec633c6103.png)],第4张](/upload/website_attach/202312/1_9RP37SX937YMCZG8.jpeg)
定义了用户身份验证的api接口(例如将用户名和密码和数据库进行比对)。可以接收一个Authentication对象作为入参,验证成功后会返回已被验证的Authentication对象。
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第5张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-WR39B9kU-1683728698717)(E:/Blog/lansg/source/img/1683185823144-bb651118-ba37-4d48-a1d1-a3b82875226f.png)],第5张](/upload/website_attach/202312/1_DB475TA3WWBK8JYR.jpeg)
授权信息以GrantedAuthority的形式存储在Authentication对象中,GrantedAuthority接口表示一个授权(权限)对象,包含一个字符串类型的授权名字(authority name)。授权名字通常是一个表示权限的字符串,例如"ROLE_ADMIN"、"ROLE_USER"等
org.springframework.boot spring-boot-starter-web 2.3.12.RELEASE org.springframework.boot spring-boot-starter-security 2.3.12.RELEASE mysql mysql-connector-java 8.0.28 io.jsonwebtoken jjwt 0.9.0 org.mybatis.spring.boot mybatis-spring-boot-starter 1.3.0 
创建一个名为security_jwt_demo的数据库,导入项目根目录下/db/db.sql文件即可。
(1)User实体
对应数据库中的user表
@Data
public class User {
    private Long id;
    private String username;
    private String password;
    private String permission;
    private String role;
    @Override
    public String toString() {
        return "User{" +
        "id=" + id +
        ", username='" + username + '\'' +
        ", password='" + password + '\'' +
        ", permission='" + permission + '\'' +
        ", role='" + role + '\'' +
        '}';
    }
}
 
(2)LoginUser
UserDetails的实现类,使用用户名/密码验证时需要用到其作为返回值。这个类中包含了用户名、密码和当前登录用户所具备的权限。
@Data
public class LoginUser implements UserDetails {
    private Long id;
    private String username;
    private String password;
    //通过自定义方式进行授权
    private Set permissions = new HashSet();
    //通过springSecurity进行授权
    private Collection extends GrantedAuthority> authorities;
    public LoginUser(){}
    public LoginUser(User user,Collection extends GrantedAuthority> authorities) {
        id = user.getId();
        username = user.getUsername();
        password = user.getPassword();
        permissions.add(user.getPermission());
        this.authorities = authorities;
    }
    @Override
    public Collection extends GrantedAuthority> getAuthorities() {
        return authorities;
    }
    @Override
    public String getPassword() {
        return password;
    }
    @Override
    public String getUsername() {
        return username;
    }
    @Override
    public boolean isAccountNonExpired() {
        return true;
    }
    @Override
    public boolean isAccountNonLocked() {
        return true;
    }
    @Override
    public boolean isCredentialsNonExpired() {
        return true;
    }
    @Override
    public boolean isEnabled() {
        return true;
    }
}
   
(3)UserVO
主要用来登录时从输入流中获取登录用户的信息,对应了前端传递的参数,包括用户名、密码、记住我等属性。
@Data
public class UserVO {
    private String username;
    private String password;
    private Integer rememberMe;
}
 
创建mapper接口并配置对应的mapper.xml
@Mapper
public interface UserMapper {
    //根据用户名获取用户
    User getByName(String username);
    //根据用户id获取用户权限
    List getPermissionById(Long id);
    //新增一个用户
    int insertUser(User user);
}
  
首先说一下为什么要实现这两个接口。
SpringSecurity提供了多种身份验证的方式,在这里我们使用的是用户名/密码的方式进行验证,而如果要使用这种方式进行验证的话,我们需要实现UserDetailService接口中的loadUserByUsername方法,这个方法用来从数据库中进行查询用户,然后和传入的用户密码进行比对。这个方法会返回一个UserDetails对象。
@Service
public class UserDetailServiceImpl implements UserDetailsService {
    @Autowired
    UserMapper userMapper;
    @Override
    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
        User user = userMapper.getByName(username);
        List authorities = new ArrayList<>();
        return new LoginUser(user,authorities);
    }
}
  
对于UserDetailService接口,SpringSecurity提供了基于内存和JDBC的两种验证方式,默认是JDBC的方式。我们也可以通过自定义实现UserDetailService接口,来达到自定义身份验证的结果。这里我们使用的是自定义身份验证的方式。
对于UserDetails,在Spring Security中,UserDetails接口是表示用户信息的规范。该接口表示应用程序中的用户,并提供有关用户的基本信息,如用户名、密码、角色、权限等,因此我们需要有一个类似用户的对象来实现该接口(LoginUser)。
检验用户token的过滤器。对于客户端发出的请求,首先对用户的token进行校验,如果token不合法表示当前用户未登录,继续执行其他过滤器的逻辑;如果token合法则设置SecurityContextHolder表示用户已被认证。
/**
 * token过滤器 验证token有效性
 */
@Component
public class JwtAuthenticationTokenFilter extends OncePerRequestFilter {
    @Autowired
    UserMapper userMapper;
    @Override
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain chain) throws ServletException, IOException {
        String token = request.getHeader(JwtTokenUtil.TOKEN_HEADER);
        if (StringUtils.isBlank(token) || !token.startsWith(JwtTokenUtil.TOKEN_PREFIX)){
            chain.doFilter(request,response);
            return;
        }
        try {
            //如果能获取到token则Authentication进行设置,表示已认证
            SecurityContextHolder.getContext().setAuthentication(getAuthentication(token));
        } catch (Exception e) {
            e.printStackTrace();
        }
        //继续执行其他过滤器的逻辑
        chain.doFilter(request,response);
    }
    private UsernamePasswordAuthenticationToken getAuthentication(String tokenHeader) throws Exception {
        String token = tokenHeader.replace(JwtTokenUtil.TOKEN_PREFIX,"");
        //判断token是否过期
        boolean expiration = JwtTokenUtil.isExpiration(token);
        if (expiration){
            throw new Exception("过期了");
        }else{
            String username = JwtTokenUtil.getUsername(token);
            User user = userMapper.getByName(username);
            List permissions = userMapper.getPermissionById(user.getId());
            LoginUser loginUser = new LoginUser(user, Collections.singleton(new SimpleGrantedAuthority(user.getRole())));
            loginUser.setPermissions(new HashSet<>(permissions));
            //新建一个UsernamePasswordAuthenticationToken用来设置Authentication
            UsernamePasswordAuthenticationToken authenticationToken = new UsernamePasswordAuthenticationToken(loginUser, null, loginUser.getAuthorities());
            return authenticationToken;
        }
    }
}
  
用户登录时对用户名密码进行校验的过滤器,在token校验过滤器之后执行。在该过滤器中会对用户名密码进行比对,校验成功后返回一个token给客户端,下次客户端访问时在请求头带上此token代表该用户已经被认证。
public class JWTAuthenticationFilter extends UsernamePasswordAuthenticationFilter {
    private ThreadLocal rememberMe = new ThreadLocal<>();
    private AuthenticationManager authenticationManager;
    public JWTAuthenticationFilter(AuthenticationManager authenticationManager) {
        this.authenticationManager = authenticationManager;
        super.setFilterProcessesUrl("/auth/login");
    }
    @Override
    public Authentication attemptAuthentication(HttpServletRequest request,
 HttpServletResponse response) throws AuthenticationException {
        // 从输入流中获取到登录的信息
        try {
            UserVO vo = new ObjectMapper().readValue(request.getInputStream(), UserVO.class);
            rememberMe.set(vo.getRememberMe() == null ? 0 : vo.getRememberMe());
            return authenticationManager.authenticate(
                    new UsernamePasswordAuthenticationToken(vo.getUsername(), vo.getPassword(), new ArrayList<>())
            );
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }
    // 成功验证后调用的方法
    // 如果验证成功,就生成token并返回
    @Override
    protected void successfulAuthentication(HttpServletRequest request,
                                            HttpServletResponse response,
                                            FilterChain chain,
                                            Authentication authResult) throws IOException, ServletException {
        LoginUser loginUser = (LoginUser) authResult.getPrincipal();
        System.out.println("loginUser:" + loginUser.toString());
        boolean isRemember = rememberMe.get() == 1;
        String role = "";
        String token = JwtTokenUtil.createToken(loginUser.getUsername(), role, isRemember);
        /* 返回创建成功的token
         但是这里创建的token只是单纯的token
         按照jwt的规定,最后请求的时候应该是 `Bearer token`*/
        response.setHeader("token", JwtTokenUtil.TOKEN_PREFIX + token);
    }
    @Override
    protected void unsuccessfulAuthentication(HttpServletRequest request, HttpServletResponse response, AuthenticationException failed) throws IOException, ServletException {
        response.getWriter().write("authentication failed, reason: " + failed.getMessage());
    }
}
  
由于业务逻辑比较简单,我们在service层中主要实现自定义授权的逻辑,用户相关的Service不做实现。
自定义授权的实现如下,首先在数据库的user表中有个string类型的permission字段,代表用户所拥有的权限。在进行授权时检查用户权限属性是否包含该权限,如果包含则表示当前用户具有访问权限。
/**
 * 自定义权限实现,ss取自SpringSecurity首字母
 */
@Service("ss")
public class PermissionService {
    public boolean hasPer(String permission) throws Exception {
        if (StringUtils.isBlank(permission)){
            return false;
        }
        LoginUser loginUser = SecurityUtil.getLoginUser();
        if (loginUser == null || CollectionUtils.isEmpty(loginUser.getPermissions())) {
            return false;
        }
        return loginUser.getPermissions().contains(StringUtils.trim(permission));
    }
}
 
我们用到的Controller主要有两个,一个是用户相关的,一个是进行测试的接口。
对于我们进行授权测试的接口,在使用自定义授权逻辑时(PermissionService),要配合@PreAuthorize注解实现(createJob方法),对应的JobController如下:
@RestController
@RequestMapping("/jobs")
public class JobController {
    @GetMapping("/list")
    public String listJobs(){
        System.out.println("接收到请求...");
        return "展示所有任务";
    }
    //通过PermissionService自定义授权实现
    @PostMapping("/create")
    @PreAuthorize("@ss.hasPer('job:add')")
    public String createJob(){
        return "创建一个新任务";
    }
    //通过SpringSecurity配合用户角色(role字段)实现权限管理
    @DeleteMapping("/delete")
    public String deleteJob(){
        return "删除一个任务";
    }
}
 
对于用户相关的Controller,我们只需要写一个注册方法就行了,如下所示:
@RestController
@RequestMapping("/")
public class UserController {
    @Autowired
    UserMapper userMapper;
    @Autowired
    private BCryptPasswordEncoder bCryptPasswordEncoder;
    @PostMapping("/register")
    public String register(@RequestBody Map registerUser){
        User user = new User();
        user.setUsername(registerUser.get("username"));
        //对密码进行一下加密
        user.setPassword(bCryptPasswordEncoder.encode(registerUser.get("password")));
        user.setPermission(registerUser.get("permission"));
        user.setRole(registerUser.get("role"));
        userMapper.insertUser(user);
        return user.toString();
    }
}
  
为什么不需要注册接口呢?是因为UsernamePasswordAuthenticationFilter已经帮我们实现了,默认是"/login"
 public UsernamePasswordAuthenticationFilter() {
        super(new AntPathRequestMatcher("/login", "POST"));
 }
 
这里我们也可以对这个路径进行修改,如下所示:
public JWTAuthenticationFilter(AuthenticationManager authenticationManager) {
        this.authenticationManager = authenticationManager;
        super.setFilterProcessesUrl("/auth/login");
    }
 
@EnableWebSecurity
@EnableGlobalMethodSecurity(prePostEnabled = true, securedEnabled = true)
public class SecurityConfig extends WebSecurityConfigurerAdapter {
    @Autowired
    JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;
    @Autowired
    @Qualifier("userDetailServiceImpl")
    UserDetailsService userDetailsService;
    @Override
    protected void configure(AuthenticationManagerBuilder auth) throws Exception {
        auth.userDetailsService(userDetailsService).passwordEncoder(bCryptPasswordEncoder());
    }
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http.cors().and().csrf().disable()
                .authorizeRequests()
                // 测试用资源,需要验证了的用户才能访问
                .antMatchers("/jobs/create").authenticated()
                //只有角色为admin的用户才能进行删除
                .antMatchers(HttpMethod.DELETE,"/jobs/delete").hasRole("ADMIN")
                // 其他请求都放行了
                .anyRequest().permitAll()
                .and()
                .addFilter(new JWTAuthenticationFilter(authenticationManager()))
                // 不需要session
                .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS);
        //将验证token的过滤器添加在验证用户名/密码的过滤器之前
        http.addFilterBefore(jwtAuthenticationTokenFilter, UsernamePasswordAuthenticationFilter.class);
    }
    @Bean
    public BCryptPasswordEncoder bCryptPasswordEncoder(){
        return new BCryptPasswordEncoder();
    }
    @Bean
    CorsConfigurationSource corsConfigurationSource(){
        final UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
        source.registerCorsConfiguration("/**",new CorsConfiguration().applyPermitDefaultValues());
        return source;
    }
}
 
到这里就全部完成了!让我们测试一下是否生效。
这是数据库表中原有的角色和权限:
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第6张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-0JtYIvnH-1683728698719)(E:/Blog/lansg/source/img/1683636702501-c242eb5e-150e-48f5-beca-166924abe01a.png)],第6张](/upload/website_attach/202312/1_UZFFPTQVRQNJTT93.jpeg)
(1)测试注册接口
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第7张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-4mvIG40y-1683728698721)(E:/Blog/lansg/source/img/1683636954282-56cc4d01-6164-4771-b6a1-02c010fee425.png)],第7张](/upload/website_attach/202312/1_6Q8MPHGU3Q3JM94F.jpeg)
可以看到是可以注册成功的,但是我们这里使用原有user1和user2进行权限测试(偷个懒)
(2)测试登录接口
由于我们之前将原有的登录接口从"/login"改为了"/auth/login",这里需要注意一下。

登录成功后的ResponseBody是空的,响应头中有token代表已经登录成功了。我们需要从header中获取该token,后续请求需要用到。这里展示了user2,user1也是一样的。

(3)测试创建任务接口
由于创建任务需要"job:add"权限,查看数据库user2是有该权限的,user1没有。
将刚才登录获得的token添加到参数中:
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第10张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-oOjDHBzl-1683728698724)(E:/Blog/lansg/source/img/1683637556009-f3cff5ff-c893-422a-b9ae-d08c0a488fd4.png)],第10张](/upload/website_attach/202312/1_8H9ESPGK76P5G8ES.jpeg)
然后发现就可以创建成功了
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第11张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-K4AJuwqQ-1683728698724)(E:/Blog/lansg/source/img/1683637594756-d709ce9f-e49e-43cc-915b-fa4ec4e9d364.png)],第11张](/upload/website_attach/202312/1_BJPM2MFHR6BRNAAE.jpeg)
(4)测试删除任务接口
删除任务需要用户角色是admin,故user2是无法进行删除的。
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第12张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-tyZxB5B4-1683728698724)(E:/Blog/lansg/source/img/1683637814101-38f69b2e-6fa6-453d-a93c-b12e98ad19c7.png)],第12张](/upload/website_attach/202312/1_TWJUAPFKPFCVDFKF.jpeg)
(5)我们按照刚才的流程对user1进行测试,来达到对比的效果。
登录:
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第13张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ygIoWd5M-1683728698725)(E:/Blog/lansg/source/img/1683637914205-3ef6c94a-5ea1-4b9d-b1de-235c4124e4b6.png)],第13张](/upload/website_attach/202312/1_YBXTQEZ8T55GV866.jpeg)
创建任务:
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第14张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-CDLqneig-1683728698725)(E:/Blog/lansg/source/img/1683637963713-8d5e8c22-0066-46b9-b832-fec0f11131f2.png)],第14张](/upload/website_attach/202312/1_WHM9Z9MQEAY74J6D.jpeg)
删除任务:
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第15张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-UhXIA5ig-1683728698726)(E:/Blog/lansg/source/img/1683637995825-0eaece05-3b8a-4550-ae3e-2d48ffdbdd44.png)],第15张](/upload/website_attach/202312/1_PEA4DWA3K39KPHHE.jpeg)
对于查询接口不需要进行认证和授权,也就是说不需要登录就能访问:
![SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),第16张 SpringSecurity实现角色权限控制(SpringBoot+SpringSecurity+JWT),[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-OmM2PU5b-1683728698726)(E:/Blog/lansg/source/img/1683638099590-2d7d7935-003d-4367-8cbd-9ef211706413.png)],第16张](/upload/website_attach/202312/1_MCDBTCQRRCXHQPG9.jpeg)
源码地址:https://github.com/Rancho-7/SpringSecurity-JWT