• shiro回话管理

    目录

    一、会话管理

    1.1会话监听器

     SessionDao

     二、案例

    三、缓存管理

    3.1 初识缓存

    3.2 ehcache.xml介绍

    3.3 Ehcache的初步使用

    3.4 Ehcache完成realm授权

    一、会话管理

    Shiro独立的会话管理，包含了单点登录的业务场景；Nginx负载多个tomcat；

     Shiro提供了完整的企业级会话管理功能，不依赖于底层容器（如Tomcat），不管是J2SE还是J2EE环境都可以使用，提供了会话管理，会话事件监听，会话存储/持久化，容器无关的集群，失效/过期支持，对Web的透明支持，SSO单点登录的支持等特性。
      
      所谓会话，即用户访问应用时保持的连接关系，在多次交互中应用能够识别出当前访问的用户是谁，且可以在多次交互中保存一些数据。如访问一些网站时登录成功后，网站可以记住用户，且在退出之前都可以识别当前用户是谁。
     

    1.1会话监听器

    1. package com.zlp.ssm.shiro;
    2.  
    3. import org.apache.shiro.session.Session;
    4. import org.apache.shiro.session.SessionListener;
    5.  
    6. public class ShiroSessionListener implements SessionListener {
    7.     @Override
    8.     public void onStart(Session session) {
    9.         System.out.println("ShiroSessionListener.onstart..."+session.getId());
    10.     }
    11.  
    12.     @Override
    13.     public void onStop(Session session) {
    14.         System.out.println("ShiroSessionListener.onStop..."+session.getId());
    15.     }
    16.  
    17.     @Override
    18.     public void onExpiration(Session session) {
    19.         System.out.println("ShiroSessionListener.onExpiration..."+session.getId());
    20.     }
    21. }
    22.

     SessionDao


    Shiro提供SessionDAO用于会话的CRUD，即DAO（Data Access Object）模式实现。
      1）AbstractSessionDAO：提供了SessionDAO的基础实现，如生成会话ID等
      2）CachingSessionDAO：提供了对开发者透明的会话缓存的功能，需要设置相应的CacheManager 
      3）MemorySessionDAO：直接在内存中进行会话维护（默认方式）
      4）EnterpriseCacheSessionDAO：提供了缓存功能的会话维护，默认情况下使用MapCache实现，内部使用ConcurrentHashMap保存缓存的会话。 
     

     二、案例

    自定义一个监听器类并实现SessionListener接口

      在Spring与shiro的整合配置文件中配置相关文件 

     SessionLestentener 

    1. package com.zlp.shiroo;
    2.  
    3. import org.apache.shiro.session.Session;
    4. import org.apache.shiro.session.SessionListener;
    5.  
    6. public class SessionLestentener implements SessionListener {
    7.     @Override
    8.     public void onStart(Session session) {
    9.         System.out.println("SessionLestentener.onStart "+session.getId());
    10.     }
    11.  
    12.     @Override
    13.     public void onStop(Session session) {
    14.         System.out.println("SessionLestentener.onStop  "+session.getId());
    15.     }
    16.  
    17.     @Override
    18.     public void onExpiration(Session session) {
    19.         System.out.println("SessionLestentener.onExpiration "+session.getId());
    20.     }
    21. }

    Spring-shiro.xml 

    1.   
    2.     <bean id="securityManager" class="org.apache.shiro.web.mgt.DefaultWebSecurityManager">
    3.         <property name="realm" ref="shiroRealm" />
    4.         <property name="sessionManager" ref="sessionManager">property>
    5.     bean>
    6.  
    8.     <bean id="sessionIdGenerator" class="org.apache.shiro.session.mgt.eis.JavaUuidSessionIdGenerator">
    9.     bean>
    10.  
    11.     
    12.     <bean id="customSessionDao" class="org.apache.shiro.session.mgt.eis.MemorySessionDAO">
    13.         <property name="sessionIdGenerator" ref="sessionIdGenerator"/>
    14.     bean>
    15.  
    16.     
    17.     <bean id="shiroSessionListener" class="com.zlp.ssm.shiro.ShiroSessionListener"/>
    18.  
    19.     
    20.     <bean id="sessionIdCookie" class="org.apache.shiro.web.servlet.SimpleCookie">
    21.         
    22.         <constructor-arg value="shiro.session"/>
    23.         
    24.         <property name="maxAge" value="-1"/>
    25.         
    26.         <property name="httpOnly" value="true"/>
    27.     bean>
    28.  
    29.     
    30.     <bean id="sessionManager" class="org.apache.shiro.web.session.mgt.DefaultWebSessionManager">
    31.         
    32.         <property name="globalSessionTimeout" value="120000"/>
    33.         
    34.         <property name="sessionDAO" ref="customSessionDao"/>
    35.         
    36.         <property name="sessionValidationInterval" value="60000"/>
    37.         
    38.         
    39.         
    40.         
    41.         
    42.         <property name="deleteInvalidSessions" value="true"/>
    43.         
    44.         <property name="sessionListeners">
    45.             <list>
    46.                 <ref bean="shiroSessionListener"/>
    47.             list>
    48.         property>
    49.         
    50.         <property name="sessionIdCookie" ref="sessionIdCookie"/>
    51.         
    52.         <property name="sessionIdUrlRewritingEnabled" value="false"/>
    53.     bean>

    三、缓存管理

    解决反复授权查询数据库的问题

    3.1 初识缓存

    1. package com.zlp.ssm.ehcache;
    2.  
    3. import java.util.HashMap;
    4. import java.util.Map;
    5.  
    6. /**
    7.  * 利用map集合简易实现缓存原理
    8.  * @author zjjt
    9.  *
    10.  */
    11. public class EhcacheDemo1 {
    12. 	static Map<String, Object> cache = new HashMap<String, Object>();
    13. 	static Object getValue(String key) {
    14. 		Object value = cache.get(key);
    15. 		if(value == null) {
    16. 			System.out.println("hello zs");
    17. 			cache.put(key, new String[] {"zs"});
    18. 			return cache.get(key);
    19. 		}
    20. 		return value;
    21. 	}
    22. 	
    23. 	public static void main(String[] args) {
    24. 		System.out.println(getValue("sname"));
    25. 		System.out.println(getValue("sname"));
    26. 	}
    27. }
    28.

    3.2 ehcache.xml介绍

    1. "1.0" encoding="UTF-8"?>
    2. <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:noNamespaceSchemaLocation="http://ehcache.org/ehcache.xsd"
    4.          updateCheck="false">
    5.     
    6.     
    7.     
    8.     <diskStore path="D://xxx"/>
    9.  
    10.  
    11.     
    12.     
    13.     
    14.     
    15.     
    16.     
    17.     
    18.     
    19.     
    20.     
    21.     
    22.     <defaultCache eternal="false" maxElementsInMemory="1000" overflowToDisk="false" diskPersistent="false"
    23.                   timeToIdleSeconds="0" timeToLiveSeconds="600" memoryStoreEvictionPolicy="LRU"/>
    24.  
    25.  
    26.     
    27.     <cache name="com.javaxl.one.entity.User" eternal="false" maxElementsInMemory="100"
    28.            overflowToDisk="true" diskPersistent="true" timeToIdleSeconds="0"
    29.            timeToLiveSeconds="300" memoryStoreEvictionPolicy="LRU"/>
    30. ehcache>
    31.

    3.3 Ehcache的初步使用

    1. package com.zlp.ssm.ehcache;
    2.  
    3. import net.sf.ehcache.Cache;
    4. import net.sf.ehcache.CacheManager;
    5. import net.sf.ehcache.Element;
    6.  
    7. import java.io.InputStream;
    8.  
    9. public class EhcacheUtil {
    10.  
    11.     private static CacheManager cacheManager;
    12.  
    13.     static {
    14.         try {
    15.             InputStream is = EhcacheUtil.class.getResourceAsStream("/ehcache.xml");
    16.             cacheManager = CacheManager.create(is);
    17.         } catch (Exception e) {
    18.             throw new RuntimeException(e);
    19.         }
    20.     }
    21.  
    22.     private EhcacheUtil() {
    23.     }
    24.  
    25.     public static void put(String cacheName, Object key, Object value) {
    26.         Cache cache = cacheManager.getCache(cacheName);
    27.         if (null == cache) {
    28.             //以默认配置添加一个名叫cacheName的Cache
    29.             cacheManager.addCache(cacheName);
    30.             cache = cacheManager.getCache(cacheName);
    31.         }
    32.         cache.put(new Element(key, value));
    33.     }
    34.  
    35.  
    36.     public static Object get(String cacheName, Object key) {
    37.         Cache cache = cacheManager.getCache(cacheName);
    38.         if (null == cache) {
    39.             //以默认配置添加一个名叫cacheName的Cache
    40.             cacheManager.addCache(cacheName);
    41.             cache = cacheManager.getCache(cacheName);
    42.         }
    43.         Element element = cache.get(key);
    44.         return null == element ? null : element.getValue();
    45.     }
    46.  
    47.     public static void remove(String cacheName, Object key) {
    48.         Cache cache = cacheManager.getCache(cacheName);
    49.         cache.remove(key);
    50.     }
    51. }
    52.

     演示利用缓存存储数据

    1. package com.zlp.ssm.ehcache;
    2.  
    3.  
    4. /**
    5.  * 演示利用缓存存储数据
    6.  * @author Administrator
    7.  *
    8.  */
    9. public class EhcacheDemo2 {
    10. 	public static void main(String[] args) {
    11. 		System.out.println(System.getProperty("java.io.tmpdir"));
    12. //		EhcacheUtil.put("com.javaxl.four.entity.Book", 11, "zhangsan");
    13. //		System.out.println(EhcacheUtil.get("com.javaxl.four.entity.Book", 11));
    14.  
    15. 		EhcacheUtil.put("com.javaxl.one.entity.User", 11, "zhangsan");
    16. 		System.out.println(EhcacheUtil.get("com.javaxl.one.entity.User", 11));
    17.  
    18. 	}
    19. }
    20.

    3.4 Ehcache完成realm授权

    1. package com.zlp.ssm.shiro;
    2.  
    3. import com.zlp.ssm.biz.UserBiz;
    4. import com.zlp.ssm.ehcache.EhcacheUtil;
    5. import com.zlp.ssm.model.User;
    6. import org.apache.shiro.authc.AuthenticationException;
    7. import org.apache.shiro.authc.AuthenticationInfo;
    8. import org.apache.shiro.authc.AuthenticationToken;
    9. import org.apache.shiro.authc.SimpleAuthenticationInfo;
    10. import org.apache.shiro.authz.AuthorizationInfo;
    11. import org.apache.shiro.authz.SimpleAuthorizationInfo;
    12. import org.apache.shiro.realm.AuthorizingRealm;
    13. import org.apache.shiro.subject.PrincipalCollection;
    14. import org.apache.shiro.util.ByteSource;
    15.  
    16. import java.util.Set;
    17.  
    18. public class Myrealm extends AuthorizingRealm {
    19.     private UserBiz userBiz;
    20.  
    21.     public UserBiz getUserBiz() {
    22.         return userBiz;
    23.     }
    24.  
    25.     public void setUserBiz(UserBiz userBiz) {
    26.         this.userBiz = userBiz;
    27.     }
    28.  
    29.     @Override
    30.     protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) {
    31.         System.out.println("用户授权...");
    32.         String username = principals.getPrimaryPrincipal().toString();
    33.         User user = userBiz.queryByName(username);
    34.         String user_role_key = "user:roles:";
    35.         String user_pers_key = "user:pers:";
    36.         Set<String> roles = userBiz.getRolesByUserId(user.getUsername());
    37.         Set<String> pers = userBiz.getPersByUserId(user.getUsername());
    38.         if(roles == null||roles.size()==0){
    39.             System.out.println("从数据库中获取相关角色信息...");
    40.             roles=userBiz.getRolesByUserId(user.getUsername());
    41.             EhcacheUtil.put(user_role_key+user.getUserid(),user.getUserid(),roles);
    42.         }
    43.         if(pers==null||pers.size()==0){
    44.             System.out.println("从数据库中获取相关权限信息...");
    45.             pers=userBiz.getPersByUserId(user.getUsername());
    46.             EhcacheUtil.put(user_pers_key+user.getUserid(),user.getUserid(),pers);
    47.         }
    48.         SimpleAuthorizationInfo info=new SimpleAuthorizationInfo();
    49.         info.setRoles(roles);
    50.         info.setStringPermissions(pers);
    51.         return info;
    52.     }
    53.  
    54.     @Override
    55.     protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken token) throws AuthenticationException {
    56.         System.out.println("身份验证...");
    57.         String username = token.getPrincipal().toString();
    58.         String password = token.getCredentials().toString();
    59.         User user = userBiz.queryByName(username);
    60.         AuthenticationInfo info=new SimpleAuthenticationInfo(
    61.                 user.getUsername(),
    62.                 user.getPassword(),
    63.                 ByteSource.Util.bytes(user.getSalt()),
    64.                 this.getName()
    65.         );
    66.         return info;
    67.     }
    68. }
    69.

    今天的分享就到这啦！！！我们下期再见~~~~

  • 相关阅读:
    技术点：前端缓存（web 缓存）详解
    ILRuntime使用指南
    我们用到的3种Mock测试方案​
    Linux操作系统安装与gcc和内核升级
    初始化antdv项目，按需引入
    回溯法（Java）
    Hadoop大数据初入门----haddop伪分布式安装
    【Java 进阶篇】JDBC ResultSet 类详解
    【JAVA】项目部署
    什么是CDN？CDN的技术原理是什么？
  • 原文地址：https://blog.csdn.net/weixin_63544775/article/details/126581078