shiro 在叢集環境下用redis(叢集版)做session共享
阿新 • • 發佈：2019-01-01
如今叢集環境已是伺服器主流,在叢集環境中，session共享一般通過應用伺服器的session複製或者儲存在公用的快取伺服器上，本文主要介紹通過Shiro管理session，並將session快取到redis叢集版中，這樣可以在叢集中使用。
Shiro除了在管理session上使用redis，也在可以快取使用者許可權，即cacheManager可以通過redis來擴充套件。
下面從 sessionManager這部分講解Shiro與Redis的整合,
先看下配置問件:
<?xml version="1.0" encoding="UTF-8"?> /cityparlor/cityparlor/**=anon /cityparlor/**=authc /common/**=anon
shiro框架中有一個對session配置管理物件:sessionManager物件,物件中可注入物件引數:sessionDAO,原始碼如下:
此SessionDao中封裝內容如下:
不難發現,裡面封裝的就是對session的增刪改查,因此我們只需對sessionDao進行自己的繼承,實現類即可;
自己封裝程式碼如下:
這裡我們只是將session的增刪改查換成了用redis的增刪改查; redis連結工具類程式碼如下:package com.cityparlor.web.admin.realm; 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; import com.cityparlor.common.utils.JedisUtils; public class RedisSessionDAO extends AbstractSessionDAO{ private static Logger logger = LoggerFactory.getLogger(RedisSessionDAO.class); /*private JedisUtils redisManager;*/ private String keyPrefix; private int expire = 0; public RedisSessionDAO() { this.keyPrefix = "shiro_redis_session:"; } @Override public void update(Session session) throws UnknownSessionException { // TODO Auto-generated method stub this.saveSession(session); } /** * 獲取序列化位元組id * TODO * @param sessionId * @return
* ============History===========
* 2017年7月17日 LHL 新建 */ /*private byte[] getByteKey(Serializable sessionId) { String preKey = this.keyPrefix + sessionId; return preKey.getBytes(); }*/ private String getKey(Serializable sessionId) { String preKey = this.keyPrefix + sessionId; return preKey; } private void saveSession(Session session) throws UnknownSessionException { if ((session == null) || (session.getId() == null)) { logger.error("session or session id is null"); return; } String key = getKey(session.getId()); /*byte[] value = SerializeUtils.serialize(session);*/ session.setTimeout(expire * 1000); JedisUtils.setObject(key, session, this.expire);//this.redisManager.set(key, value, this.redisManager.getExpire()); } @Override public void delete(Session session) { if ((session == null) || (session.getId() == null)) { logger.error("session or session id is null"); return; } JedisUtils.delObject(getKey(session.getId()));//this.redisManager.del(getByteKey(session.getId())); } @Override public Collection getActiveSessions() { // TODO Auto-generated method stub Set sessions = new HashSet(); Set keys = JedisUtils.keys(this.keyPrefix + "*"); if ((keys != null) && (keys.size() > 0)) { for (String key : keys) { Session s = (Session) JedisUtils.getObject(key);// (Session) SerializeUtils.deserialize(this.redisManager.get(key)); sessions.add(s); } } return sessions; } @Override protected Serializable doCreate(Session session) { // TODO Auto-generated method stub Serializable sessionId = generateSessionId(session); assignSessionId(session, sessionId); saveSession(session); return sessionId; } @Override protected Session doReadSession(Serializable sessionId) { // TODO Auto-generated method stub if (sessionId == null) { logger.error("session id is null"); return null; } Session s =(Session) JedisUtils.getObject(getKey(sessionId)) ;// SerializeUtils.deserialize(this.redisManager.get(getByteKey(sessionId))); return s; } }
對redis連結池的封裝也可按自己的來,只要將自己實現的RedisSessionDAO中的方法重新定義即可;/** * */ package com.cityparlor.common.utils; import java.util.List; import java.util.Map; import java.util.Set; import java.util.TreeSet; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.cityparlor.common.config.Global; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisCluster; import redis.clients.jedis.JedisPool; /** * Jedis Cache 工具類 * * @author Administrator * @version 2015-09-29 */ public class JedisUtils { private static Logger logger = LoggerFactory.getLogger(JedisUtils.class); private static JedisCluster jedisCluster = SpringContextHolder.getBean(JedisCluster.class); //private static JedisPool jedisPool = SpringContextHolder.getBean(JedisPool.class); public static final String KEY_PREFIX = Global.getConfig("redis.keyPrefix"); /** * 利用redis 生成自增長的長整形主鍵 * */ /** * 獲取所有keys * TODO * @param pattern * @return
* ============History===========
* 2017年7月17日 LHL 新建 */ public static TreeSet keys(String pattern){ //logger.debug("Start getting keys..."); TreeSet keys = new TreeSet<>(); Map clusterNodes = jedisCluster.getClusterNodes(); for(String k : clusterNodes.keySet()){ // logger.debug("Getting keys from: {}", k); JedisPool jp = clusterNodes.get(k); Jedis connection = jp.getResource(); try { keys.addAll(connection.keys(pattern)); } catch(Exception e){ logger.error("Getting keys error: {}", e); } finally{ logger.debug("Connection closed."); connection.close();//用完一定要close這個連結！！！ } } // logger.debug("Keys gotten!"); return keys; } /** * 獲取快取 * @param key 鍵 * @return 值 */ public static String get(String key) { key = KEY_PREFIX + key; String value = null; //Jedis jedis = null; try { //jedis = getResource(); if (jedisCluster.exists(key)) { value = jedisCluster.get(key); value = StringUtils.isNotBlank(value) && !"nil".equalsIgnoreCase(value) ? value : null; logger.debug("get {} = {}", key, value); } } catch (Exception e) { logger.warn("get {} = {}", key, value, e); } finally { //returnResource(jedis); } return value; } /** * 獲取快取 * @param key 鍵 * @return 值 */ public static Object getObject(String key) { key = KEY_PREFIX + key; Object value = null; //Jedis jedis = null; try { //jedis = getResource(); if (jedisCluster.exists(getBytesKey(key))) { value = toObject(jedisCluster.get(getBytesKey(key))); logger.debug("getObject {} = {}", key, value); } } catch (Exception e) { logger.warn("getObject {} = {}", key, value, e); } finally { //returnResource(jedis); } return value; } /** * 設定快取，利用setex * @param key * @param seconds * @param value * @return */ public static String setex(String key, int seconds, String value){ key = KEY_PREFIX + key; String result = null; //Jedis jedis = null; try { //jedis = getResource(); result = jedisCluster.setex(key, seconds, value); logger.debug("setex {} = {}", key, value); } catch (Exception e) { logger.warn("setex {} = {}", key, value, e); } finally { //returnResource(jedis); } return result; } /** * 設定快取 * @param key 鍵 * @param value 值 * @param cacheSeconds 超時時間，0為不超時 * @return */ public static String set(String key, String value, int cacheSeconds) { key = KEY_PREFIX + key; String result = null; //Jedis jedis = null; try { //jedis = getResource(); result = jedisCluster.set(key, value); if (cacheSeconds != 0) { jedisCluster.expire(key, cacheSeconds); } logger.debug("set {} = {}", key, value); } catch (Exception e) { logger.warn("set {} = {}", key, value, e); } finally { //returnResource(jedis); } return result; } /** * 設定快取 * @param key 鍵 * @param value 值 * @param cacheSeconds 超時時間，0為不超時 * @return */ public static String setObject(String key, Object value, int cacheSeconds) { key = KEY_PREFIX + key; String result = null; //Jedis jedis = null; try { //jedis = getResource(); result = jedisCluster.set(getBytesKey(key), toBytes(value)); if (cacheSeconds != 0) { jedisCluster.expire(key, cacheSeconds); } logger.debug("setObject {} = {}", key, value); } catch (Exception e) { logger.warn("setObject {} = {}", key, value, e); } finally { //returnResource(jedis); } return result; } /** * 獲取List快取 * @param key 鍵 * @return 值 */ public static List getList(String key) { key = KEY_PREFIX + key; List value = null; //Jedis jedis = null; try { //jedis = getResource(); if (jedisCluster.exists(key)) { value = jedisCluster.lrange(key, 0, -1); logger.debug("getList {} = {}", key, value); } } catch (Exception e) { logger.warn("getList {} = {}", key, value, e); } finally { //returnResource(jedis); } return value; } /** * 獲取List快取 * @param key 鍵 * @return 值 */ public static List
文章不夠詳細,如有深究可以參考:http://blog.csdn.net/lishehe/article/details/45224181;