分布式Shiro，SpringBoot项目Shiro整合Redis

分布式Shiro，SpringBoot项目Shiro整合Redis

====================紧张 Begin====================
你的SpringBoot项目已经使用了Shiro，而且可以正常使用。本篇文章的紧张目的是将Shiro生存在服务器内存中的session信息改为使用Redis生存session信息
====================紧张 End====================
正文开始

0、前情概要

由于shiro不支持分布式场景下使用(大概是支持，但没找到)，但是现在项目都是分布式的项目，一个服务要摆设多个实例，明显shiro已经无法满足现有的情况。为了使shiro可以在分布式项目中使用，博主查阅了很多资料，此中一个包罗引入shiro-redis依赖来实现(并未实操)，但是看这个依赖最新的版本照旧在2020年，果断放弃(应该有很多弊端，我司对弊端的把控极为严格！！！)，以是就想着是否可以根据现在把握的技能和网上的实践来手动实现一下shiro整合redis。以下就是博主的实现过程(码多话少，有事滴滴~)
1、引入依赖

1. <dependency>
2.     <groupId>org.springframework.boot</groupId>
3.     <artifactId>spring-boot-starter-data-redis</artifactId>
4. </dependency>
5. <dependency>
6.     <groupId>org.apache.commons</groupId>
7.     <artifactId>commons-pool2</artifactId>
8. </dependency>

复制代码

2、创建Redis配置类

1. /**
2. * Redis配置类
3. */
4. @EnableCaching
5. @Configuration
6. public class RedisConfiguration {
8.     @Autowired
9.     RedisCacheProperties redisCacheProperties;
11.     @Bean()
12.     public RedisTemplate<String, Object> redisShiroTemplate(@Autowired RedisConnectionFactory factory) {
13.         RedisTemplate<String, Object> template = new RedisTemplate<>();
14.         template.setConnectionFactory(factory);
15.         template.setKeySerializer(new StringRedisSerializer());
16.         template.setHashKeySerializer(new StringRedisSerializer());
17.         // shiro序列化存储session存在问题(https://www.cnblogs.com/ReturnOfTheKing/p/18224205)
18.         /*template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
19.         template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());*/
20.         return template;
21.     }
23.     @Bean(name = {"cacheKeyGenerator"})
24.     public KeyGenerator cacheKeyGenerator() {
25.         return (Object o, Method method, Object... objects) -> {
26.             StringBuilder sb = new StringBuilder();
27.             sb.append(o.getClass().getName());
28.             sb.append(method.getName());
29.             for (Object obj : objects) {
30.                 sb.append(obj.toString());
31.             }
32.             return sb.toString();
33.         };
34.     }
36.     @Bean(name = "cacheManager")
37.     public RedisCacheManager cacheManager(@Autowired RedisConnectionFactory redisConnectionFactory) {
39.         RedisCacheConfiguration defaultConfig = RedisCacheConfiguration.defaultCacheConfig()
40.                 .entryTtl(Duration.ofDays(7))
41.                 .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
42.                 .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()))
43.                 .disableCachingNullValues();
44.         RedisCacheManager.RedisCacheManagerBuilder builder =
45.                 RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(redisConnectionFactory);
47.         Set<String> cacheNames = new HashSet<>();
48.         ConcurrentHashMap<String, RedisCacheConfiguration> cacheConfig = new ConcurrentHashMap<>();
50.         for (Map.Entry<String, Duration> entry : redisCacheProperties.getCacheDuration().entrySet()) {
51.             cacheNames.add(entry.getKey());
52.             cacheConfig.put(entry.getKey(), defaultConfig.entryTtl(entry.getValue()));
53.         }
55.         RedisCacheManager cacheManager = builder
56.                 .transactionAware()
57.                 .cacheDefaults(defaultConfig)
58.                 .initialCacheNames(cacheNames)
59.                 .withInitialCacheConfigurations(cacheConfig)
60.                 .build();
62.         return cacheManager;
63.     }
64. }

复制代码

1. /**
2. * RedisCache参数
3. */
4. @Component
5. @Getter
6. public class RedisCacheProperties {
8.     private final Map<String, Duration> cacheDuration = new HashMap<>();
9. }

复制代码

3、继承AbstractSessionDAO，创建自界说RedisSessionDao 类

1. /**
2. * 自定义RedisSessionDAO
3. */
4. @Component
5. public class RedisSessionDao extends AbstractSessionDAO {
7.     @Value("${session.redis.expireTime}")
8.     private long expireTime;
10.     @Autowired
11.     private RedisTemplate<String, Object> redisShiroTemplate;
13.     private String getKey(String originalKey) {
14.         return "shiro_redis_session_key_:" + originalKey;
15.     }
17.     @Override
18.     protected Serializable doCreate(Session session) {
19.         Serializable sessionId = this.generateSessionId(session);
20.         this.assignSessionId(session, sessionId);
21.         redisShiroTemplate.opsForValue().set(getKey(session.getId().toString()), session, expireTime, TimeUnit.SECONDS);
22.         return sessionId;
23.     }
25.     @Override
26.     protected Session doReadSession(Serializable sessionId) {
27.         return sessionId == null ? null : (Session) redisShiroTemplate.opsForValue().get(getKey(sessionId.toString()));
28.     }
30.     @Override
31.     public void update(Session session) throws UnknownSessionException {
32.         if (session != null && session.getId() != null) {
33.             session.setTimeout(expireTime * 1000);
34.             redisShiroTemplate.opsForValue().set(getKey(session.getId().toString()), session, expireTime, TimeUnit.SECONDS);
35.         }
36.     }
38.     @Override
39.     public void delete(Session session) {
40.         if (session != null && session.getId() != null) {
41.             redisShiroTemplate.opsForValue().getOperations().delete(getKey(session.getId().toString()));
42.         }
43.     }
45.     @Override
46.     public Collection<Session> getActiveSessions() {
47.         return Collections.emptySet();
48.     }
49. }

复制代码

4、在ShiroConfiguration配置类中使用自界说SessionDAO

1. @Bean
2. public SessionManager shiroSessionManager() {
3.     DefaultWebSessionManager sessionManager = new DefaultWebSessionManager();
4.     //session过期时间
5.     sessionManager.setGlobalSessionTimeout(expireTime * 1000);
6.     sessionManager.setSessionDAO(redisSessionDao);
7.     return sessionManager;
8. }

复制代码

问题

往redis中放的数据记得实现 序列化接口，否则会报错！
参考

• 分布式shiro，session共享
  
• Shiro权限管理框架（二）：Shiro结合Redis实现分布式情况下的Session共享
  
• shiro org.apache.shiro.session.mgt.SimpleSession对象 反序列化失败
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。