shiro:hasPermission 標籤 ：驗證當前用戶是否擁有指定權限

時間  2019-11-19
標籤 shiro haspermission 標籤 驗證 當前 用戶 是否 擁有 指定 權限 简体版
原文   原文鏈接

一、這些值是存在數據庫裏的，在哪裏找呢？sys_menu 中的permission列。java

<shiro:hasPermission name="cms:article:edit">

 

他是怎麼入庫的呢？非菜單項的權限是怎麼加入，怎麼取出來使用的？

取出來的sql：
SELECT
	a.id ,
	a.parent_id AS "parent.id" ,
	a.parent_ids ,
	a. NAME ,
	a.href ,
	a.target ,
	a.icon ,
	a.sort ,
	a.is_show ,
	a.permission ,
	a.remarks ,
	a.create_by AS "createBy.id" ,
	a.create_date ,
	a.update_by AS "updateBy.id" ,
	a.update_date ,
	a.del_flag ,
	p. NAME AS "parent.name"
FROM
	sys_menu a
LEFT JOIN sys_menu p ON p.id = a.parent_id
WHERE
	a.del_flag = 0
ORDER BY
	a.sort

　　同一個表裏的id與parentid之間的鏈接；web

程序代碼是在：com.thinkgem.jeesite.modules.sys.security 這個包裏算法

/**
	 * 受權查詢回調函數, 進行鑑權但緩存中無用戶的受權信息時調用
	 */
	@Override
	protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) {
		Principal principal = (Principal) getAvailablePrincipal(principals);
		// 獲取當前已登陸的用戶
		if (!Global.TRUE.equals(Global.getConfig("user.multiAccountLogin"))){
			Collection<Session> sessions = getSystemService().getSessionDao().getActiveSessions(true, principal, UserUtils.getSession());
			if (sessions.size() > 0){
				// 若是是登陸進來的，則踢出已在線用戶
				if (UserUtils.getSubject().isAuthenticated()){
					for (Session session : sessions){
						getSystemService().getSessionDao().delete(session);
					}
				}
				// 記住我進來的，而且當前用戶已登陸，則退出當前用戶提示信息。
				else{
					UserUtils.getSubject().logout();
					throw new AuthenticationException("msg:帳號已在其它地方登陸，請從新登陸。");
				}
			}
		}
		User user = getSystemService().getUserByLoginName(principal.getLoginName());
		if (user != null) {
			SimpleAuthorizationInfo info = new SimpleAuthorizationInfo();
			List<Menu> list = UserUtils.getMenuList();
			for (Menu menu : list){
				if (StringUtils.isNotBlank(menu.getPermission())){
					// 添加基於Permission的權限信息
					for (String permission : StringUtils.split(menu.getPermission(),",")){
						info.addStringPermission(permission);
					}
				}
			}
			// 添加用戶權限
			info.addStringPermission("user");
			// 添加用戶角色信息
			for (Role role : user.getRoleList()){
				info.addRole(role.getEnname());
			}
			// 更新登陸IP和時間
			getSystemService().updateUserLoginInfo(user);
			// 記錄登陸日誌
			LogUtils.saveLog(Servlets.getRequest(), "系統登陸");
			return info;
		} else {
			return null;
		}
	}

　　

 List<Menu> list = UserUtils.getMenuList();
             for  (Menu menu : list){
                 if  (StringUtils.isNotBlank(menu.getPermission())){
                     // 添加基於Permission的權限信息
                     for  (String permission : StringUtils.split(menu.getPermission(), "," )){
                         info.addStringPermission(permission);
                     }
                 }
             }
這一段；
三、那麼JSP頁面上是何時判斷的呢？這些數據是何時初始化到數據庫中的呢？
 在使用Shiro標籤庫前，首先須要在JSP引入shiro標籤：  
<%@ taglib prefix="shiro" uri="/WEB-INF/tlds/shiros.tld" %>

　　

當展現一個jsp頁面時，頁面中若是遇到<shiro:hasPermission name="item:update">，shiro調用realm獲取數據庫中的權限信息，看item:update是否在權限數據中存在，若是不存在就拒絕訪問，若是存在就受權經過。 spring

package com.thinkgem.jeesite.modules.sys.security;

import java.io.Serializable;
import java.util.Collection;
import java.util.List;

import javax.annotation.PostConstruct;

import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.authc.AuthenticationException;
import org.apache.shiro.authc.AuthenticationInfo;
import org.apache.shiro.authc.AuthenticationToken;
import org.apache.shiro.authc.SimpleAuthenticationInfo;
import org.apache.shiro.authc.credential.HashedCredentialsMatcher;
import org.apache.shiro.authz.AuthorizationInfo;
import org.apache.shiro.authz.Permission;
import org.apache.shiro.authz.SimpleAuthorizationInfo;
import org.apache.shiro.realm.AuthorizingRealm;
import org.apache.shiro.session.Session;
import org.apache.shiro.subject.PrincipalCollection;
import org.apache.shiro.util.ByteSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import com.thinkgem.jeesite.common.config.Global;
import com.thinkgem.jeesite.common.servlet.ValidateCodeServlet;
import com.thinkgem.jeesite.common.utils.Encodes;
import com.thinkgem.jeesite.common.utils.SpringContextHolder;
import com.thinkgem.jeesite.common.web.Servlets;
import com.thinkgem.jeesite.modules.sys.entity.Menu;
import com.thinkgem.jeesite.modules.sys.entity.Role;
import com.thinkgem.jeesite.modules.sys.entity.User;
import com.thinkgem.jeesite.modules.sys.service.SystemService;
import com.thinkgem.jeesite.modules.sys.utils.LogUtils;
import com.thinkgem.jeesite.modules.sys.utils.UserUtils;
import com.thinkgem.jeesite.modules.sys.web.LoginController;

/**
 * 系統安全認證明現類
 * @author ThinkGem
 * @version 2014-7-5
 */
@Service
//@DependsOn({"userDao","roleDao","menuDao"})
public class SystemAuthorizingRealm extends AuthorizingRealm {

	private Logger logger = LoggerFactory.getLogger(getClass());
	
	private SystemService systemService;
	
	public SystemAuthorizingRealm() {
		this.setCachingEnabled(false);
	}

	/**
	 * 認證回調函數, 登陸時調用
	 */
	@Override
	protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authcToken) {
		UsernamePasswordToken token = (UsernamePasswordToken) authcToken;
		
		int activeSessionSize = getSystemService().getSessionDao().getActiveSessions(false).size();
		if (logger.isDebugEnabled()){
			logger.debug("login submit, active session size: {}, username: {}", activeSessionSize, token.getUsername());
		}
		
		// 校驗登陸驗證碼
		if (LoginController.isValidateCodeLogin(token.getUsername(), false, false)){
			Session session = UserUtils.getSession();
			String code = (String)session.getAttribute(ValidateCodeServlet.VALIDATE_CODE);
			if (token.getCaptcha() == null || !token.getCaptcha().toUpperCase().equals(code)){
				throw new AuthenticationException("msg:驗證碼錯誤, 請重試.");
			}
		}
		
		// 校驗用戶名密碼
		User user = getSystemService().getUserByLoginName(token.getUsername());
		if (user != null) {
			if (Global.NO.equals(user.getLoginFlag())){
				throw new AuthenticationException("msg:該已賬號禁止登陸.");
			}
			byte[] salt = Encodes.decodeHex(user.getPassword().substring(0,16));
			return new SimpleAuthenticationInfo(new Principal(user, token.isMobileLogin()), 
					user.getPassword().substring(16), ByteSource.Util.bytes(salt), getName());
		} else {
			return null;
		}
	}
	
	/**
	 * 獲取權限受權信息，若是緩存中存在，則直接從緩存中獲取，不然就從新獲取， 登陸成功後調用
	 */
	protected AuthorizationInfo getAuthorizationInfo(PrincipalCollection principals) {
		if (principals == null) {
            return null;
        }
		
        AuthorizationInfo info = null;

        info = (AuthorizationInfo)UserUtils.getCache(UserUtils.CACHE_AUTH_INFO);

        if (info == null) {
            info = doGetAuthorizationInfo(principals);
            if (info != null) {
            	UserUtils.putCache(UserUtils.CACHE_AUTH_INFO, info);
            }
        }

        return info;
	}

	/**
	 * 受權查詢回調函數, 進行鑑權但緩存中無用戶的受權信息時調用
	 */
	@Override
	protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) {
		Principal principal = (Principal) getAvailablePrincipal(principals);
		// 獲取當前已登陸的用戶
		if (!Global.TRUE.equals(Global.getConfig("user.multiAccountLogin"))){
			Collection<Session> sessions = getSystemService().getSessionDao().getActiveSessions(true, principal, UserUtils.getSession());
			if (sessions.size() > 0){
				// 若是是登陸進來的，則踢出已在線用戶
				if (UserUtils.getSubject().isAuthenticated()){
					for (Session session : sessions){
						getSystemService().getSessionDao().delete(session);
					}
				}
				// 記住我進來的，而且當前用戶已登陸，則退出當前用戶提示信息。
				else{
					UserUtils.getSubject().logout();
					throw new AuthenticationException("msg:帳號已在其它地方登陸，請從新登陸。");
				}
			}
		}
		User user = getSystemService().getUserByLoginName(principal.getLoginName());
		if (user != null) {
			SimpleAuthorizationInfo info = new SimpleAuthorizationInfo();
			List<Menu> list = UserUtils.getMenuList();
			for (Menu menu : list){
				if (StringUtils.isNotBlank(menu.getPermission())){
					// 添加基於Permission的權限信息
					for (String permission : StringUtils.split(menu.getPermission(),",")){
						info.addStringPermission(permission);
					}
				}
			}
			// 添加用戶權限
			info.addStringPermission("user");
			// 添加用戶角色信息
			for (Role role : user.getRoleList()){
				info.addRole(role.getEnname());
			}
			// 更新登陸IP和時間
			getSystemService().updateUserLoginInfo(user);
			// 記錄登陸日誌
			LogUtils.saveLog(Servlets.getRequest(), "系統登陸");
			return info;
		} else {
			return null;
		}
	}
	
	@Override
	protected void checkPermission(Permission permission, AuthorizationInfo info) {
		authorizationValidate(permission);
		super.checkPermission(permission, info);
	}
	
	@Override
	protected boolean[] isPermitted(List<Permission> permissions, AuthorizationInfo info) {
		if (permissions != null && !permissions.isEmpty()) {
            for (Permission permission : permissions) {
        		authorizationValidate(permission);
            }
        }
		return super.isPermitted(permissions, info);
	}
	
	@Override
	public boolean isPermitted(PrincipalCollection principals, Permission permission) {
		authorizationValidate(permission);
		return super.isPermitted(principals, permission);
	}
	
	@Override
	protected boolean isPermittedAll(Collection<Permission> permissions, AuthorizationInfo info) {
		if (permissions != null && !permissions.isEmpty()) {
            for (Permission permission : permissions) {
            	authorizationValidate(permission);
            }
        }
		return super.isPermittedAll(permissions, info);
	}
	
	/**
	 * 受權驗證方法
	 * @param permission
	 */
	private void authorizationValidate(Permission permission){
		// 模塊受權預留接口
	}
	
	/**
	 * 設定密碼校驗的Hash算法與迭代次數
	 */
	@PostConstruct
	public void initCredentialsMatcher() {
		HashedCredentialsMatcher matcher = new HashedCredentialsMatcher(SystemService.HASH_ALGORITHM);
		matcher.setHashIterations(SystemService.HASH_INTERATIONS);
		setCredentialsMatcher(matcher);
	}
	
//	/**
//	 * 清空用戶關聯權限認證，待下次使用時從新加載
//	 */
//	public void clearCachedAuthorizationInfo(Principal principal) {
//		SimplePrincipalCollection principals = new SimplePrincipalCollection(principal, getName());
//		clearCachedAuthorizationInfo(principals);
//	}

	/**
	 * 清空全部關聯認證
	 * @Deprecated 不須要清空，受權緩存保存到session中
	 */
	@Deprecated
	public void clearAllCachedAuthorizationInfo() {
//		Cache<Object, AuthorizationInfo> cache = getAuthorizationCache();
//		if (cache != null) {
//			for (Object key : cache.keys()) {
//				cache.remove(key);
//			}
//		}
	}

	/**
	 * 獲取系統業務對象
	 */
	public SystemService getSystemService() {
		if (systemService == null){
			systemService = SpringContextHolder.getBean(SystemService.class);
		}
		return systemService;
	}
	
	/**
	 * 受權用戶信息
	 */
	public static class Principal implements Serializable {

		private static final long serialVersionUID = 1L;
		
		private String id; // 編號
		private String loginName; // 登陸名
		private String name; // 姓名
		private boolean mobileLogin; // 是否手機登陸
		
//		private Map<String, Object> cacheMap;

		public Principal(User user, boolean mobileLogin) {
			this.id = user.getId();
			this.loginName = user.getLoginName();
			this.name = user.getName();
			this.mobileLogin = mobileLogin;
		}

		public String getId() {
			return id;
		}

		public String getLoginName() {
			return loginName;
		}

		public String getName() {
			return name;
		}

		public boolean isMobileLogin() {
			return mobileLogin;
		}

//		@JsonIgnore
//		public Map<String, Object> getCacheMap() {
//			if (cacheMap==null){
//				cacheMap = new HashMap<String, Object>();
//			}
//			return cacheMap;
//		}

		/**
		 * 獲取SESSIONID
		 */
		public String getSessionid() {
			try{
				return (String) UserUtils.getSession().getId();
			}catch (Exception e) {
				return "";
			}
		}
		
		@Override
		public String toString() {
			return id;
		}

	}
}

　　

怎麼入庫的呢？看截圖，仍是菜單管理中的操做：sql

 

 

四、控制器controller中的權限控制，對應在後臺添加菜單時，須要在控制器的方法上添加註解： 
@RequiresPermissions("cms:view")

 

對應後臺添加菜單時：
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程