Spring boot security权限管理集成cas单点登录
挣扎了两周,Spring security 的 cas 终于搞出来了,废话不多说,开篇!
- Spring boot 集成 Spring security
本篇是使用 spring security 集成 cas,因此,先得集成 spring security
新建一个 Spring boot 项目,加入 maven 依赖,我这里是用的架构是 Spring boot2.0.4+Spring mvc+Spring data jpa+Spring security5
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 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4 <modelVersion>4.0.0</modelVersion> 5 6 <groupId>com.cas.client1</groupId> 7 <artifactId>cas-client1</artifactId> 8 <version>0.0.1-SNAPSHOT</version> 9 <packaging>jar</packaging> 10 11 <name>cas-client1</name> 12 <description>Demo project for Spring Boot</description> 13 14 <parent> 15 <groupId>org.springframework.boot</groupId> 16 <artifactId>spring-boot-starter-parent</artifactId> 17 <version>2.0.4.RELEASE</version> 18 <relativePath/> <!-- lookup parent from repository --> 19 </parent> 20 21 <properties> 22 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 23 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> 24 <java.version>1.8</java.version> 25 </properties> 26 27 <dependencies> 28 <dependency> 29 <groupId>org.springframework.boot</groupId> 30 <artifactId>spring-boot-starter-web</artifactId> 31 </dependency> 32 <dependency> 33 <groupId>org.springframework.boot</groupId> 34 <artifactId>spring-boot-starter-thymeleaf</artifactId> 35 </dependency> 36 37 <dependency> 38 <groupId>org.springframework.boot</groupId> 39 <artifactId>spring-boot-starter-tomcat</artifactId> 40 <scope>provided</scope> 41 </dependency> 42 <dependency> 43 <groupId>junit</groupId> 44 <artifactId>junit</artifactId> 45 <version>4.12</version> 46 <scope>test</scope> 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.boot</groupId> 55 <artifactId>spring-boot-starter-security</artifactId> 56 </dependency> 57 <dependency> 58 <groupId>org.springframework.security</groupId> 59 <artifactId>spring-security-test</artifactId> 60 <scope>test</scope> 61 </dependency> 62 <!-- security taglibs --> 63 <dependency> 64 <groupId>org.springframework.security</groupId> 65 <artifactId>spring-security-taglibs</artifactId> 66 </dependency> 67 <dependency> 68 <groupId>org.springframework.security.oauth</groupId> 69 <artifactId>spring-security-oauth2</artifactId> 70 <version>RELEASE</version> 71 </dependency> 72 <dependency> 73 <groupId>org.springframework.boot</groupId> 74 <artifactId>spring-boot-starter-data-jpa</artifactId> 75 </dependency> 76 <dependency> 77 <groupId>org.springframework.boot</groupId> 78 <artifactId>spring-boot-starter-jdbc</artifactId> 79 </dependency> 80 <dependency> 81 <groupId>mysql</groupId> 82 <artifactId>mysql-connector-java</artifactId> 83 <version>5.1.46</version> 84 </dependency> 85 <!-- https://mvnrepository.com/artifact/com.alibaba/druid-spring-boot-starter --> 86 <dependency> 87 <groupId>com.alibaba</groupId> 88 <artifactId>druid-spring-boot-starter</artifactId> 89 <version>1.1.10</version> 90 </dependency> 91 <dependency> 92 <groupId>org.springframework.boot</groupId> 93 <artifactId>spring-boot</artifactId> 94 <version>2.0.2.RELEASE</version> 95 <scope>compile</scope> 96 </dependency> 97 </dependencies> 98 99 <build> 100 <plugins> 101 <plugin> 102 <groupId>org.springframework.boot</groupId> 103 <artifactId>spring-boot-maven-plugin</artifactId> 104 </plugin> 105 </plugins> 106 </build> 107 108 109 </project>
application.properties:
1 server.port=8083 2 #静态文件访问存放地址 3 spring.resources.static-locations=classpath:/html/ 4 # thymeleaf 模板存放地址 5 spring.thymeleaf.prefix=classpath:/html/ 6 spring.thymeleaf.suffix=.html 7 spring.thymeleaf.mode=LEGACYHTML5 8 spring.thymeleaf.encoding=UTF-8 9 10 # JDBC 配置 (驱动类自动从 url 的 mysql 识别, 数据源类型自动识别) 11 # 或 spring.datasource.url= 12 spring.datasource.druid.url=jdbc:mysql://localhost:3306/vhr?useUnicode=true&characterEncoding=UTF8 13 # 或 spring.datasource.username= 14 spring.datasource.druid.username=root 15 # 或 spring.datasource.password= 16 spring.datasource.druid.password=1234 17 #或 spring.datasource.driver-class-name= 18 #spring.datasource.druid.driver-class-name=com.mysql.jdbc.Driver 19 20 #连接池配置 ( 通常来说,只需要修改 initialSize、minIdle、maxActive 21 # 如果用 Oracle,则把 poolPreparedStatements 配置为 true,mysql 可以配置为 false。分库分表较多的数据库,建议配置为 false。removeabandoned 不建议在生产环境中打开如果用 SQL Server,建议追加配置 ) 22 spring.datasource.druid.initial-size=1 23 spring.datasource.druid.max-active=20 24 spring.datasource.druid.min-idle=1 25 # 配置获取连接等待超时的时间 26 spring.datasource.druid.max-wait=60000 27 #打开 PSCache,并且指定每个连接上 PSCache 的大小 28 spring.datasource.druid.pool-prepared-statements=true 29 spring.datasource.druid.max-pool-prepared-statement-per-connection-size=20 30 #spring.datasource.druid.max-open-prepared-statements=和上面的等价 31 spring.datasource.druid.validation-query=SELECT 'x' 32 #spring.datasource.druid.validation-query-timeout= 33 spring.datasource.druid.test-on-borrow=false 34 spring.datasource.druid.test-on-return=false 35 spring.datasource.druid.test-while-idle=true 36 #配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 37 spring.datasource.druid.time-between-eviction-runs-millis=60000 38 #配置一个连接在池中最小生存的时间,单位是毫秒 39 spring.datasource.druid.min-evictable-idle-time-millis=300000 40 #spring.datasource.druid.max-evictable-idle-time-millis= 41 #配置多个英文逗号分隔 42 #spring.datasource.druid.filters= stat 43 44 # WebStatFilter 配置,说明请参考 Druid Wiki,配置 _ 配置 WebStatFilter 45 #是否启用 StatFilter 默认值 true 46 spring.datasource.druid.web-stat-filter.enabled=true 47 spring.datasource.druid.web-stat-filter.url-pattern=/* 48 spring.datasource.druid.web-stat-filter.exclusions=*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/* 49 spring.datasource.druid.web-stat-filter.session-stat-enable=false 50 spring.datasource.druid.web-stat-filter.session-stat-max-count=1000 51 spring.datasource.druid.web-stat-filter.principal-session-name=admin 52 spring.datasource.druid.web-stat-filter.principal-cookie-name=admin 53 spring.datasource.druid.web-stat-filter.profile-enable=true 54 55 # StatViewServlet 配置 56 #展示 Druid 的统计信息,StatViewServlet 的用途包括:1. 提供监控信息展示的 html 页面 2. 提供监控信息的 JSON API 57 #是否启用 StatViewServlet 默认值 true 58 spring.datasource.druid.stat-view-servlet.enabled=true 59 spring.datasource.druid.stat-view-servlet.url-pattern=/druid/* 60 61 62 # JPA config 63 spring.jpa.database=mysql 64 spring.jpa.hibernate.ddl-auto=update 65 spring.jpa.show-sql=true 66 spring.jpa.generate-ddl=true 67 spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect 68 spring.jpa.open-in-view=true 69 # 解决 jpa no session 的问题 70 spring.jpa.properties.hibernate.enable_lazy_load_no_trans=true
这里使用数据库存储角色权限信息,分三种实体:用户;角色;资源;用户对角色多对多;角色对资源多对多
创建几个实体类:
用户:这里直接使用用户持久化对象实现 Spring security 要求的 UserDetails 接口,并实现对应方法1 package com.cas.client1.entity; 2 3 import org.springframework.security.core.GrantedAuthority; 4 import org.springframework.security.core.userdetails.UserDetails; 5 import org.springframework.util.CollectionUtils; 6 7 import javax.persistence.*; 8 import java.util.ArrayList; 9 import java.util.Collection; 10 import java.util.List; 11 12 @Entity 13 @Table(name = "s_user") 14 public class User implements UserDetails { 15 @Id 16 private String id; 17 @Column(name = "username") 18 private String username; 19 @Column(name = "password") 20 private String password; 21 22 @ManyToMany(fetch = FetchType.LAZY) 23 @JoinTable( 24 name = "s_user_role", 25 joinColumns = @JoinColumn(name = "user_id"), 26 inverseJoinColumns = @JoinColumn(name = "role_id") 27 ) 28 private List<Role> roles; 29 30 public User() { 31 } 32 33 public User(String id, String username, String password) { 34 this.id = id; 35 this.username = username; 36 this.password = password; 37 } 38 39 public String getId() { 40 return id; 41 } 42 43 public void setId(String id) { 44 this.id = id; 45 } 46 47 public List<Role> getRoles() { 48 return roles; 49 } 50 51 public void setRoles(List<Role> roles) { 52 this.roles = roles; 53 } 54 55 @Override 56 public String getUsername() { 57 return username; 58 } 59 60 @Override 61 public boolean isAccountNonExpired() { 62 return true; 63 } 64 65 @Override 66 public boolean isAccountNonLocked() { 67 return true; 68 } 69 70 @Override 71 public boolean isCredentialsNonExpired() { 72 return true; 73 } 74 75 @Override 76 public boolean isEnabled() { 77 return true; 78 } 79 80 public void setUsername(String username) { 81 this.username = username; 82 } 83 84 @Transient 85 List<GrantedAuthority> grantedAuthorities=new ArrayList<>(); 86 @Override 87 public Collection<? extends GrantedAuthority> getAuthorities() { 88 if (grantedAuthorities.size()==0){ 89 if (!CollectionUtils.isEmpty(roles)){ 90 for (Role role:roles){ 91 List<Resource> resources = role.getResources(); 92 if (!CollectionUtils.isEmpty(resources)){ 93 for (Resource resource:resources){ 94 grantedAuthorities.add(new SimpleGrantedAuthority(resource.getResCode())); 95 } 96 } 97 } 98 } 99 grantedAuthorities.add(new SimpleGrantedAuthority("AUTH_0")); 100 } 101 return grantedAuthorities; 102 } 103 @Override 104 public String getPassword() { 105 return password; 106 } 107 108 public void setPassword(String password) { 109 this.password = password; 110 } 111 }
注意看这里:
我给每一位登录的用户都授予了 AUTH_0 的权限,AUTH_0 在下面的 SecurityMetaDataSource 里被关联的 url 为:/**, 也就是说除开那些机密程度更高的,这个登录用户能访问所有资源
角色:
1 package com.cas.client1.entity; 2 3 import javax.persistence.*; 4 import java.util.List; 5 6 /** 7 * @author Administrator 8 */ 9 @Entity 10 @Table(name = "s_role") 11 public class Role { 12 @Id 13 @Column(name = "id") 14 private String id; 15 @Column(name = "role_name") 16 private String roleName; 17 18 @ManyToMany(fetch = FetchType.LAZY) 19 @JoinTable( 20 name = "s_role_res", 21 joinColumns = @JoinColumn(name = "role_id"), 22 inverseJoinColumns = @JoinColumn(name = "res_id") 23 ) 24 private List<Resource> resources; 25 @ManyToMany(fetch = FetchType.LAZY) 26 @JoinTable( 27 name = "s_user_role", 28 joinColumns = @JoinColumn(name = "role_id"), 29 inverseJoinColumns = @JoinColumn(name = "user_id") 30 ) 31 private List<User> users; 32 33 public String getId() { 34 return id; 35 } 36 37 public void setId(String id) { 38 this.id = id; 39 } 40 41 public String getRoleName() { 42 return roleName; 43 } 44 45 public void setRoleName(String roleName) { 46 this.roleName = roleName; 47 } 48 49 public List<Resource> getResources() { 50 return resources; 51 } 52 53 public void setResources(List<Resource> resources) { 54 this.resources = resources; 55 } 56 57 public List<User> getUsers() { 58 return users; 59 } 60 61 public void setUsers(List<User> users) { 62 this.users = users; 63 } 64 }
权限:
1 package com.cas.client1.entity; 2 3 import javax.persistence.Column; 4 import javax.persistence.Entity; 5 import javax.persistence.Id; 6 import javax.persistence.Table; 7 8 @Entity 9 @Table(name = "s_resource") 10 public class Resource { 11 @Id 12 @Column(name = "id") 13 private String id; 14 @Column(name = "res_name") 15 private String resName; 16 @Column(name = "res_code") 17 private String resCode; 18 @Column(name = "url") 19 private String url; 20 @Column(name = "priority") 21 private String priority; 22 23 public String getId() { 24 return id; 25 } 26 27 public void setId(String id) { 28 this.id = id; 29 } 30 31 public String getResName() { 32 return resName; 33 } 34 35 public void setResName(String resName) { 36 this.resName = resName; 37 } 38 39 public String getResCode() { 40 return resCode; 41 } 42 43 public void setResCode(String resCode) { 44 this.resCode = resCode; 45 } 46 47 public String getUrl() { 48 return url; 49 } 50 51 public void setUrl(String url) { 52 this.url = url; 53 } 54 55 public String getPriority() { 56 return priority; 57 } 58 59 public void setPriority(String priority) { 60 this.priority = priority; 61 } 62 }
建立几个 DAO
UserDao:1 package com.cas.client1.dao; 2 3 import com.cas.client1.entity.User; 4 import org.springframework.data.jpa.repository.JpaRepository; 5 import org.springframework.data.jpa.repository.Query; 6 import org.springframework.data.repository.query.Param; 7 import org.springframework.stereotype.Repository; 8 9 import java.util.List; 10 11 @Repository 12 public interface UserDao extends JpaRepository<User,String> { 13 @Override 14 List<User> findAll(); 15 16 List<User> findByUsername(String username); 17 18 /** 19 * 根据用户名 like 查询 20 * @param username 21 * @return 22 */ 23 List<User> getUserByUsernameContains(String username); 24 25 @Query("from User where id=:id") 26 User getUserById(@Param("id")String id); 27 28 }
ResourceDao:
1 package com.cas.client1.dao; 2 3 import com.cas.client1.entity.Resource; 4 import org.springframework.data.jpa.repository.JpaRepository; 5 import org.springframework.data.jpa.repository.Query; 6 import org.springframework.stereotype.Repository; 7 8 import java.util.List; 9 10 /** 11 * @author Administrator 12 */ 13 @Repository 14 public interface ResourceDao extends JpaRepository<Resource,String> { 15 16 @Query("from Resource order by priority") 17 List<Resource> getAllResource(); 18 }
Service
UserService:1 package com.cas.client1.service; 2 3 import com.cas.client1.dao.UserDao; 4 import com.cas.client1.entity.User; 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.stereotype.Service; 7 8 import java.util.List; 9 10 @Service 11 public class UserService { 12 @Autowired 13 private UserDao userDao; 14 15 public User findByUsername(String username){ 16 List<User> list = userDao.findByUsername(username); 17 return list!=null&&list.size()>0?list.get(0):null; 18 } 19 }
ResourceService:
1 package com.cas.client1.service; 2 3 import com.cas.client1.dao.ResourceDao; 4 import com.cas.client1.entity.Resource; 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.stereotype.Service; 7 8 import java.util.List; 9 10 @Service 11 public class ResourceService { 12 @Autowired 13 private ResourceDao resourceDao; 14 15 public List<Resource> getAll(){ 16 return resourceDao.getAllResource(); 17 } 18 }
创建UserDetailsServiceImpl,实现 UserDetailsService 接口,这个类是用以提供给 Spring security 从数据库加载用户信息的
1 package com.cas.client1.security; 2 3 import com.cas.client1.entity.User; 4 import com.cas.client1.service.UserService; 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.security.cas.authentication.CasAssertionAuthenticationToken; 7 import org.springframework.security.core.userdetails.AuthenticationUserDetailsService; 8 import org.springframework.security.core.userdetails.UserDetails; 9 import org.springframework.security.core.userdetails.UserDetailsService; 10 import org.springframework.security.core.userdetails.UsernameNotFoundException; 11 import org.springframework.stereotype.Component; 12 13 /** 14 * @author Administrator 15 */ 16 @SuppressWarnings("ALL") 17 @Component 18 public class UserDetailsServiceImpl implements UserDetailsService{ 19 @Autowired 20 private UserService userService; 21 @Override 22 public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { 23 User user = userService.findByUsername(username); 24 return user; 25 } 26 27 28 }
记得加 @Component 注解,以把实例交由 Spring 管理,或 @Service,你们喜欢就好
创建 SecurityMetaDataSource 类
该类实现 Spring security 的 FilterInvocationSecurityMetadataSource 接口,作用是提供权限的元数据定义,并根据请求 url 匹配该 url 所需要的权限,获取权限后交由 AccessDecisionManager 的实现者裁定能否访问这个 url,不能则会返回 403 的 http 错误码
SecurityMetaDataSource:1 package com.cas.client1.security; 2 3 import com.cas.client1.entity.Resource; 4 import com.cas.client1.service.ResourceService; 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.security.access.AccessDecisionManager; 7 import org.springframework.security.access.ConfigAttribute; 8 import org.springframework.security.access.SecurityConfig; 9 import org.springframework.security.access.intercept.AbstractSecurityInterceptor; 10 import org.springframework.security.web.FilterInvocation; 11 import org.springframework.security.web.access.intercept.FilterInvocationSecurityMetadataSource; 12 import org.springframework.security.web.util.matcher.AndRequestMatcher; 13 import org.springframework.security.web.util.matcher.AntPathRequestMatcher; 14 import org.springframework.security.web.util.matcher.RequestMatcher; 15 import org.springframework.stereotype.Component; 16 17 import javax.annotation.PostConstruct; 18 import java.util.*; 19 20 @Component 21 public class SecurityMetaDataSource implements FilterInvocationSecurityMetadataSource { 22 23 @Autowired 24 private ResourceService resourceService; 25 26 private LinkedHashMap<String,Collection<ConfigAttribute>> metaData; 27 @PostConstruct 28 private void loadSecurityMetaData(){ 29 List<Resource> list = resourceService.getAll(); 30 metaData=new LinkedHashMap<>(); 31 for (Resource resource:list){ 32 List<ConfigAttribute> attributes=new ArrayList<>(); 33 attributes.add(new SecurityConfig(resource.getResCode())); 34 metaData.put(resource.getUrl(),attributes); 35 } 36 List<ConfigAttribute> base=new ArrayList<>(); 37 base.add(new SecurityConfig("AUTH_0")); 38 metaData.put("/**",base); 39 } 40 41 @Override 42 public Collection<ConfigAttribute> getAttributes(Object object) throws IllegalArgumentException { 43 FilterInvocation invocation= (FilterInvocation) object; 44 if (metaData==null){ 45 return new ArrayList<>(0); 46 } 47 String requestUrl = invocation.getRequestUrl(); 48 System.out.println("请求 Url:"+requestUrl); 49 Iterator<Map.Entry<String, Collection<ConfigAttribute>>> iterator = metaData.entrySet().iterator(); 50 Collection<ConfigAttribute> rs=new ArrayList<>(); 51 while (iterator.hasNext()){ 52 Map.Entry<String, Collection<ConfigAttribute>> next = iterator.next(); 53 String url = next.getKey(); 54 Collection<ConfigAttribute> value = next.getValue(); 55 RequestMatcher requestMatcher=new AntPathRequestMatcher(url); 56 if (requestMatcher.matches(invocation.getRequest())){ 57 rs = value; 58 break; 59 } 60 } 61 System.out.println("拦截认证权限为:"+rs); 62 return rs; 63 } 64 65 @Override 66 public Collection<ConfigAttribute> getAllConfigAttributes() { 67 System.out.println("invoke getAllConfigAttributes"); 68 //loadSecurityMetaData(); 69 //System.out.println("初始化元数据"); 70 Collection<Collection<ConfigAttribute>> values = metaData.values(); 71 Collection<ConfigAttribute> all=new ArrayList<>(); 72 for (Collection<ConfigAttribute> each:values){ 73 each.forEach(configAttribute -> { 74 all.add(configAttribute); 75 }); 76 } 77 return all; 78 } 79 80 @Override 81 public boolean supports(Class<?> clazz) { 82 return true; 83 } 84 }
同理:记得加上 @Component 注解
重头戏来了!Spring security 的配置
创建 SpringSecurityConfig 类
该类继承于 WebSecurityConfigurerAdapter,核心的配置类,在这里定义 Spring security 的使用方式SpringSecurityConfig
1 package com.cas.client1.security; 2 3 import com.cas.client1.config.CasProperties; 4 import org.springframework.beans.factory.annotation.Autowired; 5 import org.springframework.context.annotation.Bean; 6 import org.springframework.context.annotation.Configuration; 7 import org.springframework.security.access.AccessDecisionManager; 8 import org.springframework.security.access.AccessDecisionVoter; 9 import org.springframework.security.access.vote.AffirmativeBased; 10 import org.springframework.security.access.vote.RoleVoter; 11 import org.springframework.security.authentication.AuthenticationManager; 12 import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder; 13 import org.springframework.security.config.annotation.web.builders.HttpSecurity; 14 import org.springframework.security.config.annotation.web.builders.WebSecurity; 15 import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity; 16 import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter; 17 import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; 18 import org.springframework.security.web.access.intercept.FilterSecurityInterceptor; 19 20 import java.util.ArrayList; 21 import java.util.List; 22 23 /** 24 * Spring security 配置 25 * @author youyp 26 * @date 2018-8-10 27 */ 28 @SuppressWarnings("ALL") 29 @Configuration 30 @EnableWebSecurity 31 public class SpringSecurityConfig extends WebSecurityConfigurerAdapter { 32 @Autowired 33 private UserDetailsServiceImpl userDetailsService; 34 35 @Autowired 36 private SecurityMetaDataSource securityMetaDataSource; 37 38 @Override 39 protected void configure(AuthenticationManagerBuilder auth) throws Exception { 40 super.configure(auth); 41 } 42 43 @Override 44 public void configure(WebSecurity web) throws Exception { 45 web.ignoring().antMatchers("/js/**","/css/**","/img/**","/*.ico","/login.html", 46 "/error","/login.do"); 47 } 48 49 @Override 50 protected void configure(HttpSecurity http) throws Exception { 51 System.out.println("配置 Spring security"); 52 http.formLogin() 53 //指定登录页是”/login” 54 .loginPage("/login.html").permitAll() 55 .loginProcessingUrl("/login.do").permitAll() 56 .defaultSuccessUrl("/home",true) 57 .permitAll() 58 //登录成功后可使用 loginSuccessHandler() 存储用户信息,可选。 59 //.successHandler(loginSuccessHandler()).permitAll() 60 .and() 61 .logout().permitAll() 62 .invalidateHttpSession(true) 63 .and() 64 //登录后记住用户,下次自动登录, 数据库中必须存在名为 persistent_logins 的表 65 .rememberMe() 66 .tokenValiditySeconds(1209600) 67 .and() 68 .csrf().disable() 69 //其他所有资源都需要认证,登陆后访问 70 .authorizeRequests().anyRequest().fullyAuthenticated(); 71 72 http.addFilterBefore(filterSecurityInterceptor(),FilterSecurityInterceptor.class); 73 } 74 75 /** 76 * 注意:这里不能加 @Bean 注解 77 * @return 78 * @throws Exception 79 */ 80 //@Bean 81 public FilterSecurityInterceptor filterSecurityInterceptor() throws Exception { 82 FilterSecurityInterceptor filterSecurityInterceptor=new FilterSecurityInterceptor(); 83 filterSecurityInterceptor.setSecurityMetadataSource(securityMetaDataSource); 84 filterSecurityInterceptor.setAuthenticationManager(authenticationManager()); 85 filterSecurityInterceptor.setAccessDecisionManager(affirmativeBased()); 86 return filterSecurityInterceptor; 87 } 88 89 90 /** 91 * 重写 AuthenticationManager 获取的方法并且定义为 Bean 92 * @return 93 * @throws Exception 94 */ 95 @Override 96 @Bean 97 public AuthenticationManager authenticationManagerBean() throws Exception { 98 return super.authenticationManagerBean(); 99 } 100 101 @Autowired 102 public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception { 103 //指定密码加密所使用的加密器为 passwordEncoder() 104 //需要将密码加密后写入数据库 105 auth.userDetailsService(userDetailsService).passwordEncoder(passwordEncoder()); 106 auth.eraseCredentials(false); 107 } 108 109 @Bean 110 public BCryptPasswordEncoder passwordEncoder() { 111 112 return new BCryptPasswordEncoder(4); 113 } 114 115 116 /** 117 * 定义决策管理器,这里可直接使用内置的 AffirmativeBased 选举器, 118 * 如果需要,可自定义,继承 AbstractAccessDecisionManager,实现 decide 方法即可 119 * @return 120 */ 121 @Bean 122 public AccessDecisionManager affirmativeBased(){ 123 List<AccessDecisionVoter<? extends Object>> voters=new ArrayList<>(); 124 voters.add(roleVoter()); 125 System.out.println("正在创建决策管理器"); 126 return new AffirmativeBased(voters); 127 } 128 129 /** 130 * 定义选举器 131 * @return 132 */ 133 @Bean 134 public RoleVoter roleVoter(){ 135 //这里使用角色选举器 136 RoleVoter voter=new RoleVoter(); 137 System.out.println("正在创建选举器"); 138 voter.setRolePrefix("AUTH_"); 139 System.out.println("已将角色选举器的前缀修改为 AUTH_"); 140 return voter; 141 } 142 143 }
说一个注意点:
FilterSecurityInterceptor 这个过滤器最为重要,它负责数据库权限信息加载,权限鉴定等关键动作,这个过滤器位于 SpringSecurityFilterChain,即 Spring security 的过滤器链中,如果将这个类在配置类中加了 @Bean 注解,那么它将直接加入 web 容器的过滤器链中,这个链是首层过滤器链,
进入这个过滤器链之后才会进入 SpringSecurityFilterChain 这个负责安全的链条,如果这个跑到外层去了,就会导致这个独有的过滤器一直在生效,请求无限被拦截重定向,因为这个过滤器前面没有别的过滤器阻止它生效,如果它位于 SpringSecurityFilterChain 中,在进入 FilterSecurityInterceptor 这个
过滤器之前会有很多的 Spring security 过滤器在生效,如果不满足前面的过滤器的条件,不会进入到这个过滤器。也就是说,要进入到这个过滤器,必须要从 SpringSecurityFilterChain 进入,从其他地方进入都会导致请求被无限重定向
另外
FilterSecurityInterceptor 这个类继承于 AbstractSecurityInterceptor 并实现 Filter 接口,由此我们可以重写该类,自定义我们的特殊业务,但是,个人觉得 FilterSecurityInterceptor 这个实现类已经很完整地实现了这个过滤器应做的工作,没有必要重写
类似的,还有 AccessDecisionManager 这个“决策者”,Spring security 为这个功能提供了几个默认的实现者,如 AffirmativeBased 这个类,是一个基于投票的决策器,投票器(Voter)要求实现 AccessDecisionVoter 接口,Spring security 已为我们提供了几个很有用的投票器如 RoleVoter,WebExpressionVoter
这些我们都没有必要去自定义,而且自定义出来的也没有默认实现拓展性和稳定性更好再定义一个登陆的 Controller
LoginController1 package com.cas.client2.casclient2.controller; 2 3 import org.springframework.beans.factory.annotation.Autowired; 4 import org.springframework.security.authentication.AuthenticationManager; 5 import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; 6 import org.springframework.security.cas.authentication.CasAuthenticationToken; 7 import org.springframework.security.cas.web.CasAuthenticationFilter; 8 import org.springframework.security.core.Authentication; 9 import org.springframework.security.core.context.SecurityContextHolder; 10 import org.springframework.stereotype.Controller; 11 import org.springframework.web.bind.annotation.RequestMapping; 12 13 import javax.servlet.http.HttpSession; 14 15 @SuppressWarnings("ALL") 16 @Controller 17 public class LoginController { 18 @Autowired 19 private AuthenticationManager authenticationManager; 20 21 /** 22 * 自定义登录地址 23 * @param username 24 * @param password 25 * @param session 26 * @return 27 */ 28 @RequestMapping("login.do") 29 public String login(String username,String passwod, HttpSession session){ 30 try { 31 System.out.println("进入登录请求.........."); 32 UsernamePasswordAuthenticationToken token=new UsernamePasswordAuthenticationToken(username,passwod); 33 34 Authentication authentication=authenticationManager.authenticate(token); 35 SecurityContextHolder.getContext().setAuthentication(authentication); 36 session.setAttribute("SPRING_SECURITY_CONTEXT", SecurityContextHolder.getContext()); 37 System.out.println("登录成功"); 38 return "redirect:home.html"; 39 }catch (Exception e){ 40 e.printStackTrace(); 41 return "login.html"; 42 } 43 44 } 45 }
创建几个页面:在 resources 下创建文件夹 html,用于存放 html 静态文件,
home.html1 <!DOCTYPE html> 2 <html lang="en"> 3 <head> 4 <meta charset="UTF-8"> 5 <title>HOME</title> 6 </head> 7 <body> 8 <h1>welcome to Home</h1> 9 <button onclick="javascript:location.href='/logout'">退出</button> 10 </body> 11 </html>
login.html
1 <!DOCTYPE html> 2 <html lang="en" xmlns="http://www.w3.org/1999/xhtml" xmlns:th="http://www.thymeleaf.org" 3 xmlns:sec="http://www.thymeleaf.org/thymeleaf-extras-springsecurity3"> 4 <head> 5 <meta charset="UTF-8"> 6 <title>登录</title> 7 </head> 8 9 <body> 10 <span style="color: red" id="msg"></span> 11 <form action="/login.do" method="post"> 12 <div><label> User Name : <input type="text" name="username"/> </label></div> 13 <div><label> Password: <input type="password" name="password"/> </label></div> 14 <div><input type="submit" value="Sign In"/></div> 15 <input type="checkbox" name="remember-me" value="true" th:checked="checked"/><p>Remember me</p> 16 </form> 17 18 </body> 19 <script type="text/javascript"> 20 var url=location.href 21 var param=url.split("?")[1]; 22 console.log(param); 23 if (param){ 24 var p=param.split("&"); 25 var msg=p[0].split("=")[1]; 26 document.getElementById("msg").innerHTML=msg; 27 } 28 </script> 29 </html>
admin.html
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>admin</title> </head> <body> 你好,欢迎登陆, 这是管理员界面,拥有 /admin.html 的访问权限才能访问 </body> </html>
再定义几个错误页面
在 html 文件夹下创建一个 error 文件夹,在 error 文件夹中创建 403.html,404.html,500.html;在程序遇到这些错误码时,会自动跳转到对应的页面先启动一下项目,让 spring-data-jpa 反向生成一下表结构
再往数据库插入几条数据:
用户表的密码需要放密文,我们把我们的明文密码使用我们的密码 encoder 转一下:BCryptPasswordEncoder.encode("123"); 得到密文后存到数据库的 password 字段中
用户表:资源表:即权限信息表
角色表:
角色权限中间表:
我们先不给用户配置角色,现在是空角色
启动 Spring boot 启动类,访问 localhost:8083, 检测到没登录会自动跳到登录页面,登录后自动跳转到 home.html
访问 admin.html,返回 403 页面,当前用户无权限访问
再将刚刚的角色分配给用户,再次访问
此时便可访问,大功告成!
- 部署 CAS server
cas 全称 Central Authentication Service,翻译为:中央认证服务;从名字我们便可得知,这是一个独立的服务,主要负责用户登录凭证的验证;事实也是如此,cas 有认证中心和 client 端,认证中心就是我们的 cas server,负责用户凭证的验证,需要独立部署,cas client 就是我们的各个相互信任的应用
我们从 cas 官网下载源码,从 moudle 中找到一个.war 后缀的文件,将这个文件拷出来,
改一下文件名为:cas,放到一个 Tomcat 中,启动 tomcat,(端口先改一下,如 8081),在浏览器中访问 localhost:8081/cas 即可看到 cas 的登录界面报了个警告,说我们没有配置 ssl,也就是需要配置 https,不过可以不用配置,
我们可以配置使用 http:设置 cas server 使用 http 非安全协议
主要有以下步骤:
1.WEB-INF/deployerConfigContext.xml 中在 < bean class = "org.jasig.cas.authentication.handler.support.HttpBasedServiceCredentialsAuthenticationHandler" p:httpClient-ref = "httpClient" /> 增加参数 p:requireSecure="false" ,是否需要安全验证,即 HTTPS,false 为不采用 如下:< bean class = "org.jasig.cas.authentication.handler.support.HttpBasedServiceCredentialsAuthenticationHandler" p:httpClient-ref = "httpClient" p:requireSecure= "false" />
1. WEB-INF/spring-configuration/ticketGrantingTicketCookieGenerator.xml 中将 p:cookieSecure="true" 修改为 p:cookieSecure="false"
2. WEB-INF/spring-configuration/warnCookieGenerator.xml 中将 p:cookieSecure="true" 改为 p:cookieSecure="false"
3. 在 tomcat 的 server.xml 中关闭 8443 端口,如下图
- 配置 CAS client
在之前 Spring security 的基础上,我们加入 cas 认证
在 pom.xml 中加入依赖包:1 <!-- security 对 CAS 支持 --> 2 <dependency> 3 <groupId>org.springframework.security</groupId> 4 <artifactId>spring-security-cas</artifactId> 5 </dependency>
修改一下我们的 UserDetailsServiceImpl 类,让它实现 AuthenticationUserDetailsService<CasAssertionAuthenticationToken> 接口
UserDetailsServiceImpl:1 package com.cas.client1.security; 2 3 import com.cas.client1.entity.User; 4 import com.cas.client1.service.UserService; 5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.security.cas.authentication.CasAssertionAuthenticationToken; 7 import org.springframework.security.core.userdetails.AuthenticationUserDetailsService; 8 import org.springframework.security.core.userdetails.UserDetails; 9 import org.springframework.security.core.userdetails.UserDetailsService; 10 import org.springframework.security.core.userdetails.UsernameNotFoundException; 11 import org.springframework.stereotype.Component; 12 13 /** 14 * @author Administrator 15 */ 16 @SuppressWarnings("ALL") 17 @Component 18 public class UserDetailsServiceImpl implements UserDetailsService, 19 AuthenticationUserDetailsService<CasAssertionAuthenticationToken> { 20 @Autowired 21 private UserService userService; 22 @Override 23 public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { 24 User user = userService.findByUsername(username); 25 return user; 26 } 27 28 /** 29 * 实现 AuthenticationUserDetailsService 的方法, 30 * 用于获取 cas server 返回的用户信息,再根据用户关键信息加载出用户在当前系统的权限 31 * @param token 32 * @return 33 * @throws UsernameNotFoundException 34 */ 35 @Override 36 public UserDetails loadUserDetails(CasAssertionAuthenticationToken token) throws UsernameNotFoundException { 37 String name = token.getName(); 38 System.out.println("获得的用户名:"+name); 39 User user = userService.findByUsername(name); 40 if (user==null){ 41 throw new UsernameNotFoundException(name+"不存在"); 42 } 43 return user; 44 } 45 }
在 application.properties 文件中加上以下内容:
1 # cas 服务器地址 2 cas.server.host.url=http://localhost:8081/cas 3 # cas 服务器登录地址 4 cas.server.host.login_url=${cas.server.host.url}/login 5 # cas 服务器登出地址 6 cas.server.host.logout_url=${cas.server.host.url}/logout?service=${app.server.host.url} 7 # 应用访问地址 8 app.server.host.url=http://localhost:8083 9 # 应用登录地址 10 app.login.url=/login.do 11 # 应用登出地址 12 app.logout.url=/logout
新增一个配置实体类
CasProperties
package com.cas.client1.config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;@Component
public class CasProperties {
@Value("${cas.server.host.url}")
private String casServerUrl;@Value(</span>"${cas.server.host.login_url}"<span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> String casServerLoginUrl; @Value(</span>"${cas.server.host.logout_url}"<span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> String casServerLogoutUrl; @Value(</span>"${app.server.host.url}"<span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> String appServerUrl; @Value(</span>"${app.login.url}"<span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> String appLoginUrl; @Value(</span>"${app.logout.url}"<span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">private</span><span style="color: rgba(0, 0, 0, 1)"> String appLogoutUrl;
/**get set 方法略
*/
}
再修改一下我们的 Spring security 配置类1 package com.cas.client1.security; 2 3 import com.cas.client1.config.CasProperties; 4 import org.jasig.cas.client.session.SingleSignOutFilter; 5 import org.jasig.cas.client.validation.Cas20ServiceTicketValidator; 6 import org.springframework.beans.factory.annotation.Autowired; 7 import org.springframework.context.annotation.Bean; 8 import org.springframework.context.annotation.Configuration; 9 import org.springframework.http.HttpMethod; 10 import org.springframework.security.access.AccessDecisionManager; 11 import org.springframework.security.access.AccessDecisionVoter; 12 import org.springframework.security.access.vote.AffirmativeBased; 13 import org.springframework.security.access.vote.RoleVoter; 14 import org.springframework.security.authentication.AuthenticationManager; 15 import org.springframework.security.cas.ServiceProperties; 16 import org.springframework.security.cas.authentication.CasAuthenticationProvider; 17 import org.springframework.security.cas.web.CasAuthenticationEntryPoint; 18 import org.springframework.security.cas.web.CasAuthenticationFilter; 19 import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder; 20 import org.springframework.security.config.annotation.web.builders.HttpSecurity; 21 import org.springframework.security.config.annotation.web.builders.WebSecurity; 22 import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity; 23 import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter; 24 import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; 25 import org.springframework.security.web.access.intercept.FilterSecurityInterceptor; 26 import org.springframework.security.web.authentication.logout.LogoutFilter; 27 import org.springframework.security.web.authentication.logout.SecurityContextLogoutHandler; 28 29 import java.util.ArrayList; 30 import java.util.List; 31 32 /** 33 * Spring security 配置 34 * @author youyp 35 * @date 2018-8-10 36 */ 37 @SuppressWarnings("ALL") 38 @Configuration 39 @EnableWebSecurity 40 public class SpringSecurityConfig extends WebSecurityConfigurerAdapter { 41 @Autowired 42 private CasProperties casProperties; 43 44 @Autowired 45 private UserDetailsServiceImpl userDetailsService; 46 47 @Autowired 48 private SecurityMetaDataSource securityMetaDataSource; 49 50 @Override 51 protected void configure(AuthenticationManagerBuilder auth) throws Exception { 52 super.configure(auth); 53 auth.authenticationProvider(casAuthenticationProvider()); 54 } 55 56 @Override 57 public void configure(WebSecurity web) throws Exception { 58 web.ignoring().antMatchers("/js/**","/css/**","/img/**","/*.ico","/login.html", 59 "/error","/login.do"); 60 //web.ignoring().antMatchers("/js/**","/css/**","/img/**","/*.ico",,"/home"); 61 //web.ignoring().antMatchers("/**"); 62 // super.configure(web); 63 64 } 65 66 @Override 67 protected void configure(HttpSecurity http) throws Exception { 68 System.out.println("配置 Spring security"); 69 http.formLogin() 70 //指定登录页是”/login” 71 //.loginPage("/login.html").permitAll() 72 //.loginProcessingUrl("/login.do").permitAll() 73 //.defaultSuccessUrl("/home",true) 74 //.permitAll() 75 //登录成功后可使用 loginSuccessHandler() 存储用户信息,可选。 76 //.successHandler(loginSuccessHandler()).permitAll() 77 .and() 78 .logout().permitAll() 79 //退出登录后的默认网址是”/home” 80 //.logoutSuccessUrl("/home.html") 81 //.permitAll() 82 .invalidateHttpSession(true) 83 .and() 84 //登录后记住用户,下次自动登录, 数据库中必须存在名为 persistent_logins 的表 85 .rememberMe() 86 .tokenValiditySeconds(1209600) 87 .and() 88 .csrf().disable() 89 //其他所有资源都需要认证,登陆后访问 90 .authorizeRequests().anyRequest().fullyAuthenticated(); 91 http.exceptionHandling().authenticationEntryPoint(casAuthenticationEntryPoint()) 92 .and() 93 .addFilterAt(casAuthenticationFilter(),CasAuthenticationFilter.class) 94 .addFilterBefore(casLogoutFilter(),LogoutFilter.class) 95 .addFilterBefore(singleSignOutFilter(),CasAuthenticationFilter.class); 96 /** 97 * FilterSecurityInterceptor 本身属于过滤器,不能在外面定义为 @Bean, 98 * 如果定义在外面,则这个过滤器会被独立加载到 webContext 中,导致请求会一直被这个过滤器拦截 99 * 加入到 Springsecurity 的过滤器链中,才会使它完整的生效 100 */ 101 http.addFilterBefore(filterSecurityInterceptor(),FilterSecurityInterceptor.class); 102 } 103 104 /** 105 * 注意:这里不能加 @Bean 注解 106 * @return 107 * @throws Exception 108 */ 109 // @Bean 110 public FilterSecurityInterceptor filterSecurityInterceptor() throws Exception { 111 FilterSecurityInterceptor filterSecurityInterceptor=new FilterSecurityInterceptor(); 112 filterSecurityInterceptor.setSecurityMetadataSource(securityMetaDataSource); 113 filterSecurityInterceptor.setAuthenticationManager(authenticationManager()); 114 filterSecurityInterceptor.setAccessDecisionManager(affirmativeBased()); 115 return filterSecurityInterceptor; 116 } 117 118 /** 119 * 认证入口 120 * <p> 121 * <b>Note:</b> 浏览器访问不可直接填客户端的 login 请求, 若如此则会返回 Error 页面,无法被此入口拦截 122 * </p> 123 * @return 124 */ 125 @Bean 126 public CasAuthenticationEntryPoint casAuthenticationEntryPoint(){ 127 CasAuthenticationEntryPoint casAuthenticationEntryPoint=new CasAuthenticationEntryPoint(); 128 casAuthenticationEntryPoint.setLoginUrl(casProperties.getCasServerLoginUrl()); 129 casAuthenticationEntryPoint.setServiceProperties(serviceProperties()); 130 return casAuthenticationEntryPoint; 131 } 132 133 @Bean 134 public ServiceProperties serviceProperties() { 135 ServiceProperties serviceProperties=new ServiceProperties(); 136 serviceProperties.setService(casProperties.getAppServerUrl()+casProperties.getAppLoginUrl()); 137 serviceProperties.setAuthenticateAllArtifacts(true); 138 return serviceProperties; 139 } 140 141 // @Bean 142 public CasAuthenticationFilter casAuthenticationFilter() throws Exception { 143 CasAuthenticationFilter casAuthenticationFilter=new CasAuthenticationFilter(); 144 casAuthenticationFilter.setAuthenticationManager(authenticationManager()); 145 casAuthenticationFilter.setFilterProcessesUrl(casProperties.getAppLoginUrl()); 146 // casAuthenticationFilter.setAuthenticationSuccessHandler( 147 // new SimpleUrlAuthenticationSuccessHandler("/home.html")); 148 return casAuthenticationFilter; 149 } 150 151 @Bean 152 public CasAuthenticationProvider casAuthenticationProvider(){ 153 CasAuthenticationProvider casAuthenticationProvider=new CasAuthenticationProvider(); 154 casAuthenticationProvider.setAuthenticationUserDetailsService(userDetailsService); 155 156 casAuthenticationProvider.setServiceProperties(serviceProperties()); 157 casAuthenticationProvider.setTicketValidator(cas20ServiceTicketValidator()); 158 casAuthenticationProvider.setKey("casAuthenticationProviderKey"); 159 return casAuthenticationProvider; 160 } 161 162 @Bean 163 public Cas20ServiceTicketValidator cas20ServiceTicketValidator() { 164 return new Cas20ServiceTicketValidator(casProperties.getCasServerUrl()); 165 } 166 167 // @Bean 168 public SingleSignOutFilter singleSignOutFilter(){ 169 SingleSignOutFilter singleSignOutFilter=new SingleSignOutFilter(); 170 singleSignOutFilter.setCasServerUrlPrefix(casProperties.getCasServerUrl()); 171 singleSignOutFilter.setIgnoreInitConfiguration(true); 172 return singleSignOutFilter; 173 } 174 175 // @Bean 176 public LogoutFilter casLogoutFilter(){ 177 LogoutFilter logoutFilter = new LogoutFilter(casProperties.getCasServerLogoutUrl(), new SecurityContextLogoutHandler()); 178 logoutFilter.setFilterProcessesUrl(casProperties.getAppLogoutUrl()); 179 return logoutFilter; 180 } 181 182 /** 183 * 重写 AuthenticationManager 获取的方法并且定义为 Bean 184 * @return 185 * @throws Exception 186 */ 187 @Override 188 @Bean 189 public AuthenticationManager authenticationManagerBean() throws Exception { 190 return super.authenticationManagerBean(); 191 } 192 193 @Autowired 194 public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception { 195 //指定密码加密所使用的加密器为 passwordEncoder() 196 //需要将密码加密后写入数据库 197 //auth.userDetailsService(userDetailsService).passwordEncoder(passwordEncoder()); 198 //auth.eraseCredentials(false); 199 } 200 201 @Bean 202 public BCryptPasswordEncoder passwordEncoder() { 203 204 return new BCryptPasswordEncoder(4); 205 } 206 207 208 /** 209 * 定义决策管理器,这里可直接使用内置的 AffirmativeBased 选举器, 210 * 如果需要,可自定义,继承 AbstractAccessDecisionManager,实现 decide 方法即可 211 * @return 212 */ 213 @Bean 214 public AccessDecisionManager affirmativeBased(){ 215 List<AccessDecisionVoter<? extends Object>> voters=new ArrayList<>(); 216 voters.add(roleVoter()); 217 System.out.println("正在创建决策管理器"); 218 return new AffirmativeBased(voters); 219 } 220 221 /** 222 * 定义选举器 223 * @return 224 */ 225 @Bean 226 public RoleVoter roleVoter(){ 227 //这里使用角色选举器 228 RoleVoter voter=new RoleVoter(); 229 System.out.println("正在创建选举器"); 230 voter.setRolePrefix("AUTH_"); 231 System.out.println("已将角色选举器的前缀修改为 AUTH_"); 232 return voter; 233 } 234 235 236 @Bean 237 public LoginSuccessHandler loginSuccessHandler() { 238 return new LoginSuccessHandler(); 239 } 240 241 242 }
这里我们新增了几个 filter,请注意,这几个 filter 定义时都不能配置 @Bean 注解,原因以上相同,这几个 filter 都要加入到 springSecurity 的 FilterChain 中,而不是直接加入到 web 容器的 FilterChain 中
再修改一下 LoginController1 package com.cas.client1.controller; 2 3 import org.springframework.beans.factory.annotation.Autowired; 4 import org.springframework.security.authentication.AuthenticationManager; 5 import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; 6 import org.springframework.security.cas.web.CasAuthenticationFilter; 7 import org.springframework.security.core.Authentication; 8 import org.springframework.security.core.context.SecurityContextHolder; 9 import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter; 10 import org.springframework.stereotype.Controller; 11 import org.springframework.web.bind.annotation.RequestMapping; 12 13 import javax.servlet.http.HttpSession; 14 15 @SuppressWarnings("Duplicates") 16 @Controller 17 public class LoginController { 18 @Autowired 19 private AuthenticationManager authenticationManager; 20 21 /** 22 * 自定义登录地址 23 * @param username 24 * @param password 25 * @param session 26 * @return 27 */ 28 @RequestMapping("login.do") 29 public String login(String ticket, HttpSession session){ 30 try { 31 System.out.println("进入登录请求.........."); 32 //cas 单点登录的用户名就是:_cas_stateful_ ,用户凭证是 server 传回来的 ticket 33 String username = CasAuthenticationFilter.CAS_STATEFUL_IDENTIFIER; 34 UsernamePasswordAuthenticationToken token=new UsernamePasswordAuthenticationToken(username,ticket); 35 Authentication authentication=authenticationManager.authenticate(token); 36 SecurityContextHolder.getContext().setAuthentication(authentication); 37 session.setAttribute("SPRING_SECURITY_CONTEXT", SecurityContextHolder.getContext()); 38 System.out.println("登录成功"); 39 return "redirect:home.html"; 40 }catch (Exception e){ 41 e.printStackTrace(); 42 return "login.html"; 43 } 44 45 } 46 }
这时,之前负责登录的 loginController 不再是验证用户名和密码正不正确了,因为用户名密码的验证已经交给 cas server 了,LoginController 的工作就是接收 cas server 重定向时传回来的 ticket,验证 ticket 的有效性,如果没有异常,则会进入到 UserDetailsServiceImpl 中的 loadUserDetails 方法,并根据用户名加载用户权限等信息,然后我们再将用户信息存入 Session,完成本地登录,本地登录之后,用户每次请求时,就不需要再次验证 ticket 了,而是验证 Session
到这里,cas client 已经配置完成,为了看清楚流程,我们以 debug 模式启动一下项目,在 loginController 的 login 方法开头打一个断点,打开浏览器调试模式(F12),切换到 network 看请求,在浏览器中输入:localhost:8083, 浏览器会自动重定向到 cas server 的登录页面,如下图:
我们输入一个数据库中有的用户名,再在密码栏中输入一次用户名,因为这里的 cas server 验证方式还没改,只要求用户名和密码相同就可通过验证,后面我会研究一下怎么修改 cas server 的验证方式为数据库验证
如输入:用户名:user 密码:user
点击登录,验证成功后,我们看 F12 network 请求,发现浏览器发送了两个请求,一个是 8081 的,也就是 cas server 的,另外一个是 8083 的,也就是我们的 client 端的,如图:另一个
因为我们在后台开了 debug 模式,打了断点,所以后面这个请求一直在 pending 状态,我们先看第一个请求的详细情况:
很明显的,这个请求发送了我们的用户名和密码,由此可知,这个请求的作用就是负责在 cas server 后台验证用户名的密码,验证成功后,会自动重定向到第二个请求
我们再来看第二个请求:这个请求就是我们 cas client 所配置的登录地址,此时这个请求后面自动带上了一个名为 ticket 的参数,参数值是一串自动生成的随机字符串,由 cas server 生成的
我们再回到后台,没什么错误的话,我们可以看到 LoginController 接收到了这个参数,我们先在 UserDetailsServiceImpl 类的 loadUserDetails 方法的开头打一个断点,按 F8 让调试器跑走,此时,我们就可以看到调试器跳到了我们刚刚打的 UserDetasServiceImpl 的断点中,再看看参数可以看出,我们接收到了 cas server 认证完 ticket 后传回来的用户名,我们根据用户名加载对应的权限,返回即可,此时我们再次按 F8 跳走
再回到界面,发现我们已经可以访问页面了:下一步,就是验证多个应用之间是否能只登陆一次就不用再登陆了;
我们将当前项目拷贝一份,改名称为 cas-client2(maven 的 groupId 和 artifactId),再修改一下端口为 8082,,记得对应的 cas 配置也要改:
启动项目
先访问 localhost:8082发现它自动跳转到了 8081 的 cas server
再打开另外一个浏览器标签,访问 localhost:8083发现它也自动跳到了 cas 的登录页面,我们先在这里输入账号密码登录:
登录成功后,我们再切换回刚刚没登录的 8082 的网页标签,刷新一下,
ok,8082 也不用登陆了,大功告成!
源码地址:
https://github.com/yupingyou/casclient.git
另:Spring security 原本默认有个 /login 和 /logout 的 handler,(以前不是这个地址,不知道从哪个版本开始改了,以前好像是 _spring_security_check, 大概是这个,记不太清,我用了 4 以后就发现地址变了),但是我发现我访问 /login 的时候出现 404,但 /logout 可以访问,没发现什么原因,后来我就自定义一个登陆了,也就是我配置的 /login.do,代替了默认的 /login
第一次动手写这么长的博客............... 累