碼上歡樂
相關內容    簡體    繁體

並發登錄人數控制--Shiro系列(二)

本文轉載自   查看原文   2016-07-21 10:40   2746    權限

為了安全起見，同一個賬號理應同時只能在一台設備上登錄，后面登錄的踢出前面登錄的。用Shiro可以輕松實現此功能。

shiro中sessionManager是專門作會話管理的，而sessinManager將會話保存在sessionDAO中，如果不給sessionManager注入

sessionDAO，會話將是瞬時狀態，沒有被保存起來，從sessionManager里取session,是取不到的。

此例中sessionDAO注入了Ehcache緩存，會話被保存在Ehcache中，不知Ehcache為何物的，請自行查閱資料。

完整demo下載：http://download.csdn.net/detail/qq_33556185/9555720

shiro.xml

 

[html]  view plain  copy
 
 在CODE上查看代碼片派生到我的代碼片
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"  
  3.     xmlns:mvc="http://www.springframework.org/schema/mvc"  
  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans     
  5.     http://www.springframework.org/schema/beans/spring-beans-4.2.xsd     
  6.     http://www.springframework.org/schema/tx     
  7.     http://www.springframework.org/schema/tx/spring-tx-4.2.xsd    
  8.     http://www.springframework.org/schema/context    
  9.     http://www.springframework.org/schema/context/spring-context-4.2.xsd    
  10.     http://www.springframework.org/schema/mvc    
  11.     http://www.springframework.org/schema/mvc/spring-mvc-4.2.xsd">  
  12.        
  13. <bean id="sessionManager" class="org.apache.shiro.web.session.mgt.DefaultWebSessionManager">    
  14.         <property name="globalSessionTimeout" value="1800000"/>    
  15.         <property name="deleteInvalidSessions" value="true"/>    
  16.         <property name="sessionDAO" ref="sessionDAO"/>    
  17.         <property name="sessionIdCookieEnabled" value="true"/>    
  18.         <property name="sessionIdCookie" ref="sessionIdCookie"/>    
  19.         <property name="sessionValidationSchedulerEnabled" value="true"/>  
  20.         <property name="sessionValidationScheduler" ref="sessionValidationScheduler"/>  
  21.          <property name="cacheManager" ref="shiroEhcacheManager"/>  
  22. </bean>    
  23.        <!-- 會話DAO，sessionManager里面的session需要保存在會話Dao里，沒有會話Dao，session是瞬時的，沒法從  
  24.      sessionManager里面拿到session -->    
  25.     <bean id="sessionDAO" class="org.apache.shiro.session.mgt.eis.EnterpriseCacheSessionDAO">    
  26.         <property name="sessionIdGenerator" ref="sessionIdGenerator"/>    
  27.         <property name="activeSessionsCacheName" value="shiro-activeSessionCache"/>  
  28.     </bean>   
  29.       <!-- 緩存管理器 -->  
  30.   <bean id="shiroEhcacheManager" class="org.apache.shiro.cache.ehcache.EhCacheManager">    
  31.   <property name="cacheManagerConfigFile" value="classpath:ehcache.xml" />    
  32.   </bean>  
  33. <bean id="sessionIdCookie" class="org.apache.shiro.web.servlet.SimpleCookie">    
  34.         <constructor-arg value="sid"/>  
  35.         <property name="httpOnly" value="true"/>  
  36.         <property name="maxAge" value="-1"/>   
  37. </bean>   
  38.  <!-- 會話ID生成器 -->  
  39.  <bean id="sessionIdGenerator" class="org.apache.shiro.session.mgt.eis.JavaUuidSessionIdGenerator"></bean>  
  40. <bean id="kickoutSessionControlFilter"  class="com.core.shiro.KickoutSessionControlFilter">    
  41.     <property name="sessionManager" ref="sessionManager"/>    
  42.     <property name="cacheManager" ref="shiroEhcacheManager"/>  
  43.     <property name="kickoutAfter" value="false"/>    
  44.     <property name="maxSession" value="1"/>    
  45.     <property name="kickoutUrl" value="/toLogin?kickout=1"/>    
  46. </bean>   
  47.       <bean id="logout" class="org.apache.shiro.web.filter.authc.LogoutFilter">  
  48.         <property name="redirectUrl" value="/toLogin" />  
  49.        </bean>   
  50.           <!-- 會話驗證調度器 -->  
  51.     <bean id="sessionValidationScheduler" class="org.apache.shiro.session.mgt.ExecutorServiceSessionValidationScheduler ">  
  52.         <property name="interval" value="1800000"/>  
  53.         <property name="sessionManager" ref="sessionManager"/>  
  54.     </bean>  
  55.      <!-- Shiro Filter 攔截器相關配置 -->    
  56.     <bean id="shiroFilter" class="org.apache.shiro.spring.web.ShiroFilterFactoryBean">    
  57.         <!-- securityManager -->    
  58.         <property name="securityManager" ref="securityManager" />    
  59.         <!-- 登錄路徑 -->    
  60.         <property name="loginUrl" value="/toLogin" />    
  61.         <!-- 用戶訪問無權限的鏈接時跳轉此頁面  -->    
  62.         <property name="unauthorizedUrl" value="/unauthorizedUrl.jsp" />    
  63.          
  64.         <!-- 過濾鏈定義 -->    
  65.          <property name="filters">    
  66.          <map>    
  67.              <entry key="kickout" value-ref="kickoutSessionControlFilter"/>    
  68.          </map>    
  69.      </property>   
  70.         <property name="filterChainDefinitions">    
  71.             <value>    
  72.                 /loginin=kickout,anon  
  73.                  /logout = logout  
  74.                 /toLogin=anon  
  75.                 /css/**=anon   
  76.                 /html/**=anon   
  77.                 /images/**=anon  
  78.                 /js/**=anon   
  79.                 /upload/**=anon   
  80.                 <!-- /userList=roles[admin] -->  
  81.                 /userList=kickout,authc,perms[/userList]  
  82.                 /toRegister=kickout,authc,perms[/toRegister]  
  83.                 /toDeleteUser=kickout,authc,perms[/toDeleteUser]  
  84.                 /** = kickout,authc  
  85.              </value>    
  86.         </property>    
  87.     </bean>    
  88.     
  89.     <!-- securityManager -->    
  90.     <bean id="securityManager" class="org.apache.shiro.web.mgt.DefaultWebSecurityManager">    
  91.         <property name="realm" ref="myRealm" />    
  92.          <property name="sessionManager" ref="sessionManager"/>  
  93.          <property name="cacheManager" ref="shiroEhcacheManager"/>  
  94.     </bean>    
  95.     <!-- 自定義Realm實現 -->   
  96.     <bean id="myRealm" class="com.core.shiro.CustomRealm" />    
  97.       
  98.     <bean id="lifecycleBeanPostProcessor" class="org.apache.shiro.spring.LifecycleBeanPostProcessor" />  
  99.       
  100.     <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">    
  101.        <property name="prefix" value="/"/>    
  102.        <property name="suffix" value=".jsp"></property>    
  103.     </bean>  
  104. </beans>    

ehcache.xml

 

 

[html]  view plain  copy
 
 在CODE上查看代碼片派生到我的代碼片
  1. <?xml version="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" maxBytesLocalDisk="20G" maxBytesLocalOffHeap="50M">  
  5.         
  6.     <diskStore path="java.io.tmpdir"/> <!-- 系統的默認臨時文件路徑 -->  
  7.     <defaultCache eternal="false"     
  8.         maxElementsInMemory="10000"    
  9.         overflowToDisk="false"     
  10.         timeToIdleSeconds="0"    
  11.         timeToLiveSeconds="0"     
  12.         memoryStoreEvictionPolicy="LFU" />    
  13.    <!--   
  14.     eternal：緩存中對象是否為永久的，如果是，超時設置將被忽略，對象從不過期。  
  15.     maxElementsInMemory：緩存中允許創建的最大對象數  
  16.     overflowToDisk：內存不足時，是否啟用磁盤緩存。  
  17.     timeToIdleSeconds：緩存數據的鈍化時間，也就是在一個元素消亡之前，  
  18.             兩次訪問時間的最大時間間隔值，這只能在元素不是永久駐留時有效，  
  19.      如果該值是 0 就意味着元素可以停頓無窮長的時間。  
  20.     timeToLiveSeconds：緩存數據的生存時間，也就是一個元素從構建到消亡的最大時間間隔值，  
  21.            這只能在元素不是永久駐留時有效，如果該值是0就意味着元素可以停頓無窮長的時間。  
  22.     memoryStoreEvictionPolicy：緩存滿了之后的淘汰算法。  
  23.     1 FIFO，先進先出  
  24.     2 LFU，最少被使用，緩存的元素有一個hit屬性，hit值最小的將會被清出緩存。  
  25.     3 LRU，最近最少使用的，緩存的元素有一個時間戳，當緩存容量滿了，而又需要騰出地方來緩存新的元素的時候，那么現有緩存元素中時間戳離當前時間最遠的元素將被清出緩存。  
  26.     -->  
  27.     <cache name="myCache"  eternal="false"     
  28.         maxElementsInMemory="10000"    
  29.         overflowToDisk="false"     
  30.         timeToIdleSeconds="0"    
  31.         timeToLiveSeconds="0"     
  32.         memoryStoreEvictionPolicy="LFU" />    
  33.     <cache name="shiro-activeSessionCache" eternal="false"  
  34.           maxElementsInMemory="10000"    
  35.           overflowToDisk="true"  
  36.           timeToIdleSeconds="0"  
  37.           timeToLiveSeconds="0"/>  
  38. </ehcache>   

login.jsp的javascript:

 

 

[javascript]  view plain  copy
 
 在CODE上查看代碼片派生到我的代碼片
  1. <script type="text/javascript">  
  2.     function kickout(){  
  3.        var href=location.href;  
  4.        if(href.indexOf("kickout")>0){  
  5.            alert("您的賬號在另一台設備上登錄，您被擠下線，若不是您本人操作，請立即修改密碼！");  
  6.        }   
  7.     }  
  8.     window.onload=kickout();   
  9. </script>  

KickoutSessionControlFilter：

 

 

[java]  view plain  copy
 
 在CODE上查看代碼片派生到我的代碼片
  1. package com.core.shiro;  
  2.   
  3. import java.io.Serializable;  
  4. import java.util.Deque;  
  5. import java.util.LinkedList;  
  6. import javax.servlet.ServletRequest;  
  7. import javax.servlet.ServletResponse;  
  8. import org.apache.shiro.cache.Cache;  
  9. import org.apache.shiro.cache.CacheManager;  
  10. import org.apache.shiro.session.Session;  
  11. import org.apache.shiro.session.mgt.DefaultSessionKey;  
  12. import org.apache.shiro.session.mgt.SessionManager;  
  13. import org.apache.shiro.subject.Subject;  
  14. import org.apache.shiro.web.filter.AccessControlFilter;  
  15. import org.apache.shiro.web.util.WebUtils;  
  16. public class KickoutSessionControlFilter  extends AccessControlFilter{  
  17.     private String kickoutUrl; //踢出后到的地址  
  18.     private boolean kickoutAfter; //踢出之前登錄的/之后登錄的用戶 默認踢出之前登錄的用戶  
  19.     private int maxSession; //同一個帳號最大會話數 默認1  
  20.     private SessionManager sessionManager;  
  21.     private Cache<String, Deque<Serializable>> cache;  
  22.   
  23.     public void setKickoutUrl(String kickoutUrl) {  
  24.         this.kickoutUrl = kickoutUrl;  
  25.     }  
  26.   
  27.     public void setKickoutAfter(boolean kickoutAfter) {  
  28.         this.kickoutAfter = kickoutAfter;  
  29.     }  
  30.   
  31.     public void setMaxSession(int maxSession) {  
  32.         this.maxSession = maxSession;  
  33.     }  
  34.   
  35.     public void setSessionManager(SessionManager sessionManager) {  
  36.         this.sessionManager = sessionManager;  
  37.     }  
  38.   
  39.     public void setCacheManager(CacheManager cacheManager) {  
  40.         this.cache = cacheManager.getCache("shiro-activeSessionCache");  
  41.     }  
  42.      /** 
  43.       * 是否允許訪問，返回true表示允許 
  44.       */  
  45.     @Override  
  46.     protected boolean isAccessAllowed(ServletRequest request, ServletResponse response, Object mappedValue) throws Exception {  
  47.         return false;  
  48.     }  
  49.     /** 
  50.      * 表示訪問拒絕時是否自己處理，如果返回true表示自己不處理且繼續攔截器鏈執行，返回false表示自己已經處理了（比如重定向到另一個頁面）。 
  51.      */  
  52.     @Override  
  53.     protected boolean onAccessDenied(ServletRequest request, ServletResponse response) throws Exception {  
  54.         Subject subject = getSubject(request, response);  
  55.         if(!subject.isAuthenticated() && !subject.isRemembered()) {  
  56.             //如果沒有登錄，直接進行之后的流程  
  57.             return true;  
  58.         }  
  59.   
  60.         Session session = subject.getSession();  
  61.         String username = (String) subject.getPrincipal();  
  62.         Serializable sessionId = session.getId();  
  63.   
  64.         // 初始化用戶的隊列放到緩存里  
  65.         Deque<Serializable> deque = cache.get(username);  
  66.         if(deque == null) {  
  67.             deque = new LinkedList<Serializable>();  
  68.             cache.put(username, deque);  
  69.         }  
  70.   
  71.         //如果隊列里沒有此sessionId，且用戶沒有被踢出；放入隊列  
  72.         if(!deque.contains(sessionId) && session.getAttribute("kickout") == null) {  
  73.             deque.push(sessionId);  
  74.         }  
  75.   
  76.         //如果隊列里的sessionId數超出最大會話數，開始踢人  
  77.         while(deque.size() > maxSession) {  
  78.             Serializable kickoutSessionId = null;  
  79.             if(kickoutAfter) { //如果踢出后者  
  80.                 kickoutSessionId=deque.getFirst();  
  81.                 kickoutSessionId = deque.removeFirst();  
  82.             } else { //否則踢出前者  
  83.                 kickoutSessionId = deque.removeLast();  
  84.             }  
  85.             try {  
  86.                 Session kickoutSession = sessionManager.getSession(new DefaultSessionKey(kickoutSessionId));  
  87.                 if(kickoutSession != null) {  
  88.                     //設置會話的kickout屬性表示踢出了  
  89.                     kickoutSession.setAttribute("kickout", true);  
  90.                 }  
  91.             } catch (Exception e) {//ignore exception  
  92.                 e.printStackTrace();  
  93.             }  
  94.         }  
  95.   
  96.         //如果被踢出了，直接退出，重定向到踢出后的地址  
  97.         if (session.getAttribute("kickout") != null) {  
  98.             //會話被踢出了  
  99.             try {  
  100.                 subject.logout();  
  101.             } catch (Exception e) {   
  102.             }  
  103.             WebUtils.issueRedirect(request, response, kickoutUrl);  
  104.             return false;  
  105.         }  
  106.         return true;  
  107.     }  
  108. }  

http://blog.csdn.net/qq_33556185/article/details/51744004

 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 SpringBoot Shiro並發登錄人數控制 2017.6.30 用shiro實現並發登錄人數控制（實際項目中的實現） 2017.4.12 開濤shiro教程-第十八章-並發登錄人數控制 Shiro - 限制並發人數登錄與剔除 SpringBoot 實現系統控制並發登錄人數 Shell 腳本進程並發&進程數控制 Shell腳本實現模擬並發及並發數控制 「自己開發直播」rtmp-nginx-module實現直播狀態、觀看人數控制 Linux-Shell-使用mkfifo實現多任務並發及並發數控制 Java並發工具類之並發數控制神器Semaphore
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM