update 优化自动注入器 异常检查更完善

疯狂的狮子li

2021-08-02 210b5af1c7f15f45c5d1abca607bd8d942a2b66a

 ruoyi-framework/src/main/java/com/ruoyi/framework/config/RedisConfig.java

@@ -1,45 +1,92 @@
package com.ruoyi.framework.config;



import org.springframework.cache.annotation.CachingConfigurerSupport;

import org.springframework.cache.annotation.EnableCaching;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.serializer.StringRedisSerializer;

import com.fasterxml.jackson.annotation.JsonAutoDetect;

import com.fasterxml.jackson.annotation.JsonTypeInfo;

import com.fasterxml.jackson.annotation.PropertyAccessor;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;



/**

 * redis配置

 * 
 * @author ruoyi

 */

@Configuration

@EnableCaching

public class RedisConfig extends CachingConfigurerSupport

{

    @Bean

    @SuppressWarnings(value = { "unchecked", "rawtypes" })

    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory)

    {

        RedisTemplate<Object, Object> template = new RedisTemplate<>();

        template.setConnectionFactory(connectionFactory);



        FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class);



        ObjectMapper mapper = new ObjectMapper();

        mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

        mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);

        serializer.setObjectMapper(mapper);



        template.setValueSerializer(serializer);

        // 使用StringRedisSerializer来序列化和反序列化redis的key值

        template.setKeySerializer(new StringRedisSerializer());

        template.afterPropertiesSet();

        return template;

    }

}

package com.ruoyi.framework.config;

import cn.hutool.core.util.StrUtil;
import com.ruoyi.framework.config.properties.RedissonProperties;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.codec.JsonJacksonCodec;
import org.redisson.config.Config;
import org.redisson.spring.cache.CacheConfig;
import org.redisson.spring.cache.RedissonSpringCacheManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * redis配置
 *
 * @author Lion Li
 */
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

   private static final String REDIS_PROTOCOL_PREFIX = "redis://";
   private static final String REDISS_PROTOCOL_PREFIX = "rediss://";

   @Autowired
   private RedisProperties redisProperties;

   @Autowired
   private RedissonProperties redissonProperties;

   @Bean(destroyMethod = "shutdown")
   @ConditionalOnMissingBean(RedissonClient.class)
   public RedissonClient redisson() throws IOException {
      String prefix = REDIS_PROTOCOL_PREFIX;
      if (redisProperties.isSsl()) {
         prefix = REDISS_PROTOCOL_PREFIX;
      }
      Config config = new Config();
      config.setThreads(redissonProperties.getThreads())
         .setNettyThreads(redissonProperties.getNettyThreads())
         .setCodec(JsonJacksonCodec.INSTANCE)
         .setTransportMode(redissonProperties.getTransportMode());

      RedissonProperties.SingleServerConfig singleServerConfig = redissonProperties.getSingleServerConfig();
      // 使用单机模式
      config.useSingleServer()
         .setAddress(prefix + redisProperties.getHost() + ":" + redisProperties.getPort())
         .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue())
         .setDatabase(redisProperties.getDatabase())
         .setPassword(StrUtil.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null)
         .setTimeout(singleServerConfig.getTimeout())
         .setRetryAttempts(singleServerConfig.getRetryAttempts())
         .setRetryInterval(singleServerConfig.getRetryInterval())
         .setSubscriptionsPerConnection(singleServerConfig.getSubscriptionsPerConnection())
         .setClientName(singleServerConfig.getClientName())
         .setIdleConnectionTimeout(singleServerConfig.getIdleConnectionTimeout())
         .setSubscriptionConnectionMinimumIdleSize(singleServerConfig.getSubscriptionConnectionMinimumIdleSize())
         .setSubscriptionConnectionPoolSize(singleServerConfig.getSubscriptionConnectionPoolSize())
         .setConnectionMinimumIdleSize(singleServerConfig.getConnectionMinimumIdleSize())
         .setConnectionPoolSize(singleServerConfig.getConnectionPoolSize())
         .setDnsMonitoringInterval(singleServerConfig.getDnsMonitoringInterval());
      return Redisson.create(config);
   }

   /**
    * 整合spring-cache
    */
   @Bean
   public CacheManager cacheManager(RedissonClient redissonClient) {
      List<RedissonProperties.CacheGroup> cacheGroup = redissonProperties.getCacheGroup();
      Map<String, CacheConfig> config = new HashMap<>();
      for (RedissonProperties.CacheGroup group : cacheGroup) {
         CacheConfig cacheConfig = new CacheConfig(group.getTtl(), group.getMaxIdleTime());
         cacheConfig.setMaxSize(group.getMaxSize());
         config.put(group.getGroupId(), cacheConfig);
      }
      return new RedissonSpringCacheManager(redissonClient, config, JsonJacksonCodec.INSTANCE);
   }

}