Apache shiro集群实现（六）分布式集群系统下的高可用session解决方案---Session共享

以你之姓@ 2022-08-05 12:21 121阅读 0赞

[Apache shiro集群实现 （一） shiro入门介绍][Apache shiro_ _ shiro]

[Apache shiro集群实现 （二） shiro 的INI配置][Apache shiro_ _ shiro _INI]

[Apache shiro集群实现 （三）shiro身份认证（Shiro Authentication）][Apache shiro_ _shiro_Shiro Authentication]

[Apache shiro集群实现 （四）shiro授权（Authentication）--访问控制][Apache shiro_ _shiro_Authentication_--]

[Apache shiro集群实现 （五）分布式集群系统下的高可用session解决方案][Apache shiro_ _session]

[Apache shiro集群实现 （六）分布式集群系统下的高可用session解决方案---Session共享][Apache shiro_ _session_---Session]

[Apache shiro集群实现（七）分布式集群系统下---cache共享][Apache shiro_---cache]  
[Apache shiro集群实现 （八） web集群时session同步的3种方法][Apache shiro_ _ web_session_3]

Apache Shiro的基本配置和构成这里就不详细说明了，其官网有说明文档，这里仅仅说明集群的解决方案，详细配置：[shiro web config][]

Apache Shiro集群要解决2个问题，一个是session的共享问题，一个是授权信息的cache共享问题，官网给的例子是Ehcache的实现，在配置说明上不算很详细，我这里用nosql（redis）替代了ehcache做了session和cache的存储。

shiro spring的默认配置（单机，非集群）

<bean id="securityManager" class="org.apache.shiro.web.mgt.DefaultWebSecurityManager"> 
 <property name="realm" ref="shiroDbRealm" /> 
 <property name="cacheManager" ref="memoryConstrainedCacheManager" /> 
 </bean> 
 
  
 <bean id="shiroDbRealm" class="com.xxx.security.shiro.custom.ShiroDbRealm"> 
 <property name="credentialsMatcher" ref="customCredentialsMather"></property> 
 </bean> 
  
 <bean id="memoryConstrainedCacheManager" class="org.apache.shiro.cache.MemoryConstrainedCacheManager" /> 
 
  
 <bean id="lifecycleBeanPostProcessor" class="org.apache.shiro.spring.LifecycleBeanPostProcessor"/> 
 
 <bean id="shiroFilter" class="org.apache.shiro.spring.web.ShiroFilterFactoryBean"> 
 <property name="securityManager" ref="securityManager" /> 
 <property name="loginUrl" value="/login" /> 
 <property name="successUrl" value="/project" /> 
 <property name="filterChainDefinitions"> 
 <value> 
 /login = authc 
 /logout = logout 
 </value> 
 </property> 
 </bean>

上面的配置是shiro非集群下的配置，DefaultWebSecurityManager类不需要注入sessionManager属性，它会使用默认的sessionManager类，请看源码

public DefaultWebSecurityManager() { 
 super(); 
 ((DefaultSubjectDAO) this.subjectDAO).setSessionStorageEvaluator(new DefaultWebSessionStorageEvaluator()); 
 this.sessionMode = HTTP_SESSION_MODE; 
 setSubjectFactory(new DefaultWebSubjectFactory()); 
 setRememberMeManager(new CookieRememberMeManager()); 
 setSessionManager(new ServletContainerSessionManager()); 
 }

在最后一行，set了默认的servlet容器实现的sessionManager，sessionManager会管理session的创建、删除等等。如果我们需要让session在集群中共享，就需要替换这个默认的sessionManager。在其官网上原话是这样的：

Native Sessions 
 
 If you want your session configuration settings and clustering to be portable across servlet containers 
 (e.g. Jetty in testing, but Tomcat or JBoss in production), or you want to control specific session/clustering 
 features, you can enable Shiro's native session management. 
 
 The word 'Native' here means that Shiro's own enterprise session management implementation will be used to support 
 all Subject and HttpServletRequest sessions and bypass the servlet container completely. But rest assured - Shiro 
 implements the relevant parts of the Servlet specification directly so any existing web/http related code works as 
 expected and never needs to 'know' that Shiro is transparently managing sessions. 
 
 DefaultWebSessionManager 
 
 To enable native session management for your web application, you will need to configure a native web-capable 
 session manager to override the default servlet container-based one. You can do that by configuring an instance of 
 DefaultWebSessionManager on Shiro's SecurityManager.

我们可以看到如果要用集群，就需要用本地会话，这里shiro给我准备了一个默认的native session manager，DefaultWebSessionManager，所以我们要修改spring配置文件，注入DefaultWebSessionManager

我们继续看DefaultWebSessionManager的源码，发现其父类DefaultSessionManager中有sessionDAO属性，这个属性是真正实现了session储存的类，这个就是我们自己实现的redis session的储存类。

protected SessionDAO sessionDAO; 
 
 private CacheManager cacheManager; 
 
 private boolean deleteInvalidSessions; 
 
 public DefaultSessionManager() { 
 this.deleteInvalidSessions = true; 
 this.sessionFactory = new SimpleSessionFactory(); 
 this.sessionDAO = new MemorySessionDAO(); 
 }

这里我们看到了，如果不自己注入sessionDAO，defaultWebSessionManager会使用MemorySessionDAO做为默认实现类，这个肯定不是我们想要的，所以这就自己动手实现sessionDAO吧。

package com.tgb.itoo.authority.cache;
 
 import java.io.Serializable;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
 
 import org.apache.shiro.session.Session;
 import org.apache.shiro.session.UnknownSessionException;
 import org.apache.shiro.session.mgt.eis.AbstractSessionDAO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class RedisSessionDAO extends AbstractSessionDAO {
 
 	private static Logger logger = LoggerFactory.getLogger(RedisSessionDAO.class);
 	/**
 	 * shiro-redis的session对象前缀
 	 */
 	private RedisManager redisManager;
 	
 	/**
 	 * The Redis key prefix for the sessions 
 	 */
 	private String keyPrefix = "shiro_redis_session:";
 	
 	@Override
 	public void update(Session session) throws UnknownSessionException {
 		this.saveSession(session);
 	}
 	
 	/**
 	 * save session
 	 * @param session
 	 * @throws UnknownSessionException
 	 */
 	private void saveSession(Session session) throws UnknownSessionException{
 		if(session == null || session.getId() == null){
 			logger.error("session or session id is null");
 			return;
 		}
 		
 		byte[] key = getByteKey(session.getId());
 		byte[] value = SerializeUtils.serialize(session);
 		session.setTimeout(redisManager.getExpire()*1000);		
 		this.redisManager.set(key, value, redisManager.getExpire());
 	}
 
 	@Override
 	public void delete(Session session) {
 		if(session == null || session.getId() == null){
 			logger.error("session or session id is null");
 			return;
 		}
 		redisManager.del(this.getByteKey(session.getId()));
 
 	}
 
 	//用来统计当前活动的session
 	@Override
 	public Collection<Session> getActiveSessions() {
 		Set<Session> sessions = new HashSet<Session>();
 		
 		Set<byte[]> keys = redisManager.keys(this.keyPrefix + "*");
 		if(keys != null && keys.size()>0){
 			for(byte[] key:keys){
 				Session s = (Session)SerializeUtils.deserialize(redisManager.get(key));
 				sessions.add(s);
 			}
 		}
 		
 		return sessions;
 	}
 
 	@Override
 	protected Serializable doCreate(Session session) {
 		Serializable sessionId = this.generateSessionId(session); 
 this.assignSessionId(session, sessionId);
 this.saveSession(session);
 		return sessionId;
 	}
 
 	@Override
 	protected Session doReadSession(Serializable sessionId) {
 		if(sessionId == null){
 			logger.error("session id is null");
 			return null;
 		}
 		
 		Session s = (Session)SerializeUtils.deserialize(redisManager.get(this.getByteKey(sessionId)));
 		return s;
 	}
 	
 	/**
 	 * 获得byte[]型的key
 	 * @param key
 	 * @return
 	 */
 	private byte[] getByteKey(Serializable sessionId){
 		String preKey = this.keyPrefix + sessionId;
 		return preKey.getBytes();
 	}
 
 	public RedisManager getRedisManager() {
 		return redisManager;
 	}
 
 	public void setRedisManager(RedisManager redisManager) {
 		this.redisManager = redisManager;
 		
 		/**
 		 * 初始化redisManager
 		 */
 		this.redisManager.init();
 	}
 
 	/**
 	 * Returns the Redis session keys
 	 * prefix.
 	 * @return The prefix
 	 */
 	public String getKeyPrefix() {
 		return keyPrefix;
 	}
 
 	/**
 	 * Sets the Redis sessions key 
 	 * prefix.
 	 * @param keyPrefix The prefix
 	 */
 	public void setKeyPrefix(String keyPrefix) {
 		this.keyPrefix = keyPrefix;
 	}
 }

我们自定义RedisSessionDAO继承AbstractSessionDAO，实现对session操作的方法，可以用redis、mongoDB等进行实现。

这个是自己redis的RedisCacheManager存储实现类：

package com.tgb.itoo.authority.cache;
 
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
 import org.apache.shiro.cache.Cache;
 import org.apache.shiro.cache.CacheException;
 import org.apache.shiro.cache.CacheManager;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class RedisCacheManager implements CacheManager{
 
 	private static final Logger logger = LoggerFactory
 			.getLogger(RedisCacheManager.class);
 
 	// fast lookup by name map
 	private final ConcurrentMap<String, Cache> caches = new ConcurrentHashMap<String, Cache>();
 
 	private RedisManager redisManager;
 
 	/**
 	 * The Redis key prefix for caches 
 	 */
 	private String keyPrefix = "shiro_redis_cache:";
 	
 	/**
 	 * Returns the Redis session keys
 	 * prefix.
 	 * @return The prefix
 	 */
 	public String getKeyPrefix() {
 		return keyPrefix;
 	}
 
 	/**
 	 * Sets the Redis sessions key 
 	 * prefix.
 	 * @param keyPrefix The prefix
 	 */
 	public void setKeyPrefix(String keyPrefix) {
 		this.keyPrefix = keyPrefix;
 	}
 	
 	@Override
 	public <K, V> Cache<K, V> getCache(String name) throws CacheException {
 		logger.debug("获取名称为: " + name + " 的RedisCache实例");
 		
 		Cache c = caches.get(name);
 		
 		if (c == null) {
 
 			// initialize the Redis manager instance
 			redisManager.init();
 			
 			// create a new cache instance
 			c = new RedisCache<K, V>(redisManager, keyPrefix);
 			
 			// add it to the cache collection
 			caches.put(name, c);
 		}
 		return c;
 	}
 
 	public RedisManager getRedisManager() {
 		return redisManager;
 	}
 
 	public void setRedisManager(RedisManager redisManager) {
 		this.redisManager = redisManager;
 	}
 }

这样RedisSessionDAO我们就完成了，下面继续修改我们spring配置文件：

<?xml version="1.0" encoding="UTF-8"?>
 <beans xmlns="http://www.springframework.org/schema/beans"
 	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jee="http://www.springframework.org/schema/jee"
 	xmlns:context="http://www.springframework.org/schema/context"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans 
 	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
 	http://www.springframework.org/schema/aop 
 	http://www.springframework.org/schema/aop/spring-aop-3.0.xsd 
 	http://www.springframework.org/schema/tx 
 	http://www.springframework.org/schema/tx/spring-tx-3.0.xsd 
 	http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd
 	http://www.springframework.org/schema/context
 	http://www.springframework.org/schema/context/spring-context-3.0.xsd"
 	default-lazy-init="true">
 
 	
 	<context:annotation-config />
 	<bean id="propertyConfigurer"
 		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
 		<property name="locations">
 			<list>
 				<value>classpath:config/shiro-cas.properties</value>
 			</list>
 		</property>
 	</bean>
 	
 	
 	
 	<jee:local-slsb id="PermissionManager"
 		jndi-name="java:global/itoo-authority-role-ear/itoo-authority-shiro-core-0.0.1-SNAPSHOT/PermissionManager!com.tgb.itoo.authority.service.ShiroBean"
 		business-interface="com.tgb.itoo.authority.service.ShiroBean"></jee:local-slsb>
 
 
 
 
 
 
 
 
 	
 	<bean id="shiroSecurityFilter" class="org.apache.shiro.spring.web.ShiroFilterFactoryBean">
 		<property name="securityManager" ref="securityManager"></property>
 		<property name="loginUrl" value="${loginUrl}"></property>
 		<property name="successUrl" value="${successUrl}"></property>
 		<property name="filters">
 			<map>
 				<entry key="casFilter">
 					<bean class="org.apache.shiro.cas.CasFilter">
 						
 						<property name="failureUrl" value="/message.jsp" />
 					</bean>
 				</entry>
 			</map>
 		</property>
 		
 		<property name="filterChainDefinitions">
 			<value>
 				/message.jsp=anon
 				/logout=logout
 				/shiro-cas=casFilter
 				/** =user
 			</value>
 		</property>
 	</bean>
 	
 
 	
 	<bean id="lifecycleBeanPostProcessor" class="org.apache.shiro.spring.LifecycleBeanPostProcessor" />
 
 	
 	<bean id="securityManager" class="org.apache.shiro.web.mgt.DefaultWebSecurityManager">
 		<property name="realm" ref="shiroRealm"></property>
 		<property name="sessionMode" value="http"></property>
 		<property name="subjectFactory" ref="casSubjectFactory"></property>
 		
 		
 
 		
 		<property name="cacheManager" ref="redisCacheManager" />
 
 		
 		<property name="sessionManager" ref="sessionManager"></property>
 	</bean>
 
 
 	
 
 	
 	
 	
 	
 	
 
 	
 	<bean id="redisCacheManager" class="com.tgb.itoo.authority.cache.RedisCacheManager">
 		<property name="redisManager" ref="redisManager" />
 	</bean>
 	
 	<bean id="redisCache" class="com.tgb.itoo.authority.cache.RedisCache">
 		<constructor-arg ref="redisManager"></constructor-arg>
 	</bean>
 
 	<bean id="redisManager" class="com.tgb.itoo.authority.cache.RedisManager"></bean>
 
 	
 
 
 
 	
 	<bean id="redisShiroSessionDAO" class="com.tgb.itoo.authority.cache.RedisSessionDAO">
 		<property name="redisManager" ref="redisManager" />
 	</bean>
 
 
 
 	
 	
 	<bean id="sessionManager"
 		class="org.apache.shiro.web.session.mgt.DefaultWebSessionManager">
 		
 		<property name="globalSessionTimeout" value="1800000" />
 		
 		<property name="deleteInvalidSessions" value="true" />
 
 		
 		<property name="sessionValidationInterval" value="1800000" />
 
 		
 		<property name="sessionDAO" ref="redisShiroSessionDAO" />
 		
 		<property name="sessionIdCookie" ref="sharesession" />
 		
 		<property name="sessionValidationSchedulerEnabled" value="true" />
 
 	</bean>
 
 
 	
 	<bean id="sharesession" class="org.apache.shiro.web.servlet.SimpleCookie">
 		
 		<constructor-arg name="name" value="SHAREJSESSIONID" />
 		
 		<property name="path" value="/" />
 		<property name="httpOnly" value="true"/>
 	</bean>
 
 
 
 
 
 
 
 	
 	<bean id="shiroRealm" class="com.tgb.itoo.authority.service.ShiroRealmBean">
 		<property name="defaultRoles" value="user"></property>
 
 		
 		<property name="permissionMgr" ref="PermissionManager"></property>
 		<property name="casServerUrlPrefix" value="${casServerUrlPrefix}"></property>
 		<property name="casService" value="${casService}"></property>
 	</bean>
 
 	<bean id="casSubjectFactory" class="org.apache.shiro.cas.CasSubjectFactory" />
 
 	
 	
 	
 	
 
 	
 	<bean
 		class="org.springframework.aop.framework.autoproxy.DefaultAdvisorAutoProxyCreator"
 		depends-on="lifecycleBeanPostProcessor"></bean>
 	<bean
 		class="org.apache.shiro.spring.security.interceptor.AuthorizationAttributeSourceAdvisor">
 		<property name="securityManager" ref="securityManager" />
 	</bean>
 </beans>

这样第一个问题，session的共享问题我们就解决好了，下一篇介绍另一个问题，cache的共享问题。

[Apache shiro_ _ shiro]: http://blog.csdn.net/lishehe/article/details/45218251
[Apache shiro_ _ shiro _INI]: http://blog.csdn.net/lishehe/article/details/45218605
[Apache shiro_ _shiro_Shiro Authentication]: http://blog.csdn.net/lishehe/article/details/45219023
[Apache shiro_ _shiro_Authentication_--]: http://blog.csdn.net/lishehe/article/details/45219483
[Apache shiro_ _session]: http://blog.csdn.net/lishehe/article/details/45223477
[Apache shiro_ _session_---Session]: http://blog.csdn.net/lishehe/article/details/45223823
[Apache shiro_---cache]: http://blog.csdn.net/lishehe/article/details/45224181
[Apache shiro_ _ web_session_3]: http://blog.csdn.net/lishehe/article/details/45224591
[shiro web config]: http://shiro.apache.org/web.html