要对Web资源进行保护,最好的办法莫过于Filter
要想对方法调用进行保护,最好的办法莫过于AOP。
Spring Security进行认证和鉴权的时候,就是利用的一系列的Filter来进行拦截的。

如图所示,一个请求想要访问到API就会从左到右经过蓝线框里的过滤器,其中绿色部分是负责认证的过滤器,蓝色部分是负责异常处理,橙色部分则是负责授权。进过一系列拦截最终访问到我们的API。

这里面我们只需要重点关注两个过滤器即可:
UsernamePasswordAuthenticationFilter负责登录认证,
FilterSecurityInterceptor负责权限授权。
一般Web应用的需要进行认证和授权。
认证(Authentication):验证当前访问系统的是不是本系统的用户,并且要确认具体是哪个用户
授权(Authorization):经过认证后判断当前用户是否有权限进行某个操作
而认证和授权就是SpringSecurity作为安全框架的核心功能。

说明:Spring Security的核心逻辑全在这一套过滤器中,过滤器里会调用各种组件完成功能,掌握了这些过滤器和组件你就掌握了Spring Security!这个框架的使用方式就是对这些过滤器和组件进行扩展。
此步骤省略
建议整合knif4j方便调试

访问接口文档:http://localhost:8081/doc.html(端口为自己设置的端口,默认是8080)

springboot工程搭建完成
org.springframework.boot spring-boot-starter-security
这时我们可以看到当我们访问我们的接口的时候,就会自动跳转到一个SpringSecurity的默认登陆页面(后期是需要整合到自己系统的登录页面来做认证)
这时候需要我们登录才可以进行访问,我们可以看到控制台有一串字符串,其实那就是SpringSecurity初始化生成给我的密码

用户名默认为 :user
密码在控制台打印出来了

输入用户和密码登录后,就可以正常访问接口了

核心是通过用户输入的用户名和密码去和数据库中的数据进行比对,如果比对无误
那么就会使用jwt工具根据用户名和密码去生成一个token传给前端存储起来
在登录过后用户想要访问别的资源都要在请求头里面携带token,后端会对前端请求的token拿到并且解析出来用户的id
根据用户的id获取相关的信息,来判断用户是否有访问资格,如果有,则访问目标资源返回给前端,若没有,则返回错误信息(无权限访问)

前后端进行认证的流程:

具体流程:

在上面的案例整合springSecurity,进入默认的登录页面进行登录的时候,是查询内存中的用户名和密码的,后期我们做项目肯定是要改成去数据库里面查询用户名和密码比对
其中:
Authentication接口:它的实现类,表示当前访问系统的用户,封装了用户相关信息。
AuthenticationManager接口:定义了认证Authentication的方法。
UserDetailsService接口:加载用户特定数据的核心接口。里面定义了一个根据用户名查询用户信息的方法。
UserDetails接口:提供核心用户信息。通过UserDetailsService根据用户名获取处理的用户信息要封装成UserDetails对象返回。然后将这些信息封装到Authentication对象中。
登录流程:

校验流程:
获取token,解析token获取到其中的userId;
根据userId,从redis中获取用户信息,存入SecurityContextHolder。

准备工作:
1. 引入依赖(jjwt、reids、fastjson,mysql,mybatis-plus)
org.springframework.boot spring-boot-starter-data-redis com.alibaba.fastjson2 fastjson2 2.0.25 io.jsonwebtoken jjwt 0.9.1 com.baomidou mybatis-plus-boot-starter 3.4.2 mysql mysql-connector-java
2. 添加相关配置
redis建议直接使用stringRedisTemplate,如果使用redisTemplate需要对数据进行序列化做相关的配置
参考链接:redisTemplate和stringRedisTemplate对比、redisTemplate几种序列化方式比较
因为是前后端分离,所以需要一统一结果返回类 R类(不唯一能用就行)
@Data public class Rimplements Serializable { private Integer code; //编码:1成功,0和其它数字为失败 private String msg; //错误信息 private T data; //数据 private Map map = new HashMap(); //动态数据 public static R success(T object) { R r = new R (); r.data = object; r.code = 1; return r; } public static R success(String msg,T object) { R r = new R (); r.data = object; r.code = 1; r.msg = msg; return r; } public static R error(String msg) { R r = new R(); r.msg = msg; r.code = 0; return r; } public static R success(String msg) { R r = new R(); r.msg = msg; r.code = 1; return r; } public R add(String key, Object value) { this.map.put(key, value); return this; } }
导入jwt工具类
/**
* JWT工具类
*/
public class JwtUtil {
//有效期为
public static final Long JWT_TTL = 60 * 60 *1000L;// 60 * 60 *1000 一个小时
//设置秘钥明文
public static final String JWT_KEY = "qx";
public static String getUUID(){
String token = UUID.randomUUID().toString().replaceAll("-", "");
return token;
}
/**
* 生成jtw jwt加密
* @param subject token中要存放的数据(json格式)
* @return
*/
public static String createJWT(String subject) {
JwtBuilder builder = getJwtBuilder(subject, null, getUUID());// 设置过期时间
return builder.compact();
}
/**
* 生成jtw jwt加密
* @param subject token中要存放的数据(json格式)
* @param ttlMillis token超时时间
* @return
*/
public static String createJWT(String subject, Long ttlMillis) {
JwtBuilder builder = getJwtBuilder(subject, ttlMillis, getUUID());// 设置过期时间
return builder.compact();
}
/**
* 创建token jwt加密
* @param id
* @param subject
* @param ttlMillis
* @return
*/
public static String createJWT(String id, String subject, Long ttlMillis) {
JwtBuilder builder = getJwtBuilder(subject, ttlMillis, id);// 设置过期时间
return builder.compact();
}
private static JwtBuilder getJwtBuilder(String subject, Long ttlMillis, String uuid) {
SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256;
SecretKey secretKey = generalKey();
long nowMillis = System.currentTimeMillis();
Date now = new Date(nowMillis);
if(ttlMillis==null){
ttlMillis=JwtUtil.JWT_TTL;
}
long expMillis = nowMillis + ttlMillis;
Date expDate = new Date(expMillis);
return Jwts.builder()
.setId(uuid) //唯一的ID
.setSubject(subject) // 主题 可以是JSON数据
.setIssuer("sg") // 签发者
.setIssuedAt(now) // 签发时间
.signWith(signatureAlgorithm, secretKey) //使用HS256对称加密算法签名, 第二个参数为秘钥
.setExpiration(expDate);
}
public static void main(String[] args) throws Exception {
//jwt加密
String jwt = createJWT("123456");
//jwt解密
Claims claims = parseJWT(jwt);
String subject = claims.getSubject();
System.out.println(subject);
System.out.println(jwt);
}
/**
* 生成加密后的秘钥 secretKey
* @return
*/
public static SecretKey generalKey() {
byte[] encodedKey = Base64.getDecoder().decode(JwtUtil.JWT_KEY);
SecretKey key = new SecretKeySpec(encodedKey, 0, encodedKey.length, "AES");
return key;
}
/**
* jwt解密
*
* @param jwt
* @return
* @throws Exception
*/
public static Claims parseJWT(String jwt) throws Exception {
SecretKey secretKey = generalKey();
return Jwts.parser()
.setSigningKey(secretKey)
.parseClaimsJws(jwt)
.getBody();
}
}
导入实体类
/**
* 用户表(User)实体类
*
*
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("sys_user")
public class User implements Serializable {
private static final long serialVersionUID = -40356785423868312L;
/**
* 主键
*/
@TableId
private Long id;
/**
* 用户名
*/
private String userName;
/**
* 昵称
*/
private String nickName;
/**
* 密码
*/
private String password;
/**
* 账号状态(0正常 1停用)
*/
private String status;
/**
* 邮箱
*/
private String email;
/**
* 手机号
*/
private String phonenumber;
/**
* 用户性别(0男,1女,2未知)
*/
private String sex;
/**
* 头像
*/
private String avatar;
/**
* 用户类型(0管理员,1普通用户)
*/
private String userType;
/**
* 创建人的用户id
*/
private Long createBy;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新人
*/
private Long updateBy;
/**
* 更新时间
*/
private Date updateTime;
/**
* 删除标志(0代表未删除,1代表已删除)
*/
private Integer delFlag;
}
数据库建表并且配置数据库
CREATE TABLE `sys_user` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键', `user_name` varchar(64) NOT NULL DEFAULT 'NULL' COMMENT '用户名', `nick_name` varchar(64) NOT NULL DEFAULT 'NULL' COMMENT '昵称', `password` varchar(64) NOT NULL DEFAULT 'NULL' COMMENT '密码', `status` char(1) DEFAULT '0' COMMENT '账号状态(0正常 1停用)', `email` varchar(64) DEFAULT NULL COMMENT '邮箱', `phonenumber` varchar(32) DEFAULT NULL COMMENT '手机号', `sex` char(1) DEFAULT NULL COMMENT '用户性别(0男,1女,2未知)', `avatar` varchar(128) DEFAULT NULL COMMENT '头像', `user_type` char(1) NOT NULL DEFAULT '1' COMMENT '用户类型:1代表普通用户,0代表管理员', `create_by` bigint(20) DEFAULT NULL COMMENT '创建人的用户id', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` bigint(20) DEFAULT NULL COMMENT '更新人', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `del_flag` int(11) DEFAULT '0' COMMENT '删除标志(0代表未删除,1代表已删除)', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=14787164048663 DEFAULT CHARSET=utf8mb4 COMMENT='用户表';
datasource:
druid:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/security?characterEncoding=utf-8&useSSL=false
username: root
password: root
定义mapper、service、serviceImpl并测试mapper能正常使用
省略(可以使用代码生成器)

- 这里只是查了用户信息,对于用户权限还没有查(这部分是属于授权部分的内容),因为最后是把用户信息和权限信息封装成UserDetails进行返回的
@Service
public class UserDetailsServiceImpl implements UserDetailsService {
@Autowired
private UserService userService;
@Override
public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
//查询用户信息
User user = userService.getOne(new LambdaUpdateWrapper().eq(User::getUserName, username));
//如果没有查询到用户就抛出异常
if (Objects.isNull(user)) {
throw new CustomException("用户名或密码错误");
}
//TODO 查询对应的权限信息
//把数据封装成UserDetails返回
return new LoginUser(user);
}
}
自定义一个实现UserDetails的(LoginUser)类,实现接口的方法;用来接收存储数据(用户信息和权限信息)
@Data
@NoArgsConstructor
@AllArgsConstructor
public class LoginUser implements UserDetails {
private User user;
//这里先不管权限信息这个集合
@Override
public Collection extends GrantedAuthority> getAuthorities() {
return null;
}
//获取用户的用户的密码
@Override
public String getPassword() {
return user.getPassword();
}
@Override
public String getUsername() {
return user.getUserName();
}
@Override
public boolean isAccountNonExpired() {
return true;
}
@Override
public boolean isAccountNonLocked() {
return true;
}
@Override
public boolean isCredentialsNonExpired() {
return true;
}
@Override
public boolean isEnabled() {
return true;
}
}
此次再次启动服务访问任意接口:(这个时候走的就是查我们自己的数据库了,可以在实现类里面打断点测试)
此时后端控制台就不会打印出在内存中的密码了,因为我们重写了UserDetailsService 接口的loadUserByUsername,程序走我们自己的方法。

注意:点击登录后,这里会出现一个问题

当输入正确的用户名和密码还是会显示密码错误
控制台打印的错误信息可以看出


处理办法:在 Spring Security 中,{noop} 前缀告诉系统直接将密码存储为明文,即未经过哈希或其他加密算法处理。

再次登录测试:能够成功访问接口方法
默认使用的PasswordEncoder要求数据库中的密码格式为:{id}password,它会根据id去判断密码的加密方式。但是我们一般不会采用这种方式,所以需要替换PasswordEncoder。\
我们可以定义一个SpringSecurity的配置类,SpringSecurity要求这个配置类要继承WebSecurityConfigurerAdapter。
@Configuration
public class SecurityConfig extends WebSecurityConfigurerAdapter {
//创建BCryptPasswordEncoder注入容器
@Bean
public PasswordEncoder passwordEncoder(){
return new BCryptPasswordEncoder();
}
}
相当于将原来的PasswordEncoder 中的方法覆盖掉,转而执行BCryptPasswordEncoder中的方法
其中BCryptPasswordEncoder对象中的三个方法分别作用是:

这个时候数据库里面的用户密码必须是加密过的密码,这样在进行认证的时候,根据用户名查询到加密的密码,然后再根据passwordEncoder中的密码匹配方法来判断密码是否正确。(若数据库还是明文密码,那么肯定是会密码错误认证失败的)
咱可以先把数据库的明文密码加密放回原用户:(编写Test方法加密用户密码)
@Test
public void testPasswordEncoder() {
BCryptPasswordEncoder passwordEncoder = new BCryptPasswordEncoder();
String encode = passwordEncoder.encode("123456");
System.out.println(encode);
}
得到加密的密码填入数据库:


重启系统登录测试,登陆成功,正常访问接口
其实质就是不让登录走整合SpringSecurity默认的登录页面了,而是走我们自己定义的登录接口
接下我们需要自定义登陆接口,然后让SpringSecurity对这个接口放行,让用户访问这个接口的时候不用登录也能访问。
在接口中我们通过AuthenticationManager的authenticate方法来进行用户认证,所以需要在SecurityConfig中配置把AuthenticationManager注入容器。
认证成功的话要生成一个jwt,放入响应中返回。并且为了让用户下回请求时能通过jwt识别出具体的是哪个用户,我们需要把用户信息存入redis,可以把用户id作为key。
创建LoginController 登录接口
@RestController
@RequestMapping("/user")
public class LoginController {
@Autowired
private LoginService loginService;
@PostMapping("/login")
public R login(@RequestBody User user){
return loginService.login(user);
}
那么我们可以在loginService实现类中编写login方法
其中验证是通过通过AuthenticationManager的authenticate方法来进行用户认证,需要在SecurityConfig中配置把AuthenticationManager注入容器
并且进行一个configure的配置才能使用
·SecurityConfig·
@Configuration
public class SecurityConfig extends WebSecurityConfigurerAdapter {
//创建BCryptPasswordEncoder注入容器
@Bean
public PasswordEncoder passwordEncoder(){
return new BCryptPasswordEncoder();
}
//把AuthenticationManager注入容器
@Bean
@Override
public AuthenticationManager authenticationManagerBean() throws Exception {
return super.authenticationManagerBean();
}
}
@Override
protected void configure(HttpSecurity http) throws Exception {
http
//关闭csrf
.csrf().disable()
//不通过Session获取SecurityContext
.sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
.and()
.authorizeRequests()
// 对于登录接口 允许匿名访问
.antMatchers("/user/login").anonymous()
// 除上面外的所有请求全部需要鉴权认证
.anyRequest().authenticated();
}
这个时候就可以编写登录接口了
2.AuthenticationManager委托机制对authenticationToken 进行用户认证
此时只有用户信息,还没有包括权限信息,后续授权会完善
@Service
public class LoginServiceImpl implements LoginService {
@Autowired
private UserService userService;
//认证委托
@Autowired
private AuthenticationManager authenticationManager;
@Autowired
private StringRedisTemplate redisTemplate;
@Override
public R login(User user) {
//通过UsernamePasswordAuthenticationToken获取用户名和密码
UsernamePasswordAuthenticationToken authenticationToken=new UsernamePasswordAuthenticationToken
(user.getUserName(),user.getPassword());
//AuthenticationManager委托机制对authenticationToken 进行用户认证
Authentication authenticate = authenticationManager.authenticate(authenticationToken);
//如果认证没有通过,给出对应的提示
if (Objects.isNull(authenticate)){
throw new RuntimeException("登录失败");
}
//如果认证通过,使用user生成jwt jwt存入R 返回
//如果认证通过,拿到这个当前登录用户信息
LoginUser loginUser = (LoginUser) authenticate.getPrincipal();
//获取当前用户的userid
String userid = loginUser.getUser().getId().toString();
String jwt = JwtUtil.createJWT(userid);
Map map = new HashMap<>();
map.put("token",jwt);
//把完整的用户信息存入redis userid为key 用户信息为value
将对象转换为 JSON 字符串 存入redis
String jsonString = JSONUtil.toJsonStr(loginUser);
redisTemplate.opsForValue().set("login"+userid, jsonString );
return R.success("登陆成功",map);
}
}
重启服务进行登录测试(建议打断点一步步测试数据)
这里我们用postman进行登录测试
user/login被放行,可以不用登录认证直接访问

输入url:localhost:8081/user/login
通过json传输用户信息

结果返回:

并且查看reids
此时认证成功~
我们需要自定义一个过滤器,这个过滤器会去获取请求头中的token,对token进行解析取出其中的userid。
使用userid去redis中获取对应的LoginUser对象。然后封装Authentication对象存入SecurityContextHolder
定义过滤类:JwtAuthenticationTokenFilter
流程:
封装Authentication对象:包括两部分
@Component
public class JwtAuthenticationTokenFilter extends OncePerRequestFilter {
@Autowired
private StringRedisTemplate redisTemplate;
@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
//从前端发起请求的请求头获取token
String token = request.getHeader("token");
if (!StringUtils.hasText(token)) {
//放行
filterChain.doFilter(request, response);
return;
}
//解析token
String userid;
try {
Claims claims = JwtUtil.parseJWT(token);
userid = claims.getSubject();
} catch (Exception e) {
e.printStackTrace();
throw new CustomException("token非法");
}
//从redis中获取用户信息
String redisKey = "login:" + userid;
//将json转换为对象类
String json = redisTemplate.opsForValue().get(redisKey);
LoginUser loginUser = JSONUtil.toBean(json, LoginUser.class);
if(Objects.isNull(loginUser)){
throw new RuntimeException("用户未登录");
}
//封装Authentication对象存入SecurityContextHolder
//TODO 获取权限信息封装到Authentication中
UsernamePasswordAuthenticationToken authenticationToken =
new UsernamePasswordAuthenticationToken(loginUser,null,null);
SecurityContextHolder.getContext().setAuthentication(authenticationToken);
//放行
filterChain.doFilter(request, response);
}
}
把token校验过滤器添加到过滤器链中(注入到配置类(SecurityConfig)加入过滤器链)
//把token校验过滤器注入配置类
@Autowired
JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;
//把token校验过滤器添加到过滤器链中并且添加到UsernamePasswordAuthenticationFilter之前
http.addFilterBefore(jwtAuthenticationTokenFilter, UsernamePasswordAuthenticationFilter.class);
@Configuration
public class SecurityConfig extends WebSecurityConfigurerAdapter {
//创建BCryptPasswordEncoder注入容器
@Bean
public PasswordEncoder passwordEncoder(){
return new BCryptPasswordEncoder();
}
//把AuthenticationManager注入容器
@Bean
@Override
public AuthenticationManager authenticationManagerBean() throws Exception {
return super.authenticationManagerBean();
}
//把token校验过滤器注入配置类
@Autowired
JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;
@Override
protected void configure(HttpSecurity http) throws Exception {
http
//关闭csrf
.csrf().disable()
//不通过Session获取SecurityContext
.sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
.and()
.authorizeRequests()
// 对于登录接口 允许匿名访问
.antMatchers("/user/login").anonymous()
// 除上面外的所有请求全部需要鉴权认证
.anyRequest().authenticated();
//把token校验过滤器添加到过滤器链中
http.addFilterBefore(jwtAuthenticationTokenFilter, UsernamePasswordAuthenticationFilter.class);
}
}
测试:
测试1:不登录直接访问:访问路径localhost:8081/ayo/coo

断点调试JwtAuthenticationTokenFilter:

测试2:登录后设置请求头(登录生成的token)再次访问 :访问路径localhost:8081/ayo/coo
记录登录成功的token值

在访问路径localhost:8081/ayo/coo时,在请求头加上登录过后生成的token

此时断点调试JwtAuthenticationTokenFilter:成功从请求头拿到token

然后根据token解析到用户的id(userId),根据userId从redis取出用户的信息,然后将用户的信息(和权限信息)封装成Authentication对象存入SecurityContextHolder
SecurityContextHolder 类提供了一种方便的方式来获取当前用户的安全信息,如身份验证信息和角色信息。它是一个线程本地的存储,可以在应用程序的不同层级中访问

返回此次调用接口的数据:

流程:
SecurityContextHolder.getContext().setAuthentication(authenticationToken);
- 从SecurityContextHolder中获取用户的userid
- 根据userid找到redis对应值进行删除
controller层
@GetMapping("/logout")
public R login(){
return loginService.logout();
}
service实现类:
/**
* 注销接口
* @return
*/
@Override
public R logout() {
//从SecurityContextHolder中的userid
UsernamePasswordAuthenticationToken authentication =
(UsernamePasswordAuthenticationToken)
SecurityContextHolder.getContext().getAuthentication();
LoginUser loginUser = (LoginUser) authentication.getPrincipal();
Long userid = loginUser.getUser().getId();
//根据userid找到redis对应值进行删除
redisTemplate.delete("login:"+userid);
return R.success("注销成功");
}
其中的核心是通过过滤器将用户的userId放入SecurityContextHolder中中了,在注销登录的时候可以直接拿到userId再去删除redis中的token信息

注意:这个时候再去访问其他接口的时候,发送过来的请求的请求头所携带的还是之前的登录时的token,这个时候进入过滤器的时候可以根据token获得用户的userId,但是在根据userId去redis获得用户信息的时候是获取不到的(注销的时候已经删除该用户对应的信息),抛出未登录异常.


控制台报错:

权限系统的作用:让不同的用户可以使用不同的功能。
实现:不能只依赖前端去判断用户的权限来选择显示哪些菜单哪些按钮。因为让前端判断权限,别人可以根据对应功能的接口地址,直接发送请求来实现相关的操作。
所以,我们还需要在后台进行用户权限的判断,判断当前用户是否有响应的权限,必须具有所需权限才能进行相应的操作。
在SpringSecurity中,会使用默认的FilterSecurityInterceptor来进行权限校验。在FilterSecurityInterceptor中,会从SecurityContextHolder获取其中的Authentication,然后获取其中的权限信息。当前用户是否拥有访问当前资源所需的权限。
所以我们在项目中需要把当前登录用户的权限信息也存入Authentication,然后设置我们的资源所需要的权限即可。
SpringSecurity为我们提供了基于注解的权限控制方案,这也是我们项目中主要采用的方式,我们可以使用注解去指定访问对应的资源所需的权限。
使用前先在SpringSecurity配置类上开启相关配置
@EnableGlobalMethodSecurity(prePostEnabled = true)
这样就代表开启了使用注解去指定访问权限的功能,例如:
@ApiOperation(value = "权限测试接口")
@PreAuthorize("hasAuthority('tset')")
@GetMapping("/auth")
public R auth(){
return R.success("权限测试接口访问成功");
}
@PreAuthorize(“hasAuthority(‘tset’)”) 的含义是只有具有 "tset" 权限的用户才能够调用被注解的方法。
hasAuthority() 是 Spring Security 提供的一个表达式,用于检查用户是否具有指定的权限。在这种情况下,只有当用户拥有 "tset" 权限(权限名称为 "tset")时,才能访问被注解的方法。
封装权限信息的步骤
这里的权限信息集合我们先写死成“test”(后续是从数据库根据用户查出来的权限信息集合)
此时LoginUser需要封装user和AuthList两个对象,所以需要改造登录封装类LoginUser

改造登录封装类LoginUser

小细节:因为将数据存到redis是会序列化的,但是SimpleGrantedAuthority序列化会报错,所以,存入权限信息的时候存入permissions就可以了(string类型)
使用注解 @JSONField(serialize = false) 让其不序列化


断点测试:
reids数据如下:
这里为什么redis显示authorities没有数据呢,其实数据已经存进去了,只是在属性上加上了注解@JSONField(serialize = false)使其不序列化展示出来,数据还是有的

访问带权限的接口时:


能够成功访问:

同理:如果这个controller设置的权限,通过不了框架的授权验证,肯定是不能访问的,会报错。
、、、、、、、、更新中
因为之前实现授权,是将权限集合写死了,我们通常在项目中,权限应该是从数据库根据用户对应的角色中查出来的,如下图:

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

需要设置角色表、权限表,以及用户角色关联表,角色权限关联表

CREATE TABLE `sys_user` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键', `user_name` varchar(64) NOT NULL DEFAULT 'NULL' COMMENT '用户名', `nick_name` varchar(64) NOT NULL DEFAULT 'NULL' COMMENT '昵称', `password` varchar(64) NOT NULL DEFAULT 'NULL' COMMENT '密码', `status` char(1) DEFAULT '0' COMMENT '账号状态(0正常 1停用)', `email` varchar(64) DEFAULT NULL COMMENT '邮箱', `phonenumber` varchar(32) DEFAULT NULL COMMENT '手机号', `sex` char(1) DEFAULT NULL COMMENT '用户性别(0男,1女,2未知)', `avatar` varchar(128) DEFAULT NULL COMMENT '头像', `user_type` char(1) NOT NULL DEFAULT '1' COMMENT '用户类型:1代表普通用户,0代表管理员', `create_by` bigint(20) DEFAULT NULL COMMENT '创建人的用户id', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` bigint(20) DEFAULT NULL COMMENT '更新人', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `del_flag` int(11) DEFAULT '0' COMMENT '删除标志(0代表未删除,1代表已删除)', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=14787164048663 DEFAULT CHARSET=utf8mb4 COMMENT='用户表'; CREATE TABLE `sys_menu` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '菜单ID', `menu_name` varchar(50) NOT NULL COMMENT '菜单名称', `path` varchar(200) DEFAULT '' COMMENT '路由地址', `component` varchar(255) DEFAULT NULL COMMENT '组件路径', `visible` char(1) DEFAULT '0' COMMENT '菜单状态(0显示 1隐藏)', `status` char(1) DEFAULT '0' COMMENT '菜单状态(0正常 1停用)', `perms` varchar(100) DEFAULT NULL COMMENT '权限标识', `icon` varchar(100) DEFAULT '#' COMMENT '菜单图标', `create_by` bigint(20) DEFAULT NULL COMMENT '创建者', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` bigint(20) DEFAULT NULL COMMENT '更新者', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `remark` varchar(500) DEFAULT '' COMMENT '备注', `del_flag` int(11) DEFAULT '0' , PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2029 DEFAULT CHARSET=utf8mb4 COMMENT='菜单权限表'; CREATE TABLE `sys_role` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '角色ID', `name` varchar(128) DEFAULT NULL COMMENT '角色名称', `role_key` varchar(100) DEFAULT NULL COMMENT '角色权限字符串', `status` char(1) NOT NULL COMMENT '角色状态(0正常 1停用)', `del_flag` int(1) DEFAULT '0' COMMENT '删除标志(0代表存在 1代表删除)', `create_by` bigint(20) DEFAULT NULL COMMENT '创建者', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_by` bigint(20) DEFAULT NULL COMMENT '更新者', `update_time` datetime DEFAULT NULL COMMENT '更新时间', `remark` varchar(500) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COMMENT='角色信息表'; CREATE TABLE `sys_role_menu` ( `role_id` bigint(200) NOT NULL AUTO_INCREMENT COMMENT '角色ID', `menu_id` bigint(200) NOT NULL DEFAULT '0' COMMENT '菜单ID', PRIMARY KEY (`role_id`,`menu_id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COMMENT='角色和菜单关联表'; CREATE TABLE `sys_user_role` ( `user_id` bigint(200) NOT NULL AUTO_INCREMENT COMMENT '用户ID', `role_id` bigint(200) NOT NULL DEFAULT '0' COMMENT '角色ID', PRIMARY KEY (`user_id`,`role_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户和角色关联表';
导入菜单实体类:
/**
* 菜单表(Menu)实体类
*
*/
@TableName(value="sys_menu")
@Data
@AllArgsConstructor
@NoArgsConstructor
@JsonInclude(JsonInclude.Include.NON_NULL)
public class Menu implements Serializable {
private static final long serialVersionUID = -54979041104113736L;
@TableId
private Long id;
/**
* 菜单名
*/
private String menuName;
/**
* 路由地址
*/
private String path;
/**
* 组件路径
*/
private String component;
/**
* 菜单状态(0显示 1隐藏)
*/
private String visible;
/**
* 菜单状态(0正常 1停用)
*/
private String status;
/**
* 权限标识
*/
private String perms;
/**
* 菜单图标
*/
private String icon;
private Long createBy;
private Date createTime;
private Long updateBy;
private Date updateTime;
/**
* 是否删除(0未删除 1已删除)
*/
private Integer delFlag;
/**
* 备注
*/
private String remark;
}
因为需要查询菜单表,所以需要定义菜单表的mapper接口分别增删查改。
@Mapper @Repository public interface MenuMapper extends BaseMapper
之后需要使用mapper的xml来实现多表查询
在resource下建包:

在mapper接口使用快捷方式(alt+enter)生成选择mapper文件夹的位置创建xml映射文件


在application.yml中配置mapperXML文件的位置
# 配置mapperXML文件的位置 mybatis-plus: mapper-locations: classpath*:/mapper/**/*.xml
我们只需要根据用户id,通过多表联查,去查询到其所对应的权限信息即可。
这里就需要使用mapper的xml来实现多表查询,
@Mapper @Repository public interface MenuMapper extends BaseMapper

数据库表对应说明:

接口方法权限设置


成功访问:满足预期效果、
成功访问:满足预期结果

我们希望在认证失败或者是授权失败的情况下,也能和我们的接口一样返回相同结构的json,这样可以让前端对响应进行统一的处理。要实现这个功能我们需要知道SpringSecurity的异常处理机制。
AuthenticationEntryPointImpl
/**
* 处理认证异常
*/
@Component
public class AuthenticationEntryPointImpl implements AuthenticationEntryPoint {
@Override
public void commence(HttpServletRequest request, HttpServletResponse response, AuthenticationException authException) throws IOException, ServletException {
R
AccessDeniedHandlerImpl
/**
* @Desc : 授权的异常处理
*/
@Component
public class AccessDeniedHandlerImpl implements AccessDeniedHandler {
@Override
public void handle(HttpServletRequest request, HttpServletResponse response, AccessDeniedException accessDeniedException) throws IOException, ServletException {
R
其中 WebUtils.renderString
public class WebUtils {
/**
* 在 HttpServletResponse 中渲染字符串的方法。
* 它将给定的字符串写入 HttpServletResponse 的输出流,
* 并设置相应的响应状态码、内容类型和字符编码。
*/
public static String renderString(HttpServletResponse response,String string) {
try {
response.getWriter().print(string);
response.setStatus(200);
response.setContentType("application/json");
response.setCharacterEncoding("utf-8");
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
}
@Autowired
private AuthenticationEntryPoint authenticationEntryPoint;
@Autowired
private AccessDeniedHandler accessDeniedHandler;
//配置异常处理器
http.exceptionHandling()
//认证失败处理器
.authenticationEntryPoint(authenticationEntryPoint)
.accessDeniedHandler(accessDeniedHandler);
测试------未改造之前会出现的问题:
在用户名出错的时候会抛出异常,是因为在执行loadUserByUsername方法时查询用户查询不到


但是如果用户名没错,密码错了就不会抛出异常:

因为在loadUserByUsername方法执行完成是可以找到用户的,获取用户的全部信息,所以在做密码验证的时候,方法内部验证密码的时候报错了。

改造自定义异常处理之后:
Authentication authenticate = authenticationManager.authenticate(authenticationToken);


没改造之前,异常信息也是拿不到的
改造之后,走授权异常处理器

所以我们就要处理一下,让前端能进行跨域请求。
SpringBoot配置,运行跨域请求
CorsConfig
@Configuration
public class CorsConfig implements WebMvcConfigurer {
@Override
public void addCorsMappings(CorsRegistry registry) {
// 设置允许跨域的路径
registry.addMapping("/**")
// 设置允许跨域请求的域名
.allowedOriginPatterns("*")
// 是否允许cookie
.allowCredentials(true)
// 设置允许的请求方式
.allowedMethods("GET", "POST", "DELETE", "PUT")
// 设置允许的header属性
.allowedHeaders("*")
// 跨域允许时间
.maxAge(3600);
}
}
在SecurityConfig的配置类中开启开启SpringSecurity的跨域访问
由于我们的资源都会收到SpringSecurity的保护,所以想要跨域访问还要让SpringSecurity运行跨域访问。
//允许跨域
http.cors();

@Component("ex")
public class QXExpressionRoot {
//String authority 这里是后端赋给它的权限
//从数据库获取登录用户的权限功能 和authority 进行对比
public boolean hasAuthority(String authority){
//获取当前用户得权限
Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
LoginUser loginUser = (LoginUser) authentication.getPrincipal();
List permissions = loginUser.getPermissions();
//判断用户权限集合中是否存在 authority
return permissions.contains(authority);
}
@RequestMapping("hello")
//自定义的权限功能
@PreAuthorize("@ex.hasAuthority('system:dept:list')")
public String hello(){
return "hello";
}
SpringBoot整合Spring Security实现权限控制----------gitee
作者:不易撞的网名
作者:北莽
上一篇:nginx复现负载均衡案例