Session(数据)共享的前后端分离Shiro实战

1，前言

本文期望描述如何使用Shiro构建基本的安全登录和权限验证。本文实战场景有如下特殊需求：1，在集群和分布式环境实现session共享；2，前端只使用HTML/CSS/JS。因此无法直接使用Shiro提供的SessionManager，以及Shiro针对web应用提供的Filter拦截方式。当然，除非是一定要通过共享缓存的方式共享session，否则还是使用Shiro默认的session管理，毕竟增加独立缓存就意味着维护成本的提高和可用性的下降。

2， Shiro架构

首先一睹官方给出的Shiro架构图，如图1所示。刨除最右侧的加密工具类，主要围绕SercurityManager来阐述。SercurityManager是Shiro安全框架里的顶层安全管理中心，所有安全控制相关逻辑都是在SercurityManager里面通过delegate的方式，调用到真正的动作执行者。从图1可以清楚看到主要管理的组件：authentication管理，authorization管理，session管理，session缓存管理，cache管理，realms管理。(本文不想重复已有的文字，想要更好的了解Shiro，详见官方推荐的Shiro full intro: https://www.infoq.com/articles/apache-shiro)

1）Shiro提供的CacheManager比较单薄，提供实现是MemoryConstrainedCacheManager，主要是依赖SoftHashMap来做基于内存条件的缓存，也即是当内存吃紧，没有新的内存空间来存放new出来的对象时，会去释放SoftHashMap中存放的对象，在本文中的应用场景是面向集群和分布式应用环境，使用了Redi缓存登录用户的相关信息，所以需要自定义cache处理。

2）Shiro对于session的缓存管理，定义了SessionDAO抽象，并提供了两个存放于本地JVM内存的EnterpriseCacheSessionDAO和MemorySessionDAO，两者主要区别是EnterpriseCacheSessionDAO的session存放在SoftHashMap中，原则上可以自己实现SessionDAO 接口，实际存储使用Redis来做到完整的session共享，但是缺陷是：a，不安全，因为把所有数据都共享出去了；b，当每次需要获取session数据时，都需要通过网络来把整个session反序列化回来，而考虑很多情况下，只是间断的需要几个key的数据，这样在session数据量大一些的时候，就会产生大量消耗。因此在共享session时，不去替换默认SessionDao的实现，而是通过@overwrite AbstractNativeSessionManager getter/setter attribute方法，实现有选择的共享session的基本初始化和指定attribute key的数据。

3）Shiro的authentication和authorization过程主要是依据用户定义的 AuthorizingRealm中提供的AuthenticationInfo和AuthorizationInfo。特别地，authentication 还提供类似验证链的authentication策略，允许用户提供多个Realm。第3部分会具体的示例Shiro集成Spring的使用范例，并详细解释AuthorizingRealm 。

图 1 Shiro官方架构图

3， Shiro使用范例

官方提供了集成Spring Web应用的使用例子，但是就如前文提到的，这里前端只能使用JS的Http和后端通信，因此无法直接使用ShiroFilterFactoryBean来做Request的Filter。本文鉴于简单和初期的原则，可以选择定义一个RequestInterceptor类继承HandlerInterceptorAdapter并overwrite preHandle 方法。Interceptor的applicationContext和源码定义如下：

applicationContext.xml

<mvc:interceptors>
    <mvc:interceptor>
        <mvc:mapping path="/**"/>
        <!--拦截的url -->
        <mvc:mapping path="/admin/**"/>
        <!-- 不拦截的url start -->
        <mvc:exclude-mapping path="/admin/login"/>
        <mvc:exclude-mapping path="/admin/code"/>
        <mvc:exclude-mapping path="/admin/logout"/>
        <mvc:exclude-mapping path="/admin/msgErrorInfo"/>
        <!--不拦截的url end -->
        <bean class="authorizing.RequestInterceptor">
            <property name="unauthenticatedUrl" value="/admin/msgErrorInfo" />
        </bean>
    </mvc:interceptor>
</mvc:interceptors>

RequestInterceptor.java

public class RequestInterceptor extends HandlerInterceptorAdapter {
 
    private String unauthenticatedUrl;
 
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response,
            Object handler) throws Exception {
        if(PermissionUtils.isLogin(request)){
            return true;
        }
        //token已失效，返回提示信息
        request.getRequestDispatcher(unauthenticatedUrl).forward(request, response);
        return false;
    }
 
    public void setUnauthenticatedUrl(String unauthenticatedUrl) {
        this.unauthenticatedUrl = unauthenticatedUrl;
    }
}

 

RequestInterceptor.java定义非常简单，主要是在preHandler方法中验证了一下请求是否是登录用户发出的，否则响应给前端一个重定向。然后看一下PermissionUtils.isLogin(request)是怎样做登录验证的。

PermissionUtils.java

public class PermissionUtils {
private static ThreadLocal<String> sessionToken = new ThreadLocal<String>();
 
public static boolean isLogin(HttpServletRequest request){
    String token = sessionToken(request);
    if(StringUtils.isEmpty(token))
        return false;
    /**
    * 使用token检查是否存在登录session
    */
    //Session session = SecurityUtils.getSecurityManager().getSession(new WebSessionKey(token, request, response));
    Session session = SecurityUtils.getSecurityManager().getSession(new DefaultSessionKey(token));
    if(session != null){
        session.touch();
        sessionToken.set(token);
        return true;
    }
    return false;
}
 
private static String sessionToken(HttpServletRequest request){
    return request.getHeader("token");
}
}

 

从PermissionUtils.java可以判断，保存前后端session的方式是通过token的形式。也即是每次request中的header部分都携带了登录成功后获取的token，以token为标识获取登录用户的session。特别地，对于Shiro而言，session并非特定于Web应用，Shiro有自己的session定义，可以独立于应用环境而存在。因此为了追求简单(既已弃用了Shiro针对web.xml应用提供的Filter)，直接使用Shiro创建的默认session(实际是SimpleSession)。此外，需要说明的一个细节是通过Shiro的SecurityManager 返回的session实际都是一个代理(DelegatingSession的实例)。因此，通过 SecurityManager获取的session，然后对session执行的动作实际都是通过 SecurityManager的SessionManager来完成的(因为共享session，每一次session的touch动作都应该反映到共享session中，后文，可以看到overwrite SessionManager#touch(SessionKey key)和start session)。Shiro提供的默认SessionManager都继承了AbstractValidatingSessionManager$sessionValidationSchedulerEnabled属性，该属性控制了是否执行一个后台守护线程(Thread#setDaemon(true))在给定的一个固定时间间隔(默认1个小时)内周期性的检查session是否过期，并且在每一次获取到session之后都会去检查session是否过期（对于共享session的集群，共享缓存基本都已具备超时管理功能，所以可以重新实现后文提到的 AbstractNativeSessionManager#getSession(SessionKey)）。PermissionUtils.java中定义了一个ThreadLocal类型的sessionToken变量，该变量是用于暂存当前request authentication成功之后的session标识，避免每次获取token都要从request中拿(后文中使用到的每一个url的authorization都需要首先执行一次checkPermission方法，通过token来验证是否有访问权限)。

接下来描述Authentication和Authorization，具体地说明如何基于Shiro实现login和check permission。下面先给出applicationContext配置。

applicationContext.xml

<bean id="securityManager" class="org.apache.shiro.mgt.DefaultSecurityManager"><property name="realm" ref="authorizingRealm" /><property name="sessionManager"><bean class="service.authorizing.shiro.RedisSessionManager" ><property name="globalSessionTimeout" value="${session.timeout}" /></bean></property>
</bean>
<bean id="realmCache" class="service.authorizing.shiro.cache.RedisShiroCache" />
<bean id="authorizingRealm" class="service.authorizing.shiro.DefaultAuthorizingRealm"><property name="authorizationCachingEnabled" value="true"/><property name="authorizationCache" ref="realmCache" />
</bean>
<bean id="lifecycleBeanPostProcessor" class="org.apache.shiro.spring.LifecycleBeanPostProcessor"/><bean class="org.springframework.beans.factory.config.MethodInvokingFactoryBean"><property name="staticMethod" value="org.apache.shiro.SecurityUtils.setSecurityManager"/><property name="arguments" ref="securityManager"/>
</bean>

 

applicationContext.xml中配置的DefaultSecurityManager，RedisSessionManager，DefaultAuthorizingRealm和RedisShiroCache，分别代表Shiro的默认SecurityManager，自定义基于Redis的session manager，继承自Shiro的AuthorizingRealm的默认实现，以及自定义基于Redis的用户权限相关的Cache<Object, AuthorizationInfo>实现。注意到，本文的应用场景虽然是web.xml应用，但是并没有使用Shiro提供的 DefaultWebSecurityManager和DefaultWebSessionManager这两个针对web应用的拓展。使用针对web应用的拓展实现自然也没问题，但是个人认为对于纯粹的前后端分离权限认证的应用场景中，前端和后端应当是完全独立的，它们之间唯一的耦合是通过Http request交互的token。因此就目前简单和初期的原则，不需要DefaultWebSecurityManager和DefaultWebSessionManager。

 

图2 Shiro组件交互过程

在讲解程序具体怎样执行login和check permission之前，先看图2所示的Shiro各组件的交互过程，可以看到Real是安全验证的依据。所以有必要先理解Shiro提供的abstract类AuthorizingRealm，该类定义了两个抽象方法doGetAuthorizationInfo和doGetAuthenticationInfo，分别用于check permission和login验证。具体如下DefaultAuthorizingRealm.java的定义：

DefaultAuthorizingRealm.java

public class DefaultAuthorizingRealm extends AuthorizingRealm {
 
@Autowired
private AuthorizingService authorizingService;
 
    /**
    * 获取登录用户角色和功能权限信息，
    * 使用{@link org.apache.shiro.cache.CacheManager}和{@link org.apache.shiro.cache.Cache}获取数据.
    * @param principals 登录用户ID
    * @return
    */
    protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) {
        Object username =principals.getPrimaryPrincipal();
        Cache<Object, AuthorizationInfo> infoCache = getAuthorizationCache();
        AuthorizationInfo info = infoCache.get(username);
        return info;
    }
 
    /**
    * 根据登录用户token,获取用户信息。
    * 对于session timeout时间较短的场景可以考虑使用AuthenticationCache
    * 若验证失败，会抛出异常 {@link AuthenticationException}
    * @param token
    * @return
    * @throws AuthenticationException
    */
    protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken token) throws AuthenticationException {
        Object username = token.getPrincipal();
        //对于session timeout时间较短的场景,可缓存用户authentication信息
        //Cache<Object, AuthenticationInfo> infoCache = getAuthenticationCache();
        //return infoCache.get(username);
        return authorizingService.authentication(username);
    }
}

DefaultAuthorizingRealm.java的实现，可以看到用户只需要通过 doGetAuthorizationInfo和doGetAuthenticationInfo两个方法给Shiro的SecurityManager提供Authorization和Authentication信息，SecurityManager就会在执行check permission和login操作时自动调用这两个函数来验证操作。下面我们再看执行login和check permission操作时具体做了什么。

• Authentication

下面在LoginController.java定义了login请求操作。

LoginController.java

@Controller
@RequestMapping("/admin")
public class LoginController {
  Logger logger = LoggerFactory.getLogger(LoginController.class);
 
  @Autowired
  private AuthorizingService authorizingService;
 
  @RequestMapping("/login")
  @ResponseBody
  public LoginToken login(User user, HttpServletRequest request){
      Subject subject = new Subject.Builder().buildSubject();
      UsernamePasswordToken token = new UsernamePasswordToken(userName, UtilTool.md5Tool(password));
      token.setRememberMe(true);
      LoginToken loginToken = new LoginToken();
      try{
           subject.login(token);
           Session session = subject.getSession();
           user.setToken((String) session.getId());
           loginToken.setResultCode(WebConstants.RESULT_SUCCESS_CODE);
      } catch (AuthenticationException e) {
           loginToken.setResultCode(WebConstants.RESULT_FAIL_CODE);
           loginToken.setMessage("用户名或密码错误!");
      }
      return loginToken;
  }
}

 

上述login代码只做了非常简单用户名和密码的验证示例。可以看出login如果没有抛出AuthenticationExeception，则说明登录成功。

• Authorization

访问权限控制需要在所有的访问controller的函数中配置，因此使用工具类最合适(在工具类的基础上做成spring annotation也可以很方便)，既是PermissionUtils.java。

PermissionUtils.java

private static AuthorizingService authorizingService;
 
private static ThreadLocal<String> sessionToken = new ThreadLocal<String>();
 
/**
*
* @param url eg: /admin/review
* @param argv eg: WAIT_BIZ_MANAGER
*/
public static void checkPermission(String url, @Nullable String argv){
    Subject subject = getSubject();
    String permissionCode = authorizingService.uriMappingCode(url, argv);
    if(StringUtils.isEmpty(permissionCode))
        throw new IllegalArgumentException("不明操作");
    subject.checkPermission(permissionCode);
}
 
public static Subject getSubject(){
    String token = sessionToken.get();
    if(StringUtils.isEmpty(token))
        throw new AuthenticationException("未经认证");
    return new Subject.Builder()
            .sessionId(sessionToken.get())
            .buildSubject();
}
 
public static void setAuthorizingService(AuthorizingService authorizingService) {
    PermissionUtils.authorizingService = authorizingService;
}

 

从上述代码来看，每一个request的checkPermission操作，都需要依赖前文RequestInterceptor.java中提到的，从request中获取的token，并依赖该token找到缓存的session 。在权限控制的设计时，不同的业务场景可能需要不同粒度的权限控制，在这里做到了request参数级别的权限控制（在workflow应用中，一个流程涉及多个角色的参与，但很可能只抽象一个接口，如下文的/review操作）。在实现的时，灵活的方式是可以维护一张uri和permission_code之间的关系表(简单可以propertites文件)。对于前端用户而言，为了提升用户体验，拥有不同权限的用户得到的界面会有相应的隐藏和显示，因此会给前端的登录用户提供一张可访问权限表。在这里一个细节的设计，个人觉得有意义的是，在返回给前端的权限表的Key值不应当是permission_code,而是uri。因为permission_code对于前端而言毫无意义，而uri正是前后端沟通的桥梁。因此，check Permission操作可以如下：

ReviewApiController.java

@RestController
@RequestMapping(value = "/review")
public class ReviewApiController {
 
    @Autowired
    private ReviewService reviewService;
 
    @ResponseBody
    @RequestMapping(value = "/review", method = POST)
    public WebResult review(@RequestBody NewReviewVo reviewVo){
        //检查访问权限
        PermissionUtils.checkPermission("/review/review", reviewVo.getFeatureCode());
        WebResult result = WebResult.successResult();
        try {
            Review review = ReviewAssembler.voToReview(reviewVo);
            reviewService.review(review);
        }catch (Exception e){
            result = WebResult.failureResult(e.getMessage());
        }
        return result;
    }
｝

 

• SessionManager

由于要实现有选择的共享session数据，因此session管理成了最棘手的问题，因为你不是粗暴地将整个session序列化到缓存并仍以local session的方式管理，其间需要额外得小心处理共享的session数据和本地的session数据。下面给出RedisSessionManager.java的实现：

RedisSessionManager.java

/**
* 根据 attributeKey，有选择的缓存session信息;
* 设置 {@parm enabledSharedSessionData}来有选择的启用共享session功能。
*/
public class RedisSessionManager extends DefaultSessionManager {
 
    private static Logger logger = LoggerFactory.getLogger(RedisSessionManager.class);
 
    private boolean enabledSharedSessionData;
 
    private Set<String> sharedSessionDataKeys;
 
    public RedisSessionManager() {
        enabledSharedSessionData = true;
        sharedSessionDataKeys = new HashSet<String>();
    }
 
    @Override
    public Collection<Object> getAttributeKeys(SessionKey key) {
 
        Collection<Object> keys = super.getAttributeKeys(key);
        if(enabledSharedSessionData) {
            /**
            * 从redis获取 {@param key} 对应session的所有attribute key
            */
            Set sharedKeys = RedisClient.extractAttributeKey((String) key.getSessionId());
            keys.addAll(sharedKeys);
        }
        return keys;
    }
 
    @Override
    public Object getAttribute(SessionKey sessionKey, Object attributeKey)
            throws InvalidSessionException {
        if(checkSharedStrategy(attributeKey)){
            Object object = RedisClient.getValue((String) attributeKey, (String) sessionKey.getSessionId());
            return object;
        }
        return super.getAttribute(sessionKey, attributeKey);
    }
 
    @Override
    public void setAttribute(SessionKey sessionKey, Object attributeKey, Object value)
            throws InvalidSessionException {
        if(checkSharedStrategy(attributeKey)) {
            if(value instanceof Serializable)
                RedisClient.setValue((String) attributeKey, (String) sessionKey.getSessionId(),
                        (Serializable) value, getGlobalSessionTimeout(), TimeUnit.MILLISECONDS);
            else
                throw new IllegalArgumentException("不可共享非序列化value");
            return;
        }
        super.setAttribute(sessionKey, attributeKey, value);
    }
 
    private boolean checkSharedStrategy(Object attributeKey){
        return enabledSharedSessionData && sharedSessionDataKeys.contains(attributeKey);
    }
 
    /**
    * 如果是集群， session只在一台机器上创建，因此必须共享 SessionId。
    * 当request发过来，获取request中携带的 SessionId，使用 SessionId 在本地获取session，
    * 如果为null，则用 SessionId 去redis检查是否存在，如果存在则在本地构建session返回
    * (实际就是{@link SimpleSession}的代理{@link DelegatingSession},{@see RedisSessionManager#restoreSession})，
    * 否则返回空， 请求重新登录。
    * {@link org.apache.shiro.session.mgt.AbstractNativeSessionManager#getSession(SessionKey)}
    * @param key
    * @return
    * @throws SessionException
    */
    @Override
    public Session getSession(SessionKey key) throws SessionException {
        Session session = null;
        try {
            session = getLocalSession(key);
        } catch (UnknownSessionException use){
            //ignored
            session = null;
        }
        if(!enabledSharedSessionData || session != null)
            return session;
        /**
        * 检查redis，判断session是否已创建，
        * 若已创建，则使用SessionFactory在本地构建SimpleSession
        */
        Serializable sid = RedisClient.getValue((String) key.getSessionId());
        if(sid != null){
            session = restoreSession(key);
        }
 
        return session;
    }
 
    /**
    * 每一次通过
    * {@link org.apache.shiro.session.mgt.AbstractValidatingSessionManager#doGetSession(SessionKey)}}
    * 获取session
    * 或是通过{@link org.apache.shiro.session.mgt.ExecutorServiceSessionValidationScheduler}
    * 定时检查，都会去调用
    * {@link org.apache.shiro.session.mgt.AbstractValidatingSessionManager#doValidate(Session)}
    * 验证session是否过期。
    * 共享session过期的标准是该redis中sessionId过期, 由于redis已经帮助完成了session过期检查，
    * 所以这里只需要定期清理本地内存中的过期session。
    * 然而{@link org.apache.shiro.session.mgt.AbstractValidatingSessionManager#doGetSession(SessionKey)}}
    * 是一个final方法,无法被overwrite，所以只能copy Shiro原来的代码实现来定义getLocalSession(SessionKey key)
    * @param key
    * @return
    */
    private Session getLocalSession(SessionKey key){
        Session session = lookupSession(key);
        return session != null ? createExposedSession(session, key) : null;
    }
    private Session lookupSession(SessionKey key) throws SessionException {
        if (key == null) {
            throw new NullPointerException("SessionKey argument cannot be null.");
        }
        //enableSessionValidationIfNecessary
        SessionValidationScheduler scheduler = getSessionValidationScheduler();
        if (enabledSharedSessionData ||
                (isSessionValidationSchedulerEnabled() && (scheduler == null || !scheduler.isEnabled()))
                ) {
            enableSessionValidation();
        }
        Session s = retrieveSession(key);
        if (!enabledSharedSessionData && s != null) {
            validate(s, key);
        }
        return s;
    }
 
    /**
    * 根据{@link SessionKey}以及继承自{@link DefaultSessionManager}的默认创建方法，
    * 重新在本地构建session。
    * @param key
    * @return
    */
    private Session restoreSession(SessionKey key){
        SimpleSession restoreSession = (SimpleSession) getSessionFactory().createSession(null);
        restoreSession.setId(key.getSessionId());
        restoreSession.setTimeout(getGlobalSessionTimeout());
        create(restoreSession);
        return createExposedSession(restoreSession, key);
    }
 
    /**
    * 开启一个新的session， 并且在新的session开启之后做一系列的session共享工作。
    * {@link org.apache.shiro.session.mgt.AbstractNativeSessionManager#start(SessionContext)}
    * @param context
    * @return
    */
    @Override
    public Session start(SessionContext context) {
        Session session = super.start(context);
        if(enabledSharedSessionData){
             shareSessionData(session);
        }
        return session;
    }
/**
* 完成session基本数据共享
*/
    private void shareSessionData(Session session){
        refreshTTL(session.getId());
    }
     /**
     * 刷新session存活时间
     */
    private void refreshTTL(Serializable sessionId){
        RedisClient.setValue((String) sessionId, new Date(),
                getGlobalSessionTimeout(), TimeUnit.MILLISECONDS);
    }
 
    /**
    * {@link org.apache.shiro.session.mgt.AbstractNativeSessionManager#touch(SessionKey)}
    * @param key
    * @throws InvalidSessionException
    */
    @Override
    public void touch(SessionKey key) throws InvalidSessionException {
  if(enabledSharedSessionData){
       //刷新session存活时间
       refreshTTL(key.getSessionId());
        }
        super.touch(key);
    }
 
/**
* 当主动调用{@link Subject#logout()}时，相应会调用该方法来停止session。
* 因此，如果共享了session，也需要即时清除共享session。
* {@link org.apache.shiro.session.mgt.AbstractNativeSessionManager#stop(SessionKey)}
* @param key
* @throws InvalidSessionException
*/
@Override
public void stop(SessionKey key) throws InvalidSessionException {
    super.stop(key);
    if(enabledSharedSessionData)
        RedisClient.delete((String) key.getSessionId());
}
 
    /**
    * {@link org.apache.shiro.session.mgt.AbstractNativeSessionManager#getLastAccessTime(SessionKey)}
    * @param key
    * @return
    */
    @Override
    public Date getLastAccessTime(SessionKey key) {
        Serializable lastAccessTime = enabledSharedSessionData ?
             RedisUtils.getValue((String) key.getSessionId()) :
             super.getLastAccessTime(key);
        if(lastAccessTime == null)
            throw new SessionTimeoutException();
        return (Date) lastAccessTime;
    }
 
    /**
    * 通知session manager那些attribute key对应的数据需要共享。
    * @param key
    */
    public void registerSharedAttributeKey(String key){
        if(!enabledSharedSessionData)
            throw new IllegalArgumentException("不允许共享session数据");
        if(sharedSessionDataKeys == null)
            sharedSessionDataKeys = new HashSet<String>();
        sharedSessionDataKeys.add(key);
    }
}

由于Redis本身就是单线程模型，所以作为客户端基本不需要考虑线程安全问题。下面就各个问题来详细说明 RedisSessionManager。既然需求是想要实现在集群和分布式环境下，有选择的共享session数据，这意味着有一下问题需要处理：1，怎样做到有选择的共享session数据？2，本地session过期了怎样清理，以及怎样避免Shiro每次获取本地session都会进行过期验证和Redis的过期验证之间的重复？ 3，怎样管理session存活时间？4，session只在一台机器上创建，既然不是共享了整个session，那么其它机器如何重建session？

对于第1个问题，RedisSessionManager.java定义了enabledSharedSessionData和sharedSessionDataKeys两个变量来控制session数据共享，如果要求共享session数据，则需要通过registerSharedAttributeKey(String key)来告知session manager那些attribute key需要被共享，并定义checkSharedStrategy(Object attributeKey) 方法来检查attribute key是否共享。余下就是overwrite getter/setter attribute方法就可以了。这里再提一下，对于设置enabledSharedSessionData=true，除非是一定要通过共享缓存的方式共享session，否则还是使用Shiro默认的session管理，毕竟增加独立缓存就意味着维护成本的提高和可用性的下降。

对于第2个问题，Shiro提供的session manager已经完成了local session的管理动作，因此我们只需要把local session的管理操作直接交给Shiro提供的默认session manager就可以了，而对于共享的session数据，Redis已经提供了数据过期管理功能(或者其它缓存工具基本都提供了)。因为Shiro提供的session manager清理session的原则是session已经过期或已经stop，那么session manager是怎样自动让session进入过期状态的呢？从AbstractNativeSessionManager#getSession(SessionKey)方法就可以追溯到，每一次通过该方法获取session不为空，都会调用SimpleSesion#validate()方法来验证session是否过期。此外，Shiro也提供了ExecutorServiceSessionValidationScheduler类来开启一个后台的固定周期执行的守护线程来执行session验证。既然Redis已经可以做到session有效性管理，那就没必要在每次获取session的时候都去主动的验证一次session。然而，getSession操作实际，Shiro提供的实现实际是调用了一个final类型AbstractValidatingSessionManager#doGetSession(SessionKey)方法，这意味着无法通过overwrite的方式来避免主动调用SimpleSesion#validate()。因此，在自定义sesssion manager中定义了getLocalSession(SessionKey key)方法，该方法本质实际是参照Shiro提供的实现，并在基础之上加上场景约束。

对于第3个问题，在解释第2问题时已提到，Redis已自带超时管理功能，因此session存活时间只需要由Redis管理即可，而Shiro只需要开启一个固定周期的后台任务来清理本地无效session即可。

对于第4个问题，在前后端完全分离的应用场景下，用户authentication通过之后由Shiro自动创建的session，里面包含的大部分数据都是可选共享的，而Shiro提供的最核心的Session实现，实际就是允许空参构造函数的SimpleSession。所以，实际我们只需共享出全局唯一的sessionId(shareSessionData(Session session) 方法实现)，即可使用session manager提供的getSessionFactory()方法获取默认session factory，然后通过该factory即可创建SimpleSession并设置相应的共享数据，即restoreSession(SessionKey key)方法定义的过程。在Shiro提供的默认session manager中可以看到，所有的session创建都是通过AbstractNativeSessionManager#start(SessionContext)完成的，所以只需要overwrite这个方法并共享新创建session的必要数据即可。最后，结合问题2中提到的getLocalSession(SessionKey key)方法，获取session的方法getSession(SessionKey key)的实现分为两步：第一步是通过 getLocalSession(SessionKey key) 获取；如果第一步返回null且Redis中session未过期，则第二步通过restoreSession(SessionKey key)在本地重建session 。特别地，从refreshTTL(Serializable sessionId)方法的定义，可以看到共享sessionId的同时，对应的存放了该session的LastAccessTime。

4，Authentication和Authorization执行时序

在第3部分，已经给出了一个基本的基于Shiro的前后端分离的共享session实战范例，因此在这一部分将基于第3部分，通过时序图来表述Authentication和Authorization的执行流程。

• 简要的合并时序

 

图3 合并时序

• Authentication时序

图4 Authentication时序

• Authorization时序

图4 Authorization时序

5，总结

在使用Shiro框架进行Authentication和Authorization实践时，虽然根据不同的业务场景需要做不同的修改或调整，但是基本也是最佳的实践方式是时刻围绕Shiro的设计原则和已有可借鉴的实现方案来操作，尽可能少或者不修改，从而避免一些预想不到的Bug。最后，重提前言部分说到的，除非是一定要通过共享缓存的方式共享session，否则还是使用Shiro默认的session管理。