0
点赞
收藏
分享

微信扫一扫

UNI-APP_vmin横屏适配问题

芥子书屋 2023-07-13 阅读 74
redis
@EnableCaching
@Configuration
public class RedisConfig {

    /**
     * @Cacheable注解不支持配置过期时间,所有需要通过配置CacheManneg来配置默认的过期时间和针对每个类或者是方法进行缓存失效时间配置。
     * @param redisConnectionFactory
     * @return
     */
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        return new RedisCacheManager(
                RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory),
                this.getRedisCacheConfigurationWithTtl(600), // 默认策略,未配置的 key 会使用这个
                this.getRedisCacheConfigurationMap() // 指定 key 策略
        );
    }

    private Map<String, RedisCacheConfiguration> getRedisCacheConfigurationMap() {
        Map<String, RedisCacheConfiguration> redisCacheConfigurationMap = new HashMap<>();
        redisCacheConfigurationMap.put("wxcl", this.getRedisCacheConfigurationWithTtl(60*60*24*7));
        //redisCacheConfigurationMap.put("UserInfoListAnother", this.getRedisCacheConfigurationWithTtl(18000));
        return redisCacheConfigurationMap;
    }

    private RedisCacheConfiguration getRedisCacheConfigurationWithTtl(Integer seconds) {
        StringRedisSerializer keyStringRedisSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);

        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig();
        redisCacheConfiguration = redisCacheConfiguration.serializeValuesWith(
                RedisSerializationContext
                        .SerializationPair
                        .fromSerializer(jackson2JsonRedisSerializer)
        ).entryTtl(Duration.ofSeconds(seconds));
        redisCacheConfiguration.serializeKeysWith(
                RedisSerializationContext
                        .SerializationPair
                        .fromSerializer(keyStringRedisSerializer)
        );

        return redisCacheConfiguration;
    }

}
@Slf4j
@Service("myUserCacheService")
public class MyUserCacheService {

    /**
     * sso登录用户获取当前用户
     * @param token token
     * @param user  获取默认null
     */
    @Cacheable(
            value = "iotgw",
            key = "'user'+#token",
            unless = "#result eq null")
    public Map<String, String> getUserFromRedis(String token, Map<String, String> user) {
        log.info("从缓存中获取sso登录人信息失败 {},准备写入缓存", user);
        return user;
    }

    /**
     * 获取企业信息
     * @param token   存储关键值
     * @param company 企业信息
     */
    @Cacheable(
            value = "devicecenter",
            key = "'company'+#token",
            unless = "#result eq null")
    public Map<String, String> getCompanyFromRedis(String token, Map<String, String> company) {
        log.info("从缓存中获取登录人信息失败 {},准备写入缓存", company);
        return company;
    }

    /**
     * 企业信息缓存变更
     * @param token   存储关键值
     * @param company 企业信息
     */
    @CachePut(
            value = "devicecenter",
            key = "'company'+#token",
            unless = "#result eq null")
    public Map<String, String> setCompanyFromRedis(String token, Map<String, String> company) {
        log.info("从缓存中获取登录人信息失败 {},准备写入缓存", company);
        return company;
    }

    /**
     * 后台登录用户获取当前用户
     */
    @Cacheable(
            value = "iotmgw",
            key = "'user'+#userId",
            unless = "#result eq null")
    public Map<String, String> getManagerUserFromRedis(String userId, Map<String, String> user) {
        log.info("从缓存中获取后台登录人信息失败 {},准备写入缓存", user);
        return user;
    }

}
举报

相关推荐

0 条评论