本文最后更新于:1 年前
SpringSecurity
安全是开发者永远绕不开的话题,一个不安全的网站,往往存在着各种致命漏洞,只要被不法分子稍加利用,就能直接击溃整个网站,甚至破坏网站宝贵的用户数据。而用户的授权校验,则是网站安全系统的典型代表,这也是用户访问网站的第一关,我们需要一个更加安全和可靠的授权校验框架,才能让我们的网站更加稳定。
SpringSecurity是一个基于Spring开发的非常强大的权限验证框架,其核心功能包括:
- 认证 (用户登录)
- 授权 (此用户能够做哪些事情)
- 攻击防护 (防止伪造身份攻击)
网络安全基础
网络安全是当今互联网时代非常重要的一个议题。在信息爆炸的今天,网络安全问题频频发生,给个人和组织带来了严重的损失和威胁,随着技术的发展和互联网的普及,我们越来越意识到网络安全已经成为一个全球性的挑战。本部分,我们会给各位小伙伴介绍网络安全的相关概念,以及常见的Web服务器攻击形式,如果你已经了解相关内容,可以直接跳过本板块。
其中比较典型的案例有以下几个:
在2017年,一款名叫WannaCry的勒索软件席卷全球,导致全球大量计算机受到影响,得益于全球网络的发达,这款病毒从小规模很快发展至全球范围,勒索病毒是自熊猫烧香以来影响力最大的病毒之一。
WannaCry(又叫Wanna Decryptor),一种“蠕虫式”的勒索病毒软件,大小3.3MB,由不法分子利用NSA(National Security Agency,美国国家安全局)泄露的危险漏洞“EternalBlue”(永恒之蓝)进行传播 [1] 。勒索病毒肆虐,俨然是一场全球性互联网灾难,给广大电脑用户造成了巨大损失。最新统计数据显示,100多个国家和地区超过10万台电脑遭到了勒索病毒攻击、感染。 [2] 勒索病毒是自熊猫烧香以来影响力最大的病毒之一。WannaCry勒索病毒全球大爆发,至少150个国家、30万名用户中招,造成损失达80亿美元,已经影响到金融,能源,医疗等众多行业,造成严重的危机管理问题。
除了病毒在网络上传播外,还有非常恶心的DDOS攻击,这种攻击方式成本低,效率高,只要持续一段时间就能导致没有特殊防御的网站无法正常运作:
2022年4月,郑州警方接到报警称,某政府网站平台于近日遭受多次DDoS攻击,导致平台访问量瞬间暴增多倍,造成数十家政府网站和政务新媒体账号无法正常访问。接到报警后,郑州警方立即开展侦查调查,第一时间锁定犯罪嫌疑人张某某,仅22小时就将犯罪嫌疑人张某某抓捕到案。
经审查,张某某为某医院网络安全部技术维护人员,2022年4月2日,其个人网站被DDoS攻击,导致网站无法登陆。为减少攻击对其个人网站的影响,张某某私自将个人网站域名解析地址变更为某政府网站平台地址,“转嫁”攻击流量,致使该政府网站平台被恶意网络流量攻击,多家政府网站、政务新媒体账号不能正常使用。
目前,张某某因涉嫌破坏计算机信息系统犯罪被公安机关移送起诉,案件正在进一步侦办中。
信息泄露也是非常严重的网络安全问题,我们的个人信息是我们的隐私,而在网络发达的今天,在各大APP上填写的信息很有可能会被第三方获取,从中谋取利益。
今年早些时候便已发现相关安全漏洞的网络安全专家称, 一个常见漏洞导致了这场有记录以来最大规模的个人数据泄露,也是中国所遭遇最大规模的网络安全事件,造成数据被公开在互联网上,供人取用。
据这些网络安全专家称,上海警方的这些记录是被安全存储的,其中包含个人姓名、身份证号码、电话号码以及警情信息,涉及近10亿中国公民的数据。他们说,但一个用于管理和访问该数据库的显示界面(dashboard)被设置在一个公开网址上,没有加设密码,任何有相对基本技术知识的人都可以轻松访问、复制或窃取库中的海量信息。
暗网情报公司Shadowbyte的创始人Vinny Troia说:“他们把这么多数据暴露在外,这太疯狂了。”这家公司专门在网上扫描搜寻存在安全漏洞的数据库,早在今年1月扫描时发现了上海警方的这个数据库。
个人信息数据一旦泄露,相当于别人可以通过网络直接定位你的住址、电话号码、各种社交账号、身份证信息甚至是机票、火车票、酒店开房信息等,做的再绝一定,如果这个酒店被人偷偷放了针孔摄像头,甚至还能根据记录查到你开房视频,这些事情光是想想都可怕,这等同于在互联网上“裸奔”。
网络安全问题非同小可,而我们作为网站的开发者,更应该首当其冲解决这些潜在问题。接下来,我们会介绍几个常见的Web网站攻击方式,以及在后续使用SpringSecurity时如何去防范这些攻击行为。
测试环境搭建
为了测试我们之前的网站安全性,这里我们基于Mvc框架重新搭建一个采用之前的验证方式的简易网站,首先是登录界面部分:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>登录白马银行</title> </head> <body> <form action="login" method="post"> <label> 用户名: <input name="username" type="text"> </label> <label> 密码: <input name="password" type="password"> </label> <button type="submit">登录</button> </form> <div th:if="${status}">登录失败,用户名或密码错误!</div> </body> </html>
|
接着是登录之后的首页:
1 2 3 4 5 6 7 8 9 10
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>白马银行 - 首页</title> </head> <body>
</body> </html>
|
接着是Controller部分:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
| @Controller public class HelloController { @PostMapping("/login") public String login(@RequestParam String username, @RequestParam String password, HttpSession session, Model model){ if("test".equals(username) && "123456".equals(password)) { session.setAttribute("login", true); return "redirect:/"; } else { model.addAttribute("status", true); return "login"; } }
@GetMapping("/") public String index(HttpSession session){ if(session.getAttribute("login") != null) { return "index"; }else { return "login"; } } }
|
这样我们就可以进行简单登录了:
接着我们在首页加一个转账操作,要求填写转账人账号名称:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
| @ResponseBody @PostMapping("/pay") public JSONObject pay(@RequestParam String account, HttpSession session){ JSONObject object = new JSONObject(); if(session.getAttribute("login") != null) { System.out.println("转账给"+account+"成功,交易已完成!"); object.put("success", true); } else { System.out.println("转账给"+account+"失败,用户未登录!"); object.put("success", false); } return object; }
|
接着我们在页面中添加一个简单的转账操作按键:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>白马银行 - 首页</title> <script src="https://unpkg.com/axios@1.1.2/dist/axios.min.js"></script> </head> <body> <div> <label> 转账账号: <input type="text" id="account"/> </label> <button onclick="pay()">立即转账</button> </div> </body> </html>
<script> function pay() { const account = document.getElementById("account").value axios.post('/mvc/pay', { account: account }, { headers: { 'Content-Type': 'application/x-www-form-urlencoded' } }).then(({data}) => { if(data.success) alert("转账成功") else alert("转账失败") }) } </script>
|
这样我们就成功搭建好网络安全的测试项目了,各位小伙伴请将这个项目进行保存,后面需要重复使用。
CSRF跨站请求伪造攻击
CSRF是我们要介绍的第一种攻击形式,这种攻击方式非常好理解。
在JavaWeb阶段已经了解了Session和Cookie的机制,在一开始的时候,服务端会给浏览器一个名为JSESSIONID的Cookie信息作为会话的唯一凭据,只要用户携带此Cookie访问我们的网站,那么我们就可以认定此会话属于哪个浏览器用户。因此,只要此会话的用户执行了登录操作,那么就可以随意访问个人信息等内容。
尝试模拟一下这种操作,来编写一个钓鱼网站:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>坤坤炒粉放鸡精视频在线观看</title> <script src="https://unpkg.com/axios@1.1.2/dist/axios.min.js"></script> </head> <body> <iframe name="hiddenIframe" hidden></iframe> <form action="http://localhost:8080/mvc/pay" method="post" target="hiddenIframe"> <input type="text" name="account" value="黑客" hidden> <button type="submit">点击下载全套视频</button> </form> </body> </html>
|
这个页面并不是我们官方提供的页面,而是不法分子搭建的恶意网站。我们发现此页面中有一个表单,但是表单中的输入框被隐藏了,而我们看到的只有一个按钮,我们不知道这是一个表单,也不知道表单会提交给那个地址,这时整个页面就非常有迷惑性了。如果我们点击此按钮,那么整个表单的数据会以POST的形式发送给我们的服务端(会携带之前登陆我们网站的Cookie信息),但是这里很明显是另一个网站跳转,通过这样的方式,恶意网站就成功地在我们毫不知情的情况下引导我们执行了转账操作,当你发现上当受骗时,钱已经被转走了。
我们首先作为用户,先在正常的网站进行登录:
接着我们假装自己上当,进入到我们的钓鱼网站:
现在我们毫不知情,如果是正常人思维的话,就会直接点击下载全套视频,恭喜,此时后台已经转账成功了,留下一脸懵逼的你:
而这种构建恶意页面,引导用户访问对应网站执行操作的方式称为:跨站请求伪造(CSRF,Cross Site Request Forgery)
显然,我们之前编写的图书管理系统就存在这样的安全漏洞,而SpringSecurity就解决了这样的问题。
当然,除了通过我们自己SpringSecurity使用去解决之外,随着现在的浏览器不断发展,安全性越来越受到重视,很多浏览器都有SameSite保护机制,当用户在两个不同域名的站点操作时,默认情况下Cookie就会被自动屏蔽:
SameSite是一种安全机制,旨在防止跨站点请求伪造(CSRF)攻击,它通过限制第三方Cookie的使用来实现这一目的。在Chrome浏览器中,SameSite默认为Lax,这意味着第三方Cookie只能在用户导航到与原始站点相同的站点时发送。这同样大大提升了用户的安全性,让黑客少了许多可乘之机,不过这个机制对做实施的同学(可能)不太友好。
SFA会话固定攻击
这同样是利用Cookie中相同的JSESSIONID进行的攻击,会话固定攻击(Session fixation attack)是一种针对Web应用程序的安全漏洞攻击,攻击者利用这种漏洞,将一个有效的会话ID分配给用户,并诱使用户在该会话中进行操作,然后攻击者可以利用该会话ID获取用户的权限,或者通过此会话继续进行其他攻击。
简单来说,就是黑客把他的JSESSIONID直接给你,你一旦使用这个ID登录,那么在后端这个ID就被认定为已登录状态,那么也就等同于他直接进入了已登录状态,从而直接访问你账号的任意内容,执行任意操作。
攻击者通常使用以下几种方式进行会话固定攻击:
- 会话传递:攻击者通过URL参数、表单隐藏字段、cookie等方式将会话ID传递给用户。当用户使用该会话ID登录时,攻击者就能利用该会话ID获取用户的权限。
- 会话劫持:攻击者利用劫持用户与服务器之间的通信流量,获取到用户的会话ID,然后利用该会话ID冒充用户进行操作。
- 会话劫持:攻击者事先获取到会话ID,并将其分配给用户,之后通过其他方式欺骗用户登录该会话。这样,攻击者就可以利用会话ID获取用户的权限。
这里我们来尝试一下第一种方案,这里我们首先用另一个浏览器访问目标网站,此时需要登录,开始之前记得先清理一下两个浏览器的缓存,否则可能无法生效:
这里我们直接记录下这个JSESSIONID,然后将其编写到我们的诈骗网站中,这里有一个恶意脚本,会自动将对应用户的Cookie进行替换,变成我们的JSESSIONID值:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
| <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>冠希哥全套视频</title> <script src="https://unpkg.com/axios@1.1.2/dist/axios.min.js"></script> </head> <body> <script> document.cookie = "JSESSIONID=6AAF677EC2B630704A80D36311F08E01; path=/mvc; domain=localhost" location.href = 'http://localhost:8080/mvc/' </script> </body> </html>
|
接着我们访问这个恶意网站,然后再作为用户,去正常访问目标网站进行登录操作:
可以看到此时用户的浏览器JSESSIONID值为刚刚恶意网站伪造的值,现在我们来进行登录操作,此时我们回到一开始的浏览器,刷新之后,我们发现这个浏览器同样已经登录成功了,原理其实很简单,相当于让用户直接帮我们登录了,是不是感觉特别危险?
当然,现在的浏览器同样有着对应的保护机制,Tomcat发送的SESSIONID默认是勾选了 HttpOnly 选项的,一旦被设定是无法被随意修改的,当然前提是先得正常访问一次网站才行,否则仍然存在安全隐患。
HttpOnly是Cookie中一个属性,用于防止客户端脚本通过document.cookie属性访问Cookie,有助于保护Cookie不被跨站脚本攻击窃取或篡改。但是,HttpOnly的应用仍存在局限性,一些浏览器可以阻止客户端脚本对Cookie的读操作,但允许写操作;此外大多数浏览器仍允许通过XMLHTTP对象读取HTTP响应中的Set-Cookie头。
为了彻底杜绝这个问题,登录成功之后应该重新给用户分配一个新的JSESSIONID才行,而这些都由SpringSecurity帮我们实现了。
XSS跨站脚本攻击
前面我们介绍了两种攻击方式,不过都是从外部干涉,在外部无法干涉的情况下,我们也可以从内部击溃网站,接下来我们隆重介绍XSS跨站脚本攻击方式。
XSS(跨站脚本攻击)是一种常见的网络安全漏洞,攻击者通过在合法网站中注入恶意脚本代码来攻击用户。当用户访问受到注入攻击的页面时,恶意代码会在用户的浏览器中执行,从而导致攻击者能够窃取用户的敏感信息、诱导用户操作、甚至控制用户的账号。
XSS攻击常见的方式有三种:
- 存储型XSS攻击:攻击者将恶意代码存储到目标网站的数据库中,当其他用户访问包含恶意代码的页面时,恶意代码会被执行。
- 反射型XSS攻击:攻击者将恶意代码嵌入到URL中,当用户点击包含恶意代码的URL时,恶意代码会被执行。
- DOM-based XSS攻击:攻击者利用前端JavaScript代码的漏洞,通过修改页面的DOM结构来执行恶意代码。
在一些社交网站上,用户可以自由发帖,而帖子是以富文本形式进行编辑和上传的,发送给后台的帖子往往是直接以HTML代码的形式,这个时候就会给黑客可乘之机了。
正常情况下,用户发帖会向后端上传以下内容,这些是经过转换得到的正常HTML代码,方便后续直接展示:
1 2 3 4 5 6
| <div class="content ql-editor"> <p> <strong>萨达睡觉了大数据</strong> </p> <p>撒大大撒大声地</p> </div>
|
而现在,黑客不走常规的方式发帖,而是发送以下内容给服务端:
1 2 3 4 5 6
| <div class="content ql-editor"> <p οnlοad="alert('xss')"> <strong>萨达睡觉了大数据</strong> </p> <p>撒大大撒大声地</p> </div>
|
可以看到p
标签上添加了一段JS恶意脚本,黑客可以利用这种特性,获取用户的各种信息,甚至直接发送到他的后台,这样,我们的个人信息就从网站内部被泄露了。
XSS漏洞最早被发现是在1996年,由于JavaScript的出现,导致在Web应用程序中存在了一些安全问题。在1997年,高智文(Gareth Owen)也就是“XSS之父”,在他的博客中描述了一种称为“脚本注入”(script injection)的攻击技术,这就是XSS漏洞的前身。从那时起,XSS漏洞便成为了Web应用程序中的一种常见安全漏洞。
这种攻击一般需要前端配合后端进行防御,或者后端对前端发送的内容进行安全扫描并处理。
开发环境配置
我们继续使用之前的测试项目进行教学,首先我们需要导入SpringSecurity的相关依赖,它不仅仅是一个模块,我们可以根据需求导入需要的模块,常用的是以下两个:
1 2 3 4 5 6 7 8 9 10
| <dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-web</artifactId> <version>6.1.1</version> </dependency> <dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-config</artifactId> <version>6.1.1</version> </dependency>
|
接着我们需要配置SpringSecurity,与Mvc一样,需要一个初始化器:
1 2 3 4
| public class SecurityInitializer extends AbstractSecurityWebApplicationInitializer { }
|
接着我们需要再创建一个配置类用于配置 SpringSecurity:
1 2 3 4 5
| @Configuration @EnableWebSecurity public class SecurityConfiguration { }
|
接着在根容器中添加此配置文件即可:
1 2 3 4
| @Override protected Class<?>[] getRootConfigClasses() { return new Class[]{MainConfiguration.class, SecurityConfiguration.class}; }
|
这样,SpringSecurity的配置就完成了,我们再次运行项目,会发现无法进入的我们的页面中,无论我们访问哪个页面,都会进入到SpringSecurity为我们提供的一个默认登录页面,之后我们会讲解如何进行配置。
认证
认证是我们网站的第一步,用户需要登录之后才能进入,这一部分我们将详细介绍如何使用SpringSecurity实现用户登录。
基于内存验证
首先我们来看看最简单的基于内存的配置,也就是说我们直接以代码的形式配置我们网站的用户和密码,配置方式非常简单,只需要在Security配置类中注册一个Bean即可:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
@Bean public UserDetailsService userDetailsService() { UserDetails user = User.withDefaultPasswordEncoder() .username("user") .password("password") .roles("USER") .build(); UserDetails admin = User.withDefaultPasswordEncoder() .username("admin") .password("password") .roles("ADMIN", "USER") .build(); return new InMemoryUserDetailsManager(user, admin); } }
|
配置完成后,我们就可以前往登录界面,进行登录操作了,登录成功后,就可以访问到我们之前的界面了,并且为了防止我们之前提到的会话固定问题,在登录之后,JSESSIONID会得到重新分配,当我们想要退出时,也可以直接访问:http://localhost:8080/mvc/logout 地址,我们会进入到一个退出登录界面,退出登录后就需要重新登录才能访问我们的网站了。
可以发现,在有了SpringSecurity之后,我们网站的登录验证模块相当于直接被接管了,因此,从现在开始,我们的网站不需要再自己编写登录模块了,这里我们可以直接去掉,只留下主页面:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| @Controller public class HelloController {
@GetMapping("/") public String index(){ return "index"; }
@ResponseBody @PostMapping("/pay") public JSONObject pay(@RequestParam String account){ JSONObject object = new JSONObject(); System.out.println("转账给"+account+"成功,交易已完成!"); object.put("success", true); return object; } }
|
这样,我们的网站就成功用上了更加安全的SpringSecurity框架了。细心的小伙伴可能发现了,我们在配置用户信息的时候,报了黄标,实际上这种方式存储密码并不安全:
这是因为SpringSecurity的密码校验不推荐直接使用原文进行比较,而是使用加密算法将密码进行加密(更准确地说应该进行Hash处理,此过程是不可逆的,无法解密),最后将用户提供的密码以同样的方式加密后与密文进行比较。对于我们来说,用户提供的密码属于隐私信息,直接明文存储并不好,而且如果数据库内容被窃取,那么所有用户的密码将全部泄露,这是我们不希望看到的结果,我们需要一种既能隐藏用户密码也能完成认证的机制,而Hash处理就是一种很好的解决方案,通过将用户的密码进行Hash值计算,计算出来的结果一般是单向的,无法还原为原文,如果需要验证是否与此密码一致,那么需要以同样的方式加密再比较两个Hash值是否一致,这样就很好的保证了用户密码的安全性。
因此,我们在配置用户信息的时候,可以使用官方提供的BCrypt加密工具:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
| @Configuration @EnableWebSecurity public class SecurityConfiguration { @Bean public PasswordEncoder passwordEncoder(){ return new BCryptPasswordEncoder(); }
@Bean public UserDetailsService userDetailsService(PasswordEncoder encoder) { UserDetails user = User .withUsername("user") .password(encoder.encode("password")) .roles("USER") .build(); System.out.println(encoder.encode("password")); UserDetails admin = User .withUsername("admin") .password(encoder.encode("password")) .roles("ADMIN", "USER") .build(); return new InMemoryUserDetailsManager(user, admin); } }
|
这样,我们存储的密码就是更加安全的密码了:
这样,一个简单的权限校验就配置完成了,是不是感觉用起来还是挺简单的?
不过,可能会有小伙伴发现,所有的POST请求都被403了:
这是因为SpringSecurity自带了 csrf 防护,需求我们在POST请求中携带页面中的 csrfToken 才可以,否则一律进行拦截操作,这里我们可以将其嵌入到页面中,随便找一个地方添加以下内容:
1
| <input type="text" th:id="${_csrf.getParameterName()}" th:value="${_csrf.token}" hidden>
|
接着在axios发起请求时,携带这个input的value值:
1 2 3 4 5 6 7 8
| function pay() { const account = document.getElementById("account").value const csrf = document.getElementById("_csrf").value axios.post('/mvc/pay', { account: account, _csrf: csrf }, { ...
|
如果后续各位小伙伴遇到那种需要在form表单中提交的情况,也可以直接像下面这样给塞到表单里:
1 2 3 4 5
| <form action="/xxxx" method="post"> ... <input type="text" th:name="${_csrf.getParameterName()}" th:value="${_csrf.token}" hidden> ... </form>
|
实际上现在的浏览器已经很安全了,完全不需要使用自带的csrf防护,后面我们会讲解如何通过配置关闭csrf防护。这里温馨提醒一下,在后续各位小伙伴跟我们的实战项目时,如果遇到诸如401、403这种错误时,优先查看你的SpringSecurity配置是否错误。
从Spring Security 4.0开始,默认情况下会启用CSRF保护,以防止CSRF攻击应用程序,Spring Security CSRF会针对PATCH,POST,PUT和DELETE方法的请求(不仅仅只是登陆请求,这里指的是任何请求路径)进行防护,而这里的登陆表单正好是一个POST类型的请求。在默认配置下,无论是否登陆,页面中只要发起了PATCH,POST,PUT和DELETE请求一定会被拒绝,并返回403错误(注意,这里是个究极大坑,这个没有任何提示,直接403,因此如果你不知道的话根本不清楚是什么问题,就一直卡这里了)**,需要在请求的时候加入csrfToken才行,也就是”83421936-b84b-44e3-be47-58bb2c14571a”,正是csrfToken,如果提交的是表单类型的数据,那么表单中必须包含此Token字符串,键名称为”_csrf”;如果是JSON数据格式发送的,那么就需要在请求头中包含此Token字符串。
基于数据库验证
前面我们已经实现了直接认证的方式,但是实际项目中往往都是将用户信息存储在数据库中,那么如何将其连接到数据库,通过查询数据库中的用户信息来进行用户登录呢?
官方默认提供了可以直接使用的用户和权限表设计,根本不需要我们来建表,直接在Navicat中执行以下查询:
1 2 3
| create table users(username varchar(50) not null primary key,password varchar(500) not null,enabled boolean not null); create table authorities (username varchar(50) not null,authority varchar(50) not null,constraint fk_authorities_users foreign key(username) references users(username)); create unique index ix_auth_username on authorities (username,authority);
|
接着我们添加Mybatis和MySQL相关的依赖:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
| <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.5.13</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>3.0.2</version> </dependency> <dependency> <groupId>com.mysql</groupId> <artifactId>mysql-connector-j</artifactId> <version>8.0.31</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>6.0.10</version> </dependency>
|
接着我们编写配置类:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
@Bean PasswordEncoder passwordEncoder(){ return new BCryptPasswordEncoder(); }
@Bean public DataSource dataSource(){ return new PooledDataSource("com.mysql.cj.jdbc.Driver", "jdbc:mysql://localhost:3306/test", "root", "123456"); }
@Bean public UserDetailsService userDetailsService(DataSource dataSource, PasswordEncoder encoder) { JdbcUserDetailsManager manager = new JdbcUserDetailsManager(dataSource); manager.createUser(User.withUsername("user") .password(encoder.encode("password")).roles("USER").build()); return manager; } }
|
启动后,可以看到两张表中已经自动添加好对应的数据了:
我们可以直接尝试进行登录,使用方式和之前是完全一样的:
这样,当我们下次需要快速创建一个用户登录的应用程序时,直接使用这种方式就能快速完成了,是不是感觉特别方便。
无论是我们上节课认识的 InMemoryUserDetailsManager
还是现在认识的 JdbcUserDetailsManager
,他们都是实现自 UserDetailsManager
接口,这个接口中有着一套完整的增删改查操作,方便我们直接对用户进行处理:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
| public interface UserDetailsManager extends UserDetailsService { void createUser(UserDetails user);
void updateUser(UserDetails user);
void deleteUser(String username);
void changePassword(String oldPassword, String newPassword);
boolean userExists(String username); }
|
通过使用UserDetailsManager对象,我们就能快速执行用户相关的管理操作,比如我们可以直接在网站上添加一个快速重置密码的接口,首先需要配置一下JdbcUserDetailsManager,为其添加一个AuthenticationManager用于原密码的校验:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
...
private AuthenticationManager authenticationManager(UserDetailsManager manager, PasswordEncoder encoder){ DaoAuthenticationProvider provider = new DaoAuthenticationProvider(); provider.setUserDetailsService(manager); provider.setPasswordEncoder(encoder); return new ProviderManager(provider); }
@Bean public UserDetailsManager userDetailsService(DataSource dataSource, PasswordEncoder encoder) throws Exception { JdbcUserDetailsManager manager = new JdbcUserDetailsManager(dataSource); manager.setAuthenticationManager(authenticationManager(manager, encoder)); return manager; } }
|
接着我们编写一个快速重置密码的接口:
1 2 3 4 5 6 7 8 9
| @ResponseBody @PostMapping("/change-password") public JSONObject changePassword(@RequestParam String oldPassword, @RequestParam String newPassword) { manager.changePassword(oldPassword, encoder.encode(newPassword)); JSONObject object = new JSONObject(); object.put("success", true); return object; }
|
接着我们在主界面中添加一个重置密码的操作:
1 2 3 4 5 6 7 8
| <div> <label> 修改密码: <input type="text" id="oldPassword" placeholder="旧密码"/> <input type="text" id="newPassword" placeholder="新密码"/> </label> <button onclick="change()">修改密码</button> </div>
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
| function change() { const oldPassword = document.getElementById("oldPassword").value const newPassword = document.getElementById("newPassword").value const csrf = document.getElementById("_csrf").value axios.post('/mvc/change-password', { oldPassword: oldPassword, newPassword: newPassword, _csrf: csrf }, { headers: { 'Content-Type': 'application/x-www-form-urlencoded' } }).then(({data}) => { alert(data.success ? "密码修改成功" : "密码修改失败,请检查原密码是否正确") }) }
|
这样我们就可以在首页进行修改密码操作了:
当然,这种方式的权限校验虽然能够直接使用数据库,但是存在一定的局限性,只适合快速搭建Demo使用,不适合实际生产环境下编写,下一节我们将介绍如何实现自定义验证,以应对各种情况。
自定义验证
有些时候,我们的数据库可能并不会像SpringSecurity默认的那样进行设计,而是采用自定义的表结构,这种情况下,上面两种方式就很难进行验证了,此时我们得编写自定义验证,来应对各种任意变化的情况。
既然需要自定义,那么我们就需要自行实现UserDetailsService或是功能更完善的UserDetailsManager接口,这里为了简单,我们直接选择前者进行实现:
1 2 3 4 5 6 7 8
| @Service public class AuthorizeService implements UserDetailsService {
@Override public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { return null; } }
|
现在我们需要去实现这个loadUserByUsername
方法,表示在验证的时候通过自定义的方式,根据给定的用户名查询用户,并封装为UserDetails
对象返回,然后由SpringSecurity将我们返回的对象与用户登录的信息进行核验,基本流程实际上跟之前是一样的,只是现在由我们自己来提供用户查询方式。
现在我们在数据库中创建一个自定义的用户表:
随便插入一点数据:
接着我们自行编写对应的查询操作,首先创建一个对应的实体类:
1 2 3 4 5 6
| @Data public class Account { int id; String username; String password; }
|
然后是根据用户名查询用户的Mapper接口:
1 2 3 4
| public interface UserMapper { @Select("select * from user where username = #{username}") Account findUserByName(String username); }
|
最后我们在配置类上添加相应的包扫描:
1 2 3 4 5 6 7 8 9 10
| @EnableWebMvc @Configuration @ComponentScans({ @ComponentScan("com.example.controller"), @ComponentScan("com.example.service") }) @MapperScan("com.example.mapper") public class WebConfiguration implements WebMvcConfigurer { ... }
|
然后我们来到Service这边进行一下完善,从数据库中进行查询:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
| @Service public class AuthorizeService implements UserDetailsService {
@Resource UserMapper mapper;
@Override public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { Account account = mapper.findUserByName(username); if(account == null) throw new UsernameNotFoundException("用户名或密码错误"); return User .withUsername(username) .password(account.getPassword()) .build(); } }
|
这样,我们就通过自定义的方式实现了数据库信息查询,并完成用户登录操作。
其他配置
前面我们介绍了如果将SpringSecurity作为我们的登录校验框架,并且实现了三种方式的校验,但是光是这样,自由度还远远不够,在实际开发场景中,我们还会面对各种各样的需求,这一部分我们接着来进行更加深层次的配置。
自定义登录界面
虽然SpringSecurity为我们提供了一个还行的登录界面,但是很多情况下往往都是我们使用自定义的登录界面,这个时候就需要进行更多的配置了,我们还是以之前图书管理系统使用的模版为例。
下载好模版后,我们将其中的两个页面和资源文件放到类路径下:
接着我们配置对应页面的Controller控制器:
1 2 3 4 5 6 7 8 9 10 11 12
| @Controller public class HelloController { @GetMapping("/") public String index(){ return "index"; }
@GetMapping("/login") public String login(){ return "login"; } }
|
这样,我们在登录之后,就可以展示前端模版页面了:
不过现在依然是默认进入到SpringSecurity默认的登录界面,现在我们来配置自定义的登录界面,将我们的前端模版中的登录页面作为SpringSecurity的默认登录界面。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
... @Bean public SecurityFilterChain filterChain(HttpSecurity http) throws Exception { return http .authorizeHttpRequests(auth -> { auth.anyRequest().authenticated(); }) .formLogin(conf -> { conf.loginPage("/login"); conf.loginProcessingUrl("/doLogin"); conf.defaultSuccessUrl("/"); conf.permitAll(); conf.usernameParameter("username"); conf.passwordParameter("password"); }) .build(); } }
|
需要配置登陆页面的地址和登陆请求发送的地址,这里登陆页面填写为/login
,登陆请求地址为/doLogin
,登陆页面我们刚刚已经自己编写Controller来实现了,登陆请求提交处理由SpringSecurity 提供,只需要写路径就可以了。现在访问我们的网站,就可以进入到自定义的登录界面了:
但是我们发现,我们的页面只有一个纯文本,这是因为在获取静态资源的时候,所有的静态资源默认情况下也会被拦截,因此全部被302重定向到登录页面,这显然是不对的:
因此,现在我们需要将所有的静态资源也给放行,否则登录界面都没法正常展示:
1 2 3 4
| .authorizeHttpRequests(auth -> { auth.requestMatchers("/static/**").permitAll(); auth.anyRequest().authenticated(); })
|
再次访问我们的网站,就可以看到正常显示的登录界面了:
因此,如果各位小伙伴后续在编写项目过程中发现有302的情况,一定要先检查是否因为没有放行导致被SpringSecurity给拦截了,别再遇到302一脸懵逼了。
接着我们来配置登录操作,这里我们只需要配置一下登录的地址和登录按钮即可,当然,跟之前一样,要把CSRF的输入框也加上:
1 2 3 4 5 6 7 8 9 10 11 12
| <form action="doLogin" method="post"> ... <input type="text" name="username" placeholder="Email Address" class="ad-input"> ... <input type="password" name="password" placeholder="Password" class="ad-input"> ... <input type="text" th:name="${_csrf.getParameterName()}" th:value="${_csrf.token}" hidden> <div class="ad-auth-btn"> <button type="submit" class="ad-btn ad-login-member">Login</button> </div> ... </form>
|
接着我们就可以尝试进行登录操作了:
可以看到,现在我们可以成功地登录到主页了。
退出登录也是同样的操作,我们只需要稍微进行一下配置就可以实现,我们首先继续完善配置类:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
...
@Bean public SecurityFilterChain filterChain(HttpSecurity http) throws Exception { return http ... .logout(conf -> { conf.logoutUrl("/doLogout"); conf.logoutSuccessUrl("/login"); conf.permitAll(); }) .build(); } }
|
接着我们来稍微魔改一下页面中的退出登录按钮:
1 2 3 4 5 6 7 8
| <li> <form action="doLogout" method="post"> <input type="text" th:name="${_csrf.getParameterName()}" th:value="${_csrf.token}" hidden> <button type="submit"> <i class="fas fa-sign-out-alt"></i> logout </button> </form> </li>
|
现在我们点击右上角的退出按钮就可以退出了:
不过,可能会有小伙伴觉得,我们现在无论提交什么请求都需要Csrf校验,有些太麻烦了,实际上现在浏览器已经很安全了,没必要防御到这种程度,我们也可以直接在配置中关闭csrf校验:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
... @Bean public SecurityFilterChain filterChain(HttpSecurity http) throws Exception { return http ... .csrf(conf -> { conf.disable(); conf.ignoringRequestMatchers("/xxx/**"); }) .build(); } }
|
这样,我们就不需要再往页面中嵌入CSRF相关的输入框了,发送请求时也不会进行校验,至此,我们就完成了简单的自定义登录界面配置。
记住我功能
我们的网站还有一个重要的功能,就是记住我,也就是说我们可以在登陆之后的一段时间内,无需再次输入账号和密码进行登陆,相当于服务端已经记住当前用户,再次访问时就可以免登陆进入,这是一个非常常用的功能。
我们之前在JavaWeb阶段,使用本地Cookie存储的方式实现了记住我功能,但是这种方式并不安全,同时在代码编写上也比较麻烦,那么能否有一种更加高效的记住我功能实现呢?
SpringSecurity为我们提供了一种优秀的实现,它为每个已经登陆的浏览器分配一个携带Token的Cookie,并且此Cookie默认会被保留14天,只要我们不清理浏览器的Cookie,那么下次携带此Cookie访问服务器将无需登陆,直接继续使用之前登陆的身份,这样显然比我们之前的写法更加简便。并且我们需要进行简单配置,即可开启记住我功能:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| @Configuration @EnableWebSecurity public class SecurityConfiguration {
...
@Bean public SecurityFilterChain filterChain(HttpSecurity http) throws Exception { return http ... .rememberMe(conf -> { conf.alwaysRemember(false); conf.rememberMeParameter("remember-me"); conf.rememberMeCookieName("xxxx"); }) .build(); } }
|
配置完成后,我们需要修改一下前端页面中的表单,将记住我勾选框也作为表单的一部分进行提交:
1 2 3 4 5 6
| <div class="ad-checkbox"> <label> <input type="checkbox" name="remember-me" class="ad-checkbox"> <span>Remember Me</span> </label> </div>
|
接着我们来尝试勾选记住我选项进行登录:
此时提交的表单中就已经包含记住我字段了,我们会发现,服务端返回给我们了一个记住我专属的Cookie信息:
这个Cookie信息的过期时间并不是仅会话,而是默认保存一段时间,因此,我们关闭浏览器后下次再次访问网站时,就不需要我们再次进行登录操作了,而是直接继续上一次的登录状态。
当然,由于记住我信息是存放在内存中的,我们需要保证服务器一直处于运行状态,如果关闭服务器的话,记住我信息会全部丢失,因此,如果我们希望记住我能够一直持久化保存,我们就需要进一步进行配置。我们需要创建一个基于JDBC的TokenRepository实现:
1 2 3 4 5 6 7 8
| @Bean public PersistentTokenRepository tokenRepository(DataSource dataSource){ JdbcTokenRepositoryImpl repository = new JdbcTokenRepositoryImpl(); repository.setCreateTableOnStartup(true); repository.setDataSource(dataSource); return repository; }
|
然后添加此仓库:
1 2 3 4 5
| .rememberMe(conf -> { conf.rememberMeParameter("remember-me"); conf.tokenRepository(repository); conf.tokenValiditySeconds(3600 * 7); })
|
这样,我们就成功配置了数据库持久化存储记住我信息,即使我们重启服务器也不会导致数据丢失。当我们登录之后,数据库中会自动记录相关的信息:
授权
用户登录后,可能会根据用户当前是身份进行角色划分,比如我们最常用的QQ,一个QQ群里面,有群主、管理员和普通群成员三种角色,其中群主具有最高权限,群主可以管理整个群的任何板块,并且具有解散和升级群的资格,而管理员只有群主的一部分权限,只能用于日常管理,普通群成员则只能进行最基本的聊天操作。
对于我们来说,用户的一个操作实际上就是在访问我们提供的接口
(编写的对应访问路径的Servlet),比如登陆,就需要调用/login
接口,退出登陆就要调用/logout
接口,而我们之前的图书管理系统中,新增图书、删除图书,所有的操作都有着对应的Servlet来进行处理。因此,从我们开发者的角度来说,决定用户能否使用某个功能,只需要决定用户是否能够访问对应的Servlet即可。
我们可以大致像下面这样进行划分:
- 群主:
/login
、/logout
、/chat
、/edit
、/delete
、/upgrade
- 管理员:
/login
、/logout
、/chat
、/edit
- 普通群成员:
/login
、/logout
、/chat
也就是说,我们需要做的就是指定哪些请求可以由哪些用户发起。
SpringSecurity为我们提供了两种授权方式:
- 基于权限的授权:只要拥有某权限的用户,就可以访问某个路径。
- 基于角色的授权:根据用户属于哪个角色来决定是否可以访问某个路径。
两者只是概念上的不同,实际上使用起来效果差不多。这里我们就先演示以角色方式来进行授权。
基于角色授权
现在我们希望创建两个角色,普通用户和管理员,普通用户只能访问index页面,而管理员可以访问任何页面。
首先我们需要对数据库中的角色表进行一些修改,添加一个用户角色字段,并创建一个新的用户,Test用户的角色为user,而Admin用户的角色为admin。
接着我们需要配置SpringSecurity,决定哪些角色可以访问哪些页面:
1 2 3 4 5 6 7 8
| .authorizeHttpRequests(auth -> { auth.requestMatchers("/static/**").permitAll(); auth.requestMatchers("/").hasAnyRole("user", "admin"); auth.anyRequest().hasRole("admin"); })
|
接着我们需要稍微修改一下验证逻辑,我们在数据库中的用户表上添加一个新的字段,用于表示角色:
修改一下对应的实体类:
1 2 3 4 5 6 7
| @Data public class Account { int id; String username; String password; String role; }
|
现在我们在查询用户时,需要添加其对应的角色:
1 2 3 4 5 6 7 8 9 10 11
| @Override public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { Account account = mapper.findUserByName(username); if(account == null) throw new UsernameNotFoundException("用户名或密码错误"); return User .withUsername(username) .password(account.getPassword()) .roles(account.getRole()) .build(); }
|
这样就可以了,我们重启服务器登录看看:
目前依然是可以正常登录的,但是我们随便访问一个其他的页面,就会被拦截并自动退回到登录界面:
这是因为我们前面配置的是user角色,那么这个角色只能访问首页,其他的都不行,所以就会被自动拦截掉了。现在我们可以到数据库中对这个用户的角色进行修改,看看修改后是否能够访问到其他页面:
这样就可以访问其他页面不会被拦截了,不过因为我们没配置这个路径,所以出来的是404页面。
通过使用角色控制页面的访问,我们就可以让某些用户只能访问部分页面。
基于权限授权
基于权限的授权与角色类似,需要以hasAnyAuthority
或hasAuthority
进行判断:
1 2 3 4 5 6
| .authorizeHttpRequests(auth -> { auth.requestMatchers("/static/**").permitAll(); auth.anyRequest().hasAnyAuthority("page:index"); })
|
实际上权限跟角色相比只是粒度更细,由于使用方式差不多,这里不多做阐述。
使用注解权限判断
除了直接配置以外,我们还可以以注解形式直接配置,首先需要在配置类(注意这里是在Mvc的配置类上添加,因为这里只针对Controller进行过滤,所有的Controller是由Mvc配置类进行注册的,如果需要为Service或其他Bean也启用权限判断,则需要在Security的配置类上添加)上开启:
1 2 3 4 5 6
| @Configuration @EnableWebSecurity @EnableMethodSecurity public class SecurityConfiguration { ... }
|
现在我们就可以在我们想要进行权限校验的方法上添加注解了:
1 2 3 4 5 6 7 8 9 10
| @Controller public class HelloController { @PreAuthorize("hasRole('user')") @GetMapping("/") public String index(){ return "index"; }
... }
|
通过添加@PreAuthorize
注解,在执行之前判断判断权限,如果没有对应的权限或是对应的角色,将无法访问页面。
这里其实是使用的就是我们之前讲解的SpEL表达式,我们可以直接在这里使用权限判断相关的方法,如果有忘记SpEL如何使用的可以回顾我们的Spring6核心篇。所有可以进行权限判断的方法在SecurityExpressionRoot
类中有定义,各位小伙伴可以自行前往查看。
同样的还有@PostAuthorize
注解,但是它是在方法执行之后再进行拦截:
1 2 3 4 5 6
| @PostAuthorize("hasRole('user')") @RequestMapping("/") public String index(){ System.out.println("执行了"); return "index"; }
|
除了Controller以外,只要是由Spring管理的Bean都可以使用注解形式来控制权限,我们可以在任意方法上添加这个注解,只要不具备表达式中指定的访问权限,那么就无法执行方法并且会返回403页面。
1 2 3 4 5 6 7 8
| @Service public class UserService {
@PreAuthorize("hasAnyRole('user')") public void test(){ System.out.println("成功执行"); } }
|
与具有相同功能的还有@Secured
但是它不支持SpEL表达式的权限表示形式,并且需要添加”ROLE_”前缀,这里就不做演示了。
我们还可以使用@PreFilter
和@PostFilter
对集合类型的参数或返回值进行过滤。
比如:
1 2 3 4 5
| @PreFilter("filterObject.equals('lbwnb')") public void test(List<String> list){ System.out.println("成功执行"+list); }
|
1 2 3 4 5 6 7 8
| @RequestMapping("/") public String index(){ List<String> list = new LinkedList<>(); list.add("lbwnb"); list.add("yyds"); service.test(list); return "index"; }
|
与@PreFilter
类似的@PostFilter
这里就不做演示了,它用于处理返回值,使用方法是一样的。
当有多个集合时,需要使用filterTarget
进行指定:
1 2 3 4
| @PreFilter(value = "filterObject.equals('lbwnb')", filterTarget = "list2") public void test(List<String> list, List<String> list2){ System.out.println("成功执行"+list); }
|
内部机制探究
**注意:本小节内容作为选学内容,但是难度比前两章的源码部分简单得多。
授权校验流程
最后我们再来聊一下SpringSecurity的实现原理,它本质上是依靠N个Filter实现的,也就是一个完整的过滤链(注意这里是过滤器,不是拦截器)
我们就从AbstractSecurityWebApplicationInitializer
开始下手,我们来看看它配置了什么:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| public final void onStartup(ServletContext servletContext) { this.beforeSpringSecurityFilterChain(servletContext); if (this.configurationClasses != null) { AnnotationConfigWebApplicationContext rootAppContext = new AnnotationConfigWebApplicationContext(); rootAppContext.register(this.configurationClasses); servletContext.addListener(new ContextLoaderListener(rootAppContext)); }
if (this.enableHttpSessionEventPublisher()) { servletContext.addListener("org.springframework.security.web.session.HttpSessionEventPublisher"); }
servletContext.setSessionTrackingModes(this.getSessionTrackingModes()); this.insertSpringSecurityFilterChain(servletContext); this.afterSpringSecurityFilterChain(servletContext); }
|
1 2 3 4 5 6 7 8 9 10 11
| private void insertSpringSecurityFilterChain(ServletContext servletContext) { String filterName = "springSecurityFilterChain"; DelegatingFilterProxy springSecurityFilterChain = new DelegatingFilterProxy(filterName); String contextAttribute = this.getWebApplicationContextAttribute(); if (contextAttribute != null) { springSecurityFilterChain.setContextAttribute(contextAttribute); } this.registerFilter(servletContext, true, filterName, springSecurityFilterChain); }
|
我们接着来看看,DelegatingFilterProxy
在做什么:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
| protected void initFilterBean() throws ServletException { synchronized(this.delegateMonitor) { if (this.delegate == null) { if (this.targetBeanName == null) { this.targetBeanName = this.getFilterName(); }
WebApplicationContext wac = this.findWebApplicationContext(); if (wac != null) { this.delegate = this.initDelegate(wac); } }
} }
|
1 2 3 4 5 6 7 8 9 10 11 12
| protected Filter initDelegate(WebApplicationContext wac) throws ServletException { String targetBeanName = this.getTargetBeanName(); Assert.state(targetBeanName != null, "No target bean name set"); Filter delegate = (Filter)wac.getBean(targetBeanName, Filter.class); if (this.isTargetFilterLifecycle()) { delegate.init(this.getFilterConfig()); }
return delegate; }
|
这里我们需要添加一个断点来查看到底获取到了什么Bean。
通过断点调试,我们发现这里放回的对象是一个FilterChainProxy类型的,并且调用了它的初始化方法。
我们倒回去看,当Filter返回之后,DelegatingFilterProxy
的一个成员变量delegate
被赋值为得到的Filter,也就是FilterChainProxy对象,接着我们来看看,DelegatingFilterProxy
是如何执行doFilter方法的。
1 2 3 4 5 6 7 8
| public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws ServletException, IOException { Filter delegateToUse = this.delegate; if (delegateToUse == null) { } this.invokeDelegate(delegateToUse, request, response, filterChain); }
|
1 2 3 4
| protected void invokeDelegate(Filter delegate, ServletRequest request, ServletResponse response, FilterChain filterChain) throws ServletException, IOException { delegate.doFilter(request, response, filterChain); }
|
所以我们接着来看,FilterChainProxy
的doFilter方法又在干什么:
1 2 3 4 5 6 7 8 9
| public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { boolean clearContext = request.getAttribute(FILTER_APPLIED) == null; if (!clearContext) { this.doFilterInternal(request, response, chain); } else { } }
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
| private void doFilterInternal(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { FirewalledRequest firewallRequest = this.firewall.getFirewalledRequest((HttpServletRequest)request); HttpServletResponse firewallResponse = this.firewall.getFirewalledResponse((HttpServletResponse)response); List<Filter> filters = this.getFilters((HttpServletRequest)firewallRequest); if (filters != null && filters.size() != 0) { if (logger.isDebugEnabled()) { logger.debug(LogMessage.of(() -> { return "Securing " + requestLine(firewallRequest); })); } FilterChainProxy.VirtualFilterChain virtualFilterChain = new FilterChainProxy.VirtualFilterChain(firewallRequest, chain, filters); virtualFilterChain.doFilter(firewallRequest, firewallResponse); } else { if (logger.isTraceEnabled()) { logger.trace(LogMessage.of(() -> { return "No security for " + requestLine(firewallRequest); })); }
firewallRequest.reset(); chain.doFilter(firewallRequest, firewallResponse); } }
|
我们来看一下虚拟过滤链的doFilter是怎么处理的:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
| public void doFilter(ServletRequest request, ServletResponse response) throws IOException, ServletException { if (this.currentPosition == this.size) { if (FilterChainProxy.logger.isDebugEnabled()) { FilterChainProxy.logger.debug(LogMessage.of(() -> { return "Secured " + FilterChainProxy.requestLine(this.firewalledRequest); })); }
this.firewalledRequest.reset(); this.originalChain.doFilter(request, response); } else { ++this.currentPosition; Filter nextFilter = (Filter)this.additionalFilters.get(this.currentPosition - 1); if (FilterChainProxy.logger.isTraceEnabled()) { FilterChainProxy.logger.trace(LogMessage.format("Invoking %s (%d/%d)", nextFilter.getClass().getSimpleName(), this.currentPosition, this.size)); } nextFilter.doFilter(request, response, this); } }
|
因此,我们差不多已经了解了整个SpringSecurity的实现机制了,那么我们来随便看一个内部的过滤器在做什么。
比如用于处理登陆的过滤器UsernamePasswordAuthenticationFilter
,它继承自AbstractAuthenticationProcessingFilter
,我们来看看它是怎么进行过滤的:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
| public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { this.doFilter((HttpServletRequest)request, (HttpServletResponse)response, chain); }
private void doFilter(HttpServletRequest request, HttpServletResponse response, FilterChain chain) throws IOException, ServletException { if (!this.requiresAuthentication(request, response)) { chain.doFilter(request, response); } else { try { Authentication authenticationResult = this.attemptAuthentication(request, response); if (authenticationResult == null) { return; }
this.sessionStrategy.onAuthentication(authenticationResult, request, response); if (this.continueChainBeforeSuccessfulAuthentication) { chain.doFilter(request, response); }
this.successfulAuthentication(request, response, chain, authenticationResult); } catch (InternalAuthenticationServiceException var5) { this.logger.error("An internal error occurred while trying to authenticate the user.", var5); this.unsuccessfulAuthentication(request, response, var5); } catch (AuthenticationException var6) { this.unsuccessfulAuthentication(request, response, var6); }
} }
|
那么我们来看看successfulAuthentication和unsuccessfulAuthentication分别做了什么:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
| protected void successfulAuthentication(HttpServletRequest request, HttpServletResponse response, FilterChain chain, Authentication authResult) throws IOException, ServletException { SecurityContextHolder.getContext().setAuthentication(authResult); if (this.logger.isDebugEnabled()) { this.logger.debug(LogMessage.format("Set SecurityContextHolder to %s", authResult)); }
this.rememberMeServices.loginSuccess(request, response, authResult); if (this.eventPublisher != null) { this.eventPublisher.publishEvent(new InteractiveAuthenticationSuccessEvent(authResult, this.getClass())); } this.successHandler.onAuthenticationSuccess(request, response, authResult); }
protected void unsuccessfulAuthentication(HttpServletRequest request, HttpServletResponse response, AuthenticationException failed) throws IOException, ServletException { SecurityContextHolder.clearContext(); this.logger.trace("Failed to process authentication request", failed); this.logger.trace("Cleared SecurityContextHolder"); this.logger.trace("Handling authentication failure"); this.rememberMeServices.loginFail(request, response); this.failureHandler.onAuthenticationFailure(request, response, failed); }
|
了解了整个用户验证实现流程,其实其它的过滤器是如何实现的也就很容易联想到了,SpringSecurity的过滤器从某种意义上来说,更像是一个处理业务的Servlet,它做的事情不像是拦截,更像是完成自己对应的职责,只不过是使用了过滤器机制进行实现罢了,从而将所有的验证提前到进入Controller之前。
最后附上完整的过滤器清单,这里列出14个常见的内部过滤器:
过滤器名称 |
职责 |
DisableEncodeUrlFilter |
禁止 HttpServletResponse 对 URL 进行编码,以防止在 URL 中包含 Session ID,此类 URL 不被视为 URL,因为会话 ID 可能会在 HTTP 访问日志等内容中泄露。 |
WebAsyncManagerIntegrationFilter |
实现了对SecurityContext与WebAsyncManager的集成,使 Controller 中能够线程安全地获取到用户上下文认证信息。 |
SecurityContextHolderFilter |
通过HttpSessionSecurityContextRepository接口从Session中读取SecurityContext或是直接创建新的,然后存入到SecurityContextHolder中,最后请求结束时会进行清理。 |
HeaderWriterFilter |
给HTTP响应添加一些Header属性,如:X-Frame-Options、X-XSS-Protection、X-Content-Type-Options等。 |
CsrfFilter |
针对Csrf相关校验。 |
LogoutFilter |
对退出登录的请求进行处理,执行登出操作。 |
UsernamePasswordAuthenticationFilter |
对登录的请求进行处理,执行登录操作。 |
ConcurrentSessionFilter |
检查SessionRegistry保存的Session信息是否过期。 |
RequestCacheAwareFilter |
缓存Request请求,可以用于恢复因登录而打断的请求。 |
SecurityContextHolderAwareRequestFilter |
对ServletRequest进行进一步包装,让Request具有更加丰富的内容。 |
RememberMeAuthenticationFilter |
针对于记住我Cookie进行校验。 |
AnonymousAuthenticationFilter |
未验证成功的情况下进行匿名登录操作。 |
SessionManagementFilter |
Session管理相关。 |
ExceptionTranslationFilter |
异常转换处理,比如最常见的AccessDenied之类的。 |
安全上下文
用户登录之后,怎么获取当前已经登录用户的信息呢?通过使用SecurityContextHolder就可以很方便地得到SecurityContext对象了,我们可以直接使用SecurityContext对象来获取当前的认证信息:
1 2 3 4 5 6 7 8 9
| @RequestMapping("/index") public String index(){ SecurityContext context = SecurityContextHolder.getContext(); Authentication authentication = context.getAuthentication(); User user = (User) authentication.getPrincipal(); System.out.println(user.getUsername()); System.out.println(user.getAuthorities()); return "index"; }
|
通过SecurityContext我们就可以快速获取当前用户的名称和授权信息等:
除了这种方式以外,我们还可以直接从Session中获取:
1 2 3 4 5 6 7 8
| @RequestMapping("/index") public String index(@SessionAttribute("SPRING_SECURITY_CONTEXT") SecurityContext context){ Authentication authentication = context.getAuthentication(); User user = (User) authentication.getPrincipal(); System.out.println(user.getUsername()); System.out.println(user.getAuthorities()); return "index"; }
|
注意SecurityContextHolder是有一定的存储策略的,SecurityContextHolder中的SecurityContext对象会在一开始请求到来时被设定,至于存储方式其实是由存储策略决定的,如果我们这样编写,那么在默认情况下是无法获取到认证信息的:
1 2 3 4 5 6 7 8 9 10 11
| @RequestMapping("/index") public String index(){ new Thread(() -> { SecurityContext context = SecurityContextHolder.getContext(); Authentication authentication = context.getAuthentication(); User user = (User) authentication.getPrincipal(); System.out.println(user.getUsername()); System.out.println(user.getAuthorities()); }).start(); return "index"; }
|
这是因为SecurityContextHolder的存储策略默认是MODE_THREADLOCAL
,它是基于ThreadLocal实现的,getContext()
方法本质上调用的是对应的存储策略实现的方法:
1 2 3
| public static SecurityContext getContext() { return strategy.getContext(); }
|
SecurityContextHolderStrategy有三个实现类:
- GlobalSecurityContextHolderStrategy:全局模式,不常用
- ThreadLocalSecurityContextHolderStrategy:基于ThreadLocal实现,线程内可见
- InheritableThreadLocalSecurityContextHolderStrategy:基于InheritableThreadLocal实现,线程和子线程可见
因此,如果上述情况需要在子线程中获取,那么需要修改SecurityContextHolder的存储策略,在初始化的时候设置:
1 2 3 4
| @PostConstruct public void init(){ SecurityContextHolder.setStrategyName(SecurityContextHolder.MODE_INHERITABLETHREADLOCAL); }
|
这样在子线程中也可以获取认证信息了。
因为用户的验证信息是基于SecurityContext进行判断的,我们可以直接修改SecurityContext的内容,来手动为用户进行登陆:
1 2 3 4 5 6 7 8 9
| @RequestMapping("/auth") @ResponseBody public String auth(){ SecurityContext context = SecurityContextHolder.getContext(); UsernamePasswordAuthenticationToken token = new UsernamePasswordAuthenticationToken("Test", null, AuthorityUtils.commaSeparatedStringToAuthorityList("ROLE_user")); context.setAuthentication(token); return "Login success!"; }
|
在未登陆的情况下,访问此地址将直接进行手动登陆,再次访问/index
页面,可以直接访问,说明手动设置认证信息成功。
疑惑:SecurityContext这玩意不是默认线程独占吗,那每次请求都是一个新的线程,按理说上一次的SecurityContext对象应该没了才对啊,为什么再次请求依然能够继续使用上一次SecurityContext中的认证信息呢?
SecurityContext的生命周期:请求到来时从Session中取出,放入SecurityContextHolder中,请求结束时从SecurityContextHolder取出,并放到Session中,实际上就是依靠Session来存储的,一旦会话过期验证信息也跟着消失。
安全上下文持久化过滤器
SecurityContextHolderFilter也是内置的Filter,它就是专门用于处理SecurityContext的,这里先说一下大致流程,以便我们后续更加方便地理解:
当过滤器链执行到SecurityContextHolderFilter时,它会从HttpSession中把SecurityContext对象取出来(是存在Session中的,跟随会话的消失而消失),然后放入SecurityContextHolder对象中。请求结束后,再把SecurityContext存入HttpSession中,并清除SecurityContextHolder内的SecurityContext对象。
我们还是直接进入到源码中:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
| @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { doFilter((HttpServletRequest) request, (HttpServletResponse) response, chain); }
private void doFilter(HttpServletRequest request, HttpServletResponse response, FilterChain chain) throws ServletException, IOException { if (request.getAttribute(FILTER_APPLIED) != null) { chain.doFilter(request, response); return; } request.setAttribute(FILTER_APPLIED, Boolean.TRUE); Supplier<SecurityContext> deferredContext = this.securityContextRepository.loadDeferredContext(request); ... }
|
我们接着来看loadDeferredContext
的实现细节,其中SecurityContextRepository的实现类是DelegatingSecurityContextRepository类,这个类中维护了多个SecurityContextRepository实现类,而其本身并没有实现loadDeferredContext
方法,而是靠内部维护的其他SecurityContextRepository实现类来完成:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
| @Override public DeferredSecurityContext loadDeferredContext(HttpServletRequest request) { DeferredSecurityContext deferredSecurityContext = null; for (SecurityContextRepository delegate : this.delegates) { if (deferredSecurityContext == null) { deferredSecurityContext = delegate.loadDeferredContext(request); } else { DeferredSecurityContext next = delegate.loadDeferredContext(request); deferredSecurityContext = new DelegatingDeferredSecurityContext(deferredSecurityContext, next); } } return deferredSecurityContext; }
|
首先我们来看第一个HttpSessionSecurityContextRepository,它是第一个被遍历的实现:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| @Override public DeferredSecurityContext loadDeferredContext(HttpServletRequest request) { Supplier<SecurityContext> supplier = () -> readSecurityContextFromSession(request.getSession(false)); return new SupplierDeferredSecurityContext(supplier, this.securityContextHolderStrategy); }
public static final String SPRING_SECURITY_CONTEXT_KEY = "SPRING_SECURITY_CONTEXT"; private String springSecurityContextKey = SPRING_SECURITY_CONTEXT_KEY;
private SecurityContext readSecurityContextFromSession(HttpSession httpSession) { ... Object contextFromSession = httpSession.getAttribute(this.springSecurityContextKey); ... return (SecurityContext) contextFromSession; }
|
最后返回回去的是一个SupplierDeferredSecurityContext对象:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52
| final class SupplierDeferredSecurityContext implements DeferredSecurityContext {
private static final Log logger = LogFactory.getLog(SupplierDeferredSecurityContext.class);
private final Supplier<SecurityContext> supplier;
private final SecurityContextHolderStrategy strategy;
private SecurityContext securityContext;
private boolean missingContext;
SupplierDeferredSecurityContext(Supplier<SecurityContext> supplier, SecurityContextHolderStrategy strategy) { this.supplier = supplier; this.strategy = strategy; }
@Override public SecurityContext get() { init(); return this.securityContext; }
@Override public boolean isGenerated() { init(); return this.missingContext; }
private void init() { if (this.securityContext != null) { return; } this.securityContext = this.supplier.get(); this.missingContext = (this.securityContext == null); if (this.missingContext) { this.securityContext = this.strategy.createEmptyContext(); if (logger.isTraceEnabled()) { logger.trace(LogMessage.format("Created %s", this.securityContext)); } } }
}
|
接着是第二个被遍历的实现RequestAttributeSecurityContextRepository类:
1 2 3 4 5 6 7 8 9 10 11 12
| @Override public DeferredSecurityContext loadDeferredContext(HttpServletRequest request) { Supplier<SecurityContext> supplier = () -> getContext(request); return new SupplierDeferredSecurityContext(supplier, this.securityContextHolderStrategy); }
private SecurityContext getContext(HttpServletRequest request) { return (SecurityContext) request.getAttribute(this.requestAttributeName); }
|
最后,两个SecurityContext就会以链式存放在DelegatingDeferredSecurityContext对象中,一并返回了,它的内部长这样:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
| static final class DelegatingDeferredSecurityContext implements DeferredSecurityContext {
private final DeferredSecurityContext previous;
private final DeferredSecurityContext next;
DelegatingDeferredSecurityContext(DeferredSecurityContext previous, DeferredSecurityContext next) { this.previous = previous; this.next = next; }
@Override public SecurityContext get() { SecurityContext securityContext = this.previous.get(); if (!this.previous.isGenerated()) { return securityContext; } return this.next.get(); }
@Override public boolean isGenerated() { return this.previous.isGenerated() && this.next.isGenerated(); } }
|
兜了这么大一圈,现在回到一开始的Filter中:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
| private void doFilter(HttpServletRequest request, HttpServletResponse response, FilterChain chain) throws ServletException, IOException { ... Supplier<SecurityContext> deferredContext = this.securityContextRepository.loadDeferredContext(request); try { this.securityContextHolderStrategy.setDeferredContext(deferredContext); chain.doFilter(request, response); } finally { this.securityContextHolderStrategy.clearContext(); request.removeAttribute(FILTER_APPLIED); } }
|
最后我们再来看一下我们之前通过SecurityContextHolder是如何获取到SecurityContext的:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45
| public class SecurityContextHolder { ... private static String strategyName = System.getProperty(SYSTEM_PROPERTY); private static SecurityContextHolderStrategy strategy; private static int initializeCount = 0;
static { initialize(); }
private static void initialize() { initializeStrategy(); initializeCount++; }
private static void initializeStrategy() { ... try { Class<?> clazz = Class.forName(strategyName); Constructor<?> customStrategy = clazz.getConstructor(); strategy = (SecurityContextHolderStrategy) customStrategy.newInstance(); } catch (Exception ex) { ReflectionUtils.handleReflectionException(ex); } }
public static void clearContext() { strategy.clearContext(); }
public static SecurityContext getContext() { return strategy.getContext(); } ... }
|
我们发现,实际上SecurityContextHolder获取SecurityContext对象,就是通过SecurityContextHolderStrategy根据策略来获取,我们直接来看SecurityContextHolderStrategy的实现类:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32
| final class ThreadLocalSecurityContextHolderStrategy implements SecurityContextHolderStrategy {
private static final ThreadLocal<Supplier<SecurityContext>> contextHolder = new ThreadLocal<>();
@Override public void clearContext() { contextHolder.remove(); }
@Override public SecurityContext getContext() { return getDeferredContext().get(); }
@Override public Supplier<SecurityContext> getDeferredContext() { Supplier<SecurityContext> result = contextHolder.get(); if (result == null) { SecurityContext context = createEmptyContext(); result = () -> context; contextHolder.set(result); } return result; }
...
}
|
这样,整个流程其实就很清楚了,项目启动时,SecurityContextHolder会自动根据配置创建对应的SecurityContextHolderStrategy对象。当我们的请求到来之后,首先会经过SecurityContextHolderFilter,然后在这个阶段,通过SecurityContextRepository来将不同地方存储(一般是Session中存储)的SecurityContext对象取出并封装为DefferdSecurityContext,然后将其添加到一开始创建好的SecurityContextHolderStrategy对象中,这样,我们的Controller在处理时就能直接从SecurityContextHolder取出SecurityContext对象了,最后在处理结束返回响应时,SecurityContextHolderFilter也会将SecurityContextHolderStrategy存储的DefferdSecurityContext清除掉,至此,一个完整流程结束。
SpringSecurity常用配置
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116
| package com.example.springsecurity.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.security.authentication.AuthenticationManager; import org.springframework.security.authentication.ProviderManager; import org.springframework.security.authentication.dao.DaoAuthenticationProvider; import org.springframework.security.config.annotation.web.builders.HttpSecurity; import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity; import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; import org.springframework.security.crypto.password.PasswordEncoder; import org.springframework.security.provisioning.UserDetailsManager; import org.springframework.security.web.SecurityFilterChain; import org.springframework.security.web.authentication.rememberme.JdbcTokenRepositoryImpl; import org.springframework.security.web.authentication.rememberme.PersistentTokenRepository; import javax.sql.DataSource; @Configuration @EnableWebSecurity public class SecurityConfiguration { private AuthenticationManager authenticationManager(UserDetailsManager manager, PasswordEncoder encoder) { DaoAuthenticationProvider provider = new DaoAuthenticationProvider(); provider.setUserDetailsService(manager); provider.setPasswordEncoder(encoder); return new ProviderManager(provider); } @Bean public PasswordEncoder passwordEncoder() {
return new BCryptPasswordEncoder(); } @Bean public SecurityFilterChain filterChain(HttpSecurity http, PersistentTokenRepository repository) throws Exception { return http .authorizeHttpRequests(authorize -> { authorize.requestMatchers("/assets/**").permitAll();
authorize.anyRequest().authenticated(); })
.formLogin(conf -> { conf.loginPage("/login"); conf.loginProcessingUrl("/doLogin"); conf.failureUrl("/login?error"); conf.defaultSuccessUrl("/"); conf.permitAll(); conf.usernameParameter("username"); conf.passwordParameter("password"); }) .logout(conf -> { conf.logoutUrl("/doLogout"); conf.logoutSuccessUrl("/login"); conf.permitAll(); }) .csrf(conf -> { conf.disable();
}) .rememberMe(conf -> { conf.rememberMeParameter("remember-me"); conf.tokenRepository(repository); conf.tokenValiditySeconds(3600 * 24 * 7); }) .build(); } @Bean public PersistentTokenRepository tokenRepository(DataSource dataSource) { JdbcTokenRepositoryImpl repository = new JdbcTokenRepositoryImpl();
repository.setDataSource(dataSource); return repository; }
}
|
自定义验证:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
| package com.example.springsecurity.service.impl; import com.example.springsecurity.entity.User; import com.example.springsecurity.mapper.UserMapper; import jakarta.annotation.Resource; import org.springframework.security.core.userdetails.UserDetails; import org.springframework.security.core.userdetails.UserDetailsService; import org.springframework.security.core.userdetails.UsernameNotFoundException; import org.springframework.stereotype.Service;
@Service public class AuthorizeService implements UserDetailsService { @Resource UserMapper mapper; @Override public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { User user = mapper.getUserByUsername(username);
if (user == null) { throw new UsernameNotFoundException("用户名或密码错误"); } return org.springframework.security.core.userdetails.User .withUsername(user.getName()) .password(user.getPwd()) .roles(user.getRole()) .build(); } }
|
Reference
1 2 3 4
| url: https://itbaima.net/ title: "柏码 - 让每一行代码都闪耀智慧的光芒!" host: itbaima.net favicon: /favicon.ico
|
柏码 - 让每一行代码都闪耀智慧的光芒!