content: package top.panll.assist.config;
  
  import com.alibaba.fastjson.parser.ParserConfig;
  import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
  import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
  import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
  import org.springframework.boot.context.properties.EnableConfigurationProperties;
  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.RedisOperations;
  import org.springframework.data.redis.core.RedisTemplate;
  import org.springframework.data.redis.listener.RedisMessageListenerContainer;
  import org.springframework.data.redis.serializer.StringRedisSerializer;
  
  /**
   * @Description:Redis中间件配置类，使用spring-data-redis集成，自动从application.yml中加载redis配置
   * @author: swwheihei
   * @date: 2019年5月30日 上午10:58:25
   * 
   */
  @Configuration
  @ConditionalOnClass(RedisOperations.class)
  @EnableConfigurationProperties(RedisProperties.class)
  public class RedisConfig {
  
  	static {
  		ParserConfig.getGlobalInstance().addAccept("top.panll.assist");
  	}
  
  	@Bean
  	@ConditionalOnMissingBean(name = "redisTemplate")
  	public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
  		RedisTemplate<Object, Object> template = new RedisTemplate<>();
  		template.setConnectionFactory(redisConnectionFactory);
  		// 使用fastjson进行序列化处理，提高解析效率
  		FastJsonRedisSerializer<Object> serializer = new FastJsonRedisSerializer<>(Object.class);
  		// value值的序列化采用fastJsonRedisSerializer
  		template.setValueSerializer(serializer);
  		template.setHashValueSerializer(serializer);
  		// key的序列化采用StringRedisSerializer
  		template.setKeySerializer(new StringRedisSerializer());
  		template.setHashKeySerializer(new StringRedisSerializer());
  		template.setConnectionFactory(redisConnectionFactory);
  		// 使用fastjson时需设置此项，否则会报异常not support type
  //		ParserConfig.getGlobalInstance().setAutoTypeSupport(true);
  		return template;
  
  	}
  
  	/**
  	 * redis消息监听器容器 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器
  	 * 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
  	 * 
  	 * @param connectionFactory
  	 * @return
  	 */
  	@Bean
  	RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
  
          RedisMessageListenerContainer container = new RedisMessageListenerContainer();
          container.setConnectionFactory(connectionFactory);
          return container;
      }
  
  }
  