分布式Shiro，SpringBoot项目Shiro整合Redis - ToB企服应用市场:ToB评测及商务社交产业平台

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>

复制代码

/**
* Redis配置类
*/
@EnableCaching
@Configuration
public class RedisConfiguration {
@Autowired
RedisCacheProperties redisCacheProperties;
@Bean()
public RedisTemplate<String, Object> redisShiroTemplate(@Autowired RedisConnectionFactory factory) {
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(factory);
template.setKeySerializer(new StringRedisSerializer());
template.setHashKeySerializer(new StringRedisSerializer());
// shiro序列化存储session存在问题(https://www.cnblogs.com/ReturnOfTheKing/p/18224205)
/*template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());*/
return template;
}
@Bean(name = {"cacheKeyGenerator"})
public KeyGenerator cacheKeyGenerator() {
return (Object o, Method method, Object... objects) -> {
StringBuilder sb = new StringBuilder();
sb.append(o.getClass().getName());
sb.append(method.getName());
for (Object obj : objects) {
sb.append(obj.toString());
}
return sb.toString();
};
}
@Bean(name = "cacheManager")
public RedisCacheManager cacheManager(@Autowired RedisConnectionFactory redisConnectionFactory) {
RedisCacheConfiguration defaultConfig = RedisCacheConfiguration.defaultCacheConfig()
.entryTtl(Duration.ofDays(7))
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()))
.disableCachingNullValues();
RedisCacheManager.RedisCacheManagerBuilder builder =
RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(redisConnectionFactory);
Set<String> cacheNames = new HashSet<>();
ConcurrentHashMap<String, RedisCacheConfiguration> cacheConfig = new ConcurrentHashMap<>();
for (Map.Entry<String, Duration> entry : redisCacheProperties.getCacheDuration().entrySet()) {
cacheNames.add(entry.getKey());
cacheConfig.put(entry.getKey(), defaultConfig.entryTtl(entry.getValue()));
}
RedisCacheManager cacheManager = builder
.transactionAware()
.cacheDefaults(defaultConfig)
.initialCacheNames(cacheNames)
.withInitialCacheConfigurations(cacheConfig)
.build();
return cacheManager;
}
}

复制代码

/**
* RedisCache参数
*/
@Component
@Getter
public class RedisCacheProperties {
private final Map<String, Duration> cacheDuration = new HashMap<>();
}

复制代码

/**
* 自定义RedisSessionDAO
*/
@Component
public class RedisSessionDao extends AbstractSessionDAO {
@Value("${session.redis.expireTime}")
private long expireTime;
@Autowired
private RedisTemplate<String, Object> redisShiroTemplate;
private String getKey(String originalKey) {
return "shiro_redis_session_key_:" + originalKey;
}
@Override
protected Serializable doCreate(Session session) {
Serializable sessionId = this.generateSessionId(session);
this.assignSessionId(session, sessionId);
redisShiroTemplate.opsForValue().set(getKey(session.getId().toString()), session, expireTime, TimeUnit.SECONDS);
return sessionId;
}
@Override
protected Session doReadSession(Serializable sessionId) {
return sessionId == null ? null : (Session) redisShiroTemplate.opsForValue().get(getKey(sessionId.toString()));
}
@Override
public void update(Session session) throws UnknownSessionException {
if (session != null && session.getId() != null) {
session.setTimeout(expireTime * 1000);
redisShiroTemplate.opsForValue().set(getKey(session.getId().toString()), session, expireTime, TimeUnit.SECONDS);
}
}
@Override
public void delete(Session session) {
if (session != null && session.getId() != null) {
redisShiroTemplate.opsForValue().getOperations().delete(getKey(session.getId().toString()));
}
}
@Override
public Collection<Session> getActiveSessions() {
return Collections.emptySet();
}
}

复制代码

@Bean
public SessionManager shiroSessionManager() {
DefaultWebSessionManager sessionManager = new DefaultWebSessionManager();
//session过期时间
sessionManager.setGlobalSessionTimeout(expireTime * 1000);
sessionManager.setSessionDAO(redisSessionDao);
return sessionManager;
}

复制代码