29.0、springboot-Shiro整合，以及shiro整合mybatis实现登录拦截器
先在pom.xml文件中导入相关依赖，后面也会用到thymeleaf所以也顺便导入吧
<!--
Subject 用户
SecurityManager 管理所有用户
Realm 连接数据
-->
<!--shiro整合Spring的包-->
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-spring</artifactId>
<version>1.4.1</version>
</dependency>
<!--Thymeleaf-->
<dependency>
<groupId>org.thymeleaf</groupId>
<artifactId>thymeleaf-spring5</artifactId>
</dependency>
<dependency>
<groupId>org.thymeleaf.extras</groupId>
<artifactId>thymeleaf-extras-java8time</artifactId>
</dependency>
然后我们需要自定义一个realm，在config文件夹下创建一个叫做UserRealm.java的文件
package com.hkl.config;
import org.apache.shiro.authc.AuthenticationException;
import org.apache.shiro.authc.AuthenticationInfo;
import org.apache.shiro.authc.AuthenticationToken;
import org.apache.shiro.authz.AuthorizationInfo;
import org.apache.shiro.realm.AuthorizingRealm;
import org.apache.shiro.subject.PrincipalCollection;
public class UserRealm extends AuthorizingRealm {
@Override
protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principalCollection) {
System.out.println("执行了=>授权doGetAuthorizationInfo");
return null;
}
@Override
protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authenticationToken) throws AuthenticationException {
System.out.println("执行了=>认证doGetAuthenticationInfo");
return null;
}
}
在config文件夹下创建一个java配置类文件ShiroConfig.java文件
package com.hkl.config;
import org.apache.shiro.spring.web.ShiroFilterFactoryBean;
import org.apache.shiro.web.mgt.DefaultWebSecurityManager;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ShiroConfig {
@Bean
ShiroFilterFactoryBean getshiroFilterFactoryBean(@Qualifier("getdefaultWebSecurityManager") DefaultWebSecurityManager defaultWebSecurityManager) {
ShiroFilterFactoryBean bean = new ShiroFilterFactoryBean();
//设施安全管理器
bean.setSecurityManager(defaultWebSecurityManager);
return bean;
}
@Bean
public DefaultWebSecurityManager getdefaultWebSecurityManager(@Qualifier("userRealm") UserRealm userRealm) {
DefaultWebSecurityManager securityManager = new DefaultWebSecurityManager();
//关联UserRealm
securityManager.setRealm(userRealm);
return securityManager;
}
//创建realm对象，需要自定义类：1
@Bean
public UserRealm userRealm() {
return new UserRealm();
}
}
用shiro实现登录拦截器功能
搭建环境：因为shiro不像spring-security一样有一个默认的login登录界面，所以我们得自己在template文件夹下写一个login.html文件
<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
<meta charset="UTF-8">
<title>登录</title>
</head>
<body>
<h1>登录</h1>
<hr>
<p th:text="${msg}" style="color: red"></p>
<form th:action="@{/logintoindex}">
<input type="text" name="username" placeholder="用户名" /><br>
<input type="password" name="password" placeholder="密码" /><br>
<input type="submit" value="登录" /><br>
</form>
</body>
</html>
然后在template在自己写一个index.html首页界面
<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
<meta charset="UTF-8">
<title>首页</title>
</head>
<body>
<h1>首页</h1>
<hr>
<a th:href="@{/user/toadd}">进入添加用户界面</a>
<a th:href="@{/user/toupdate}">进入修改用户界面</a>
</body>
</html>
在template文件夹下创建一个叫做user的文件夹，然后在user文件夹下创建两个html文件分别为add.html和update.html内容自定义即可
配置MyController.java文件
package com.hkl.controller;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
@Controller
public class MyController {
@RequestMapping({"/","/index","index.html"})
public String toindex(Model model) {
model.addAttribute("msg","hello world首页");
return "index";
}
@RequestMapping("/user/toadd")
public String toadd() {
return "user/add";
}
@RequestMapping("/user/toupdate")
public String toupdate() {
return "user/update";
}
@RequestMapping("/tologin")
public String tologin() {
return "login";
}
}
在ShiroConfig.java文件继续配置以下代码
package com.hkl.config;
import org.apache.shiro.spring.web.ShiroFilterFactoryBean;
import org.apache.shiro.web.mgt.DefaultWebSecurityManager;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.LinkedHashMap;
import java.util.Map;
@Configuration
public class ShiroConfig {
@Bean
ShiroFilterFactoryBean getshiroFilterFactoryBean(@Qualifier("getdefaultWebSecurityManager") DefaultWebSecurityManager defaultWebSecurityManager) {
ShiroFilterFactoryBean bean = new ShiroFilterFactoryBean();
//设置安全管理器
bean.setSecurityManager(defaultWebSecurityManager);
//添加shiro的内置过滤器
/*
anon: 无需认证就可以访问
authc: 必须认证了才能访问
user: 必须拥有 记住我 功能才能用
perms: 拥有对某个资源的权限才能访问
role： 拥有某个角色权限才能访问
*/
Map<String,String> filterMap = new LinkedHashMap<>();
filterMap.put("/user/*","authc");//这里表示所有在user下的访问都必须经过认证才可以
bean.setFilterChainDefinitionMap(filterMap);
//设置登录页面的url请求
bean.setLoginUrl("/tologin");
return bean;
}
@Bean
public DefaultWebSecurityManager getdefaultWebSecurityManager(@Qualifier("userRealm") UserRealm userRealm) {
DefaultWebSecurityManager securityManager = new DefaultWebSecurityManager();
//关联UserRealm
securityManager.setRealm(userRealm);
return securityManager;
}
//创建realm对象，需要自定义类：1
@Bean
public UserRealm userRealm() {
return new UserRealm();
}
}
这里主要完成的工作就是： 设置好拦截、过滤的请求，以及放行的请求~
那么想要能够设置就必须要先设置好安全管理器securityManager，但是想要设置好securityManager就必须吓你设置好realm；
所以->
第一步：我先自定义了一个 UserRealm.java 文件，并且把他注入到了spring容器中
第二步：定义一个getdefaultWebSecurityManager()方法去设置realm，并且返回设置好realm的securityManager【这里利用@Qualifier 注释将UserReal和自己关联了起来】，最后返回securityManage
第三步：定义了一个getshiroFilterFactoryBean()的方法去设置过滤拦截的请求，在这之前首先需要获取刚刚我们设置好 realm 的 securityManager，获取完成之后同理用@Qualifier 将之与自己关联起来，然后利用这个bean去创建一个链式过滤，添加好需要过滤的请求即可~
用Shiro实现用户认证
先来回顾一下在28.0里说过的在Quickstart.java出现有关subject的方法
用SecurityUtils.getSubject();获取subject
通过currentUser.getSession();获取session
currentUser.isAuthenticated()判断用户验证
currentUser.getPrincipal();获得当前用户的认证
currentUser.hasRole("schwartz")获取当前用户的角色
currentUser.isPermitted("lightsaber:wield")获取当前用户的权限
currentUser.logout();注销
然后我们开始在controller层写一些操作：
获取当前用户SecurityUtils.getSubject();
封装用户的登录数据、令牌加密：new UsernamePasswordToken(username,password);
执行登录方法，如果没有异常就说明OK了：subject.login(token);
然后加一些异常捕获操作即可
MyController.java文件的/logintoindex请求如下：
package com.hkl.controller;
import org.apache.shiro.SecurityUtils;
import org.apache.shiro.authc.IncorrectCredentialsException;
import org.apache.shiro.authc.UnknownAccountException;
import org.apache.shiro.authc.UsernamePasswordToken;
import org.apache.shiro.subject.Subject;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import javax.websocket.server.PathParam;
@Controller
public class MyController {
@RequestMapping({"/","/index","index.html"})
public String toindex(Model model) {
model.addAttribute("msg","hello world首页");
return "index";
}
@RequestMapping("/user/toadd")
public String toadd() {
return "user/add";
}
@RequestMapping("/user/toupdate")
public String toupdate() {
return "user/update";
}
@RequestMapping("/tologin")
public String tologin() {
return "login";
}
@PostMapping("/logintoindex")
public String logintoindex(@PathParam("username") String username, @PathParam("password") String password,Model model) {
//获取当前的用户
Subject subject = SecurityUtils.getSubject();
//封装用户的登录数据
UsernamePasswordToken token = new UsernamePasswordToken(username, password);
try{
subject.login(token);//执行登录方法，如果没有异常就说明OK了
return "index";
}catch (UnknownAccountException e) {//用户名不存在
model.addAttribute("msg","用户名错误！");
return "login";
}catch (IncorrectCredentialsException e) {
model.addAttribute("msg","密码错误！");
return "login";
}
}
}
现在还没有配置用户名和密码的数据，我们写完上面的代码可以发现每次点击登录的时候都会去到UserRealm.java这个我们之前写好的类中执行他的doGetAuthenticationInf()方法，
所以我们可以在这个方法里写一些验证的操作，我们先不连接数据库，将数据写死来测试一下，UserRealm.java文件如下：
package com.hkl.config;
import org.apache.shiro.authc.*;
import org.apache.shiro.authz.AuthorizationInfo;
import org.apache.shiro.realm.AuthorizingRealm;
import org.apache.shiro.subject.PrincipalCollection;
public class UserRealm extends AuthorizingRealm {
@Override
protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principalCollection) {
System.out.println("执行了=>授权doGetAuthorizationInfo");
return null;
}
@Override
protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authenticationToken) throws AuthenticationException {
System.out.println("执行了=>认证doGetAuthenticationInfo");
//配置用户名和密码，正常情况下是从数据库中取的，但是我们先将数据写死来测试一下
String name = "hkl";
String password = "123";
UsernamePasswordToken userToken = (UsernamePasswordToken) authenticationToken;
//如果用户名不正确
if(!userToken.getUsername().equals(name)) {
return null;//return null 的意思就是会抛出异常 UnknownAccountException 用户名不存在
}
return new SimpleAuthenticationInfo("",password,"");//这里有三个对象，分别是获取当前用户的认证，密码，认证名，第一个和第三个可以先省略不懈
}
}
好了写完这个之后，来测试一下
登录的时候用户名和密码错误确实会提示而且不让进入add和update页面
登录成功后确实就可以进入这两个页面了
测试成功后，我们接下来整合一下mybatis连接数据库
第一步：首先在pom.xml文件中导入相关的依赖
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.0</version>
</dependency>
第二步：连接自己的数据库，在application.properties文件中配置mybatis的相关代码
#关闭模板引擎以便调试
spring.thymeleaf.cache=false
#连接数据库
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost:3306/jdbcmysql?useUnicode=true&characterEncoding=utf-8
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# 配置mybatis
mybatis.type-aliases-package=com.hkl.pojo
mybatis.mapper-locations=classpath:mapper/*.xml
这里一定要注意，如果时区没有问题，就不要在spring.datasource.url中配置serverTimezone=URC，不然就会报错！！！
第三步：在pojo文件夹下创建一个User.java实体类文件如下：
package com.hkl.pojo;
public class User {
private int id;
private String username;
private String password;
public User(int id, String username, String password) {
this.id = id;
this.username = username;
this.password = password;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
第四步：在mapper文件夹下创建一个UserMapper.java接口类文件如下：
package com.hkl.mapper;
import com.hkl.pojo.User;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;
@Repository
@Mapper
public interface UserMapper {
public User queryUserByName(String name);
}
第五步：在resources文件夹下创建一个mapper文件夹，在mapper里创建一个UserMapper.xml文件如下：
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hkl.mapper.UserMapper">
<select id="queryUserByName" parameterType="String" resultType="User">
select * from jdbcmysql.table_user where username = #{username}
</select>
</mapper>
第六步：在service文件夹下创建接口UserService和接口的实现类UserServiceImpl如下：
package com.hkl.service;
import com.hkl.pojo.User;
public interface UserService {
public User queryUserByName(String name);
}
package com.hkl.service;
import com.hkl.mapper.UserMapper;
import com.hkl.pojo.User;
import org.springframework.stereotype.Service;
@Service
public class UserServiceImpl implements UserService {
private UserMapper userMapper;
@Override
public User queryUserByName(String username) {
User user = userMapper.queryUserByName(username);
return user;
}
}
接下来配置一下UserRealm.java文件
package com.hkl.config;
import com.hkl.pojo.User;
import com.hkl.service.UserService;
import org.apache.shiro.authc.*;
import org.apache.shiro.authz.AuthorizationInfo;
import org.apache.shiro.realm.AuthorizingRealm;
import org.apache.shiro.subject.PrincipalCollection;
import org.springframework.beans.factory.annotation.Autowired;
public class UserRealm extends AuthorizingRealm {
@Autowired
private UserService userService;
@Override
protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principalCollection) {
System.out.println("执行了=>授权doGetAuthorizationInfo");
return null;
}
@Override
protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authenticationToken) throws AuthenticationException {
System.out.println("执行了=>认证doGetAuthenticationInfo");
UsernamePasswordToken userToken = (UsernamePasswordToken) authenticationToken;
User user = userService.queryUserByName(userToken.getUsername());
//如果用户名不正确
if(user == null) {//没有这个人
return null;//return null 的意思就是会抛出异常 UnknownAccountException 用户名不存在
}
return new SimpleAuthenticationInfo("",user.getPassword(),"");//这里有三个对象，分别是获取当前用户的认证，密码，认证名，第一个和第三个可以先省略不写
}
}
这里的代码和之前不同了，这里没有把账号密码的数据写死，而是从数据库中读取数据，然后拿来认证
本文含有隐藏内容，请 开通VIP 后查看