SpringSecurity中的session并发控制

x33g5p2x  于2022-03-31 转载在 Spring  
字(13.3k)|赞(0)|评价(0)|浏览(212)

1.pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  5. <parent>
  6. <groupId>org.springframework.boot</groupId>
  7. <artifactId>spring-boot-starter-parent</artifactId>
  8. <version>2.6.4</version>
  9. <relativePath/> <!-- lookup parent from repository -->
  10. </parent>
  11. <groupId>com.yl</groupId>
  12. <artifactId>securitydemo</artifactId>
  13. <version>0.0.1-SNAPSHOT</version>
  14. <name>securitydemo</name>
  15. <description>Demo project for Spring Boot</description>
  16. <properties>
  17. <java.version>11</java.version>
  18. </properties>
  19. <dependencies>
  20. <dependency>
  21. <groupId>org.springframework.boot</groupId>
  22. <artifactId>spring-boot-starter-security</artifactId>
  23. </dependency>
  24. <dependency>
  25. <groupId>org.springframework.boot</groupId>
  26. <artifactId>spring-boot-starter-web</artifactId>
  27. </dependency>
  28. <dependency>
  29. <groupId>com.alibaba</groupId>
  30. <artifactId>druid-spring-boot-starter</artifactId>
  31. <version>1.1.10</version>
  32. </dependency>
  33. <dependency>
  34. <groupId>org.mybatis.spring.boot</groupId>
  35. <artifactId>mybatis-spring-boot-starter</artifactId>
  36. <version>2.2.2</version>
  37. </dependency>
  38. <dependency>
  39. <groupId>mysql</groupId>
  40. <artifactId>mysql-connector-java</artifactId>
  41. <scope>runtime</scope>
  42. </dependency>
  43. <dependency>
  44. <groupId>com.github.penggle</groupId>
  45. <artifactId>kaptcha</artifactId>
  46. <version>2.3.2</version>
  47. </dependency>
  48. <dependency>
  49. <groupId>org.springframework.boot</groupId>
  50. <artifactId>spring-boot-starter-test</artifactId>
  51. <scope>test</scope>
  52. </dependency>
  53. <dependency>
  54. <groupId>org.springframework.security</groupId>
  55. <artifactId>spring-security-test</artifactId>
  56. <scope>test</scope>
  57. </dependency>
  58. </dependencies>
  59. <build>
  60. <resources>
  61. <resource>
  62. <directory>src/main/java</directory>
  63. <includes>
  64. <include>**/*.xml</include>
  65. </includes>
  66. </resource>
  67. <resource>
  68. <directory>src/min/resources</directory>
  69. </resource>
  70. </resources>
  71. <plugins>
  72. <plugin>
  73. <groupId>org.springframework.boot</groupId>
  74. <artifactId>spring-boot-maven-plugin</artifactId>
  75. </plugin>
  76. </plugins>
  77. </build>
  78. </project>

2.建表语句

  1. DROP TABLE IF EXISTS `user`;
  2. CREATE TABLE `user` (
  3. `id` int(11) NOT NULL AUTO_INCREMENT,
  4. `username` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  5. `password` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  6. `enabled` tinyint(1) NULL DEFAULT NULL,
  7. `locked` tinyint(1) NULL DEFAULT NULL,
  8. PRIMARY KEY (`id`) USING BTREE
  9. ) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;
  10. -- ----------------------------
  11. -- Records of user
  12. -- ----------------------------
  13. INSERT INTO `user` VALUES (1, 'root', '$2a$10$O8G0X/sUPAA76MV7U3BwY.3Uo8/QMBcqK678Rwkoz.fowbce.CLtO', 1, 0);
  14. INSERT INTO `user` VALUES (2, 'admin', '$2a$10$O8G0X/sUPAA76MV7U3BwY.3Uo8/QMBcqK678Rwkoz.fowbce.CLtO', 1, 0);
  15. INSERT INTO `user` VALUES (3, 'tom', '$2a$10$O8G0X/sUPAA76MV7U3BwY.3Uo8/QMBcqK678Rwkoz.fowbce.CLtO', 1, 0);
  16. DROP TABLE IF EXISTS `role`;
  17. CREATE TABLE `role` (
  18. `id` int(11) NOT NULL AUTO_INCREMENT,
  19. `name` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  20. `description` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  21. PRIMARY KEY (`id`) USING BTREE
  22. ) ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;
  23. -- ----------------------------
  24. -- Records of role
  25. -- ----------------------------
  26. INSERT INTO `role` VALUES (1, 'ROLE_db', '数据库管理员');
  27. INSERT INTO `role` VALUES (2, 'ROLE_admin', '系统管理员');
  28. INSERT INTO `role` VALUES (3, 'ROLE_user', '用户');
  29. DROP TABLE IF EXISTS `user_role_ref`;
  30. CREATE TABLE `user_role_ref` (
  31. `id` int(11) NOT NULL AUTO_INCREMENT,
  32. `user_id` int(11) NULL DEFAULT NULL,
  33. `role_id` int(11) NULL DEFAULT NULL,
  34. PRIMARY KEY (`id`) USING BTREE
  35. ) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;
  36. -- ----------------------------
  37. -- Records of user_role_ref
  38. -- ----------------------------
  39. INSERT INTO `user_role_ref` VALUES (1, 1, 1);
  40. INSERT INTO `user_role_ref` VALUES (2, 1, 2);
  41. INSERT INTO `user_role_ref` VALUES (3, 2, 2);
  42. INSERT INTO `user_role_ref` VALUES (4, 3, 3);

3.application.properties

  1. spring.datasource.url=jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai
  2. spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
  3. spring.datasource.username=root
  4. spring.datasource.password=root

3.实体类

  1. package com.yl.securitydemo.model;
  2. import org.springframework.security.core.GrantedAuthority;
  3. import org.springframework.security.core.authority.SimpleGrantedAuthority;
  4. import org.springframework.security.core.userdetails.UserDetails;
  5. import java.util.ArrayList;
  6. import java.util.Collection;
  7. import java.util.List;
  8. import java.util.Objects;
  9. public class User implements UserDetails {
  10. private Integer id;
  11. private String username;
  12. private String password;
  13. private Boolean enabled;
  14. private Boolean locked;
  15. private List<Role> roles;
  16. public Integer getId() {
  17. return id;
  18. }
  19. public void setId(Integer id) {
  20. this.id = id;
  21. }
  22. public void setUsername(String username) {
  23. this.username = username;
  24. }
  25. @Override
  26. public Collection<? extends GrantedAuthority> getAuthorities() {
  27. List<SimpleGrantedAuthority> list = new ArrayList<>();
  28. for (Role role : roles) {
  29. list.add(new SimpleGrantedAuthority("ROLE_" + role.getName()));
  30. }
  31. return list;
  32. }
  33. @Override
  34. public String getPassword() {
  35. return password;
  36. }
  37. @Override
  38. public String getUsername() {
  39. return username;
  40. }
  41. // 账户是否未过期
  42. @Override
  43. public boolean isAccountNonExpired() {
  44. return true;
  45. }
  46. // 账户是否未锁定
  47. @Override
  48. public boolean isAccountNonLocked() {
  49. return !locked;
  50. }
  51. // 凭证是否未过期
  52. @Override
  53. public boolean isCredentialsNonExpired() {
  54. return true;
  55. }
  56. @Override
  57. public boolean isEnabled() {
  58. return enabled;
  59. }
  60. public void setPassword(String password) {
  61. this.password = password;
  62. }
  63. public void setEnabled(Boolean enabled) {
  64. this.enabled = enabled;
  65. }
  66. public void setLocked(Boolean locked) {
  67. this.locked = locked;
  68. }
  69. public List<Role> getRoles() {
  70. return roles;
  71. }
  72. public void setRoles(List<Role> roles) {
  73. this.roles = roles;
  74. }
  75. @Override
  76. public boolean equals(Object o) {
  77. if (this == o) return true;
  78. if (o == null || getClass() != o.getClass()) return false;
  79. User user = (User) o;
  80. return username.equals(user.username);
  81. }
  82. @Override
  83. public int hashCode() {
  84. return Objects.hash(username);
  85. }
  86. @Override
  87. public String toString() {
  88. return "User{" +
  89. "id=" + id +
  90. ", username='" + username + '\'' +
  91. ", password='" + password + '\'' +
  92. ", enabled=" + enabled +
  93. ", locked=" + locked +
  94. '}';
  95. }
  96. }
  1. package com.yl.securitydemo.model;
  2. import java.io.Serializable;
  3. public class Role implements Serializable {
  4. private Integer id;
  5. private String name;
  6. private String description;
  7. public Integer getId() {
  8. return id;
  9. }
  10. public void setId(Integer id) {
  11. this.id = id;
  12. }
  13. public String getName() {
  14. return name;
  15. }
  16. public void setName(String name) {
  17. this.name = name;
  18. }
  19. public String getDescription() {
  20. return description;
  21. }
  22. public void setDescription(String description) {
  23. this.description = description;
  24. }
  25. @Override
  26. public String toString() {
  27. return "Role{" +
  28. "id=" + id +
  29. ", name='" + name + '\'' +
  30. ", description='" + description + '\'' +
  31. '}';
  32. }
  33. }
  1. package com.yl.securitydemo.model;
  2. import java.io.Serializable;
  3. public class UserRoleRef implements Serializable {
  4. private Integer id;
  5. private Integer userId;
  6. private Integer roleId;
  7. public Integer getId() {
  8. return id;
  9. }
  10. public void setId(Integer id) {
  11. this.id = id;
  12. }
  13. public Integer getUserId() {
  14. return userId;
  15. }
  16. public void setUserId(Integer userId) {
  17. this.userId = userId;
  18. }
  19. public Integer getRoleId() {
  20. return roleId;
  21. }
  22. public void setRoleId(Integer roleId) {
  23. this.roleId = roleId;
  24. }
  25. @Override
  26. public String toString() {
  27. return "UserRoleRef{" +
  28. "id=" + id +
  29. ", userId=" + userId +
  30. ", roleId=" + roleId +
  31. '}';
  32. }
  33. }

4.mapper及xml文件

  1. package com.yl.securitydemo.mapper;
  2. import com.yl.securitydemo.model.Role;
  3. import com.yl.securitydemo.model.User;
  4. import org.apache.ibatis.annotations.Mapper;
  5. import java.util.List;
  6. @Mapper
  7. public interface UserMapper {
  8. User loadUserByUsername(String username);
  9. List<Role> getRolesByUserId(Integer userId);
  10. }
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.yl.securitydemo.mapper.UserMapper">
  4. <select id="loadUserByUsername" resultType="com.yl.securitydemo.model.User">
  5. select * from user where username = #{username}
  6. </select>
  7. <select id="getRolesByUserId" resultType="com.yl.securitydemo.model.Role">
  8. select * from role where id in (select role_id from user_role_ref where user_id = #{userId})
  9. </select>
  10. </mapper>

5.UserService

  1. package com.yl.securitydemo.service;
  2. import com.yl.securitydemo.mapper.UserMapper;
  3. import com.yl.securitydemo.model.User;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.security.core.userdetails.UserDetails;
  6. import org.springframework.security.core.userdetails.UserDetailsService;
  7. import org.springframework.security.core.userdetails.UsernameNotFoundException;
  8. import org.springframework.stereotype.Service;
  9. @Service
  10. public class UserService implements UserDetailsService {
  11. @Autowired
  12. UserMapper userMapper;
  13. @Override
  14. public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
  15. User user = userMapper.loadUserByUsername(username);
  16. if (user == null) {
  17. throw new UsernameNotFoundException("用户名不存在");
  18. }
  19. user.setRoles(userMapper.getRolesByUserId(user.getId()));
  20. return user;
  21. }
  22. }

5.Security的配置

  1. package com.yl.securitydemo.config;
  2. import com.yl.securitydemo.service.UserService;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.security.authentication.AuthenticationManager;
  7. import org.springframework.security.authentication.ProviderManager;
  8. import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder;
  9. import org.springframework.security.config.annotation.web.builders.HttpSecurity;
  10. import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
  11. import org.springframework.security.core.Authentication;
  12. import org.springframework.security.core.AuthenticationException;
  13. import org.springframework.security.core.userdetails.UserDetailsService;
  14. import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
  15. import org.springframework.security.crypto.password.NoOpPasswordEncoder;
  16. import org.springframework.security.crypto.password.PasswordEncoder;
  17. import org.springframework.security.web.authentication.AuthenticationFailureHandler;
  18. import org.springframework.security.web.authentication.AuthenticationSuccessHandler;
  19. import org.springframework.security.web.session.HttpSessionEventPublisher;
  20. import javax.servlet.ServletException;
  21. import javax.servlet.http.HttpServletRequest;
  22. import javax.servlet.http.HttpServletResponse;
  23. import java.io.IOException;
  24. @Configuration
  25. public class SecurityConfig extends WebSecurityConfigurerAdapter {
  26. @Autowired
  27. UserService userService;
  28. // @Autowired
  29. // MyWebAuthenticationDetailsSource myWebAuthenticationDetailsSource;
  30. @Bean
  31. PasswordEncoder passwordEncoder() {
  32. return new BCryptPasswordEncoder();
  33. }
  34. // @Bean
  35. // MyAuthenticationProvider myAuthenticationProvider() {
  36. // MyAuthenticationProvider provider = new MyAuthenticationProvider();
  37. // provider.setPasswordEncoder(passwordEncoder());
  38. // provider.setUserDetailsService(userService);
  39. // return provider;
  40. // }
  41. @Bean
  42. HttpSessionEventPublisher httpSessionEventPublisher() {
  43. return new HttpSessionEventPublisher();
  44. }
  45. // @Override
  46. // @Bean
  47. // protected AuthenticationManager authenticationManager() throws Exception {
  48. // return new ProviderManager(myAuthenticationProvider());
  49. // }
  50. @Override
  51. protected void configure(AuthenticationManagerBuilder auth) throws Exception {
  52. auth.userDetailsService(userService);
  53. }
  54. @Override
  55. protected void configure(HttpSecurity http) throws Exception {
  56. http.authorizeRequests()
  57. // .antMatchers("/getVerifyCode")
  58. // .permitAll()
  59. .anyRequest()
  60. .authenticated()
  61. .and()
  62. .formLogin()
  63. // .authenticationDetailsSource(myWebAuthenticationDetailsSource)
  64. .successHandler(new AuthenticationSuccessHandler() {
  65. @Override
  66. public void onAuthenticationSuccess(HttpServletRequest request, HttpServletResponse response, Authentication authentication) throws IOException, ServletException {
  67. response.setContentType("text/html;charset=utf-8");
  68. response.getWriter().write("login success");
  69. }
  70. })
  71. .failureHandler(new AuthenticationFailureHandler() {
  72. @Override
  73. public void onAuthenticationFailure(HttpServletRequest request, HttpServletResponse response, AuthenticationException exception) throws IOException, ServletException {
  74. response.setContentType("text/html;charset=utf-8");
  75. response.getWriter().write("login fail");
  76. }
  77. })
  78. .permitAll()
  79. .and()
  80. .csrf().disable()
  81. .sessionManagement()
  82. .maximumSessions(1) //限制能登录的用户个数为1
  83. .maxSessionsPreventsLogin(true);// 禁止后面的用户登录
  84. }
  85. }

6.测试

1.在一个客户端登录admin账号,登录成功

2.在另外一个客户端登录admin账号,登录失败!

相关文章