package com.chhliu.springboot.shiro.cache; import java.io.Serializable; import java.util.Collection; import java.util.concurrent.TimeUnit; import org.apache.shiro.session.Session; import org.apache.shiro.session.UnknownSessionException; import org.apache.shiro.session.mgt.eis.AbstractSessionDAO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service;  @Service @SuppressWarnings({ "rawtypes", "unchecked" }) public class RedisSessionDao extends AbstractSessionDAO {    // Session超時(shí)時(shí)間，單位為毫秒   private long expireTime = 120000;    @Autowired   private RedisTemplate redisTemplate;// Redis操作類，對這個(gè)使用不熟悉的，可以參考前面的博客    public RedisSessionDao() {     super();   }    public RedisSessionDao(long expireTime, RedisTemplate redisTemplate) {     super();     this.expireTime = expireTime;     this.redisTemplate = redisTemplate;   }    @Override // 更新session   public void update(Session session) throws UnknownSessionException {     System.out.println("===============update================");     if (session == null || session.getId() == null) {       return;     }     session.setTimeout(expireTime);     redisTemplate.opsForValue().set(session.getId(), session, expireTime, TimeUnit.MILLISECONDS);   }    @Override // 刪除session   public void delete(Session session) {     System.out.println("===============delete================");     if (null == session) {       return;     }     redisTemplate.opsForValue().getOperations().delete(session.getId());   }    @Override// 獲取活躍的session，可以用來統(tǒng)計(jì)在線人數(shù)，如果要實(shí)現(xiàn)這個(gè)功能，可以在將session加入redis時(shí)指定一個(gè)session前綴，統(tǒng)計(jì)的時(shí)候則使用keys("session-prefix*")的方式來模糊查找redis中所有的session集合   public Collection<Session> getActiveSessions() {     System.out.println("==============getActiveSessions=================");     return redisTemplate.keys("*");   }    @Override// 加入session   protected Serializable doCreate(Session session) {     System.out.println("===============doCreate================");     Serializable sessionId = this.generateSessionId(session);     this.assignSessionId(session, sessionId);      redisTemplate.opsForValue().set(session.getId(), session, expireTime, TimeUnit.MILLISECONDS);     return sessionId;   }    @Override// 讀取session   protected Session doReadSession(Serializable sessionId) {     System.out.println("==============doReadSession=================");     if (sessionId == null) {       return null;     }     return (Session) redisTemplate.opsForValue().get(sessionId);   }    public long getExpireTime() {     return expireTime;   }    public void setExpireTime(long expireTime) {     this.expireTime = expireTime;   }    public RedisTemplate getRedisTemplate() {     return redisTemplate;   }    public void setRedisTemplate(RedisTemplate redisTemplate) {     this.redisTemplate = redisTemplate;   } } 

 @Bean   public DefaultWebSessionManager configWebSessionManager(){     DefaultWebSessionManager manager = new DefaultWebSessionManager();     manager.setCacheManager(cacheManager);// 加入緩存管理器     manager.setSessionDAO(sessionDao);// 設(shè)置SessionDao     manager.setDeleteInvalidSessions(true);// 刪除過期的session     manager.setGlobalSessionTimeout(sessionDao.getExpireTime());// 設(shè)置全局session超時(shí)時(shí)間     manager.setSessionValidationSchedulerEnabled(true);// 是否定時(shí)檢查session          return manager;   } 

@Bean   public SecurityManager securityManager(DefaultWebSessionManager webSessionManager) {     DefaultWebSecurityManager securityManager = new DefaultWebSecurityManager();     // 設(shè)置realm.     securityManager.setRealm(myShiroRealm());      // 注入緩存管理器;     securityManager.setCacheManager(cacheManager);// 這個(gè)如果執(zhí)行多次，也是同樣的一個(gè)對象;          // session管理器     securityManager.setSessionManager(webSessionManager);          //注入記住我管理器;     securityManager.setRememberMeManager(rememberMeManager());     return securityManager;   }