| | |
| | | package com.genersoft.iot.vmp.conf;
|
| | |
|
| | | import com.alibaba.fastjson.parser.ParserConfig;
|
| | | import com.genersoft.iot.vmp.common.VideoManagerConstants;
|
| | | import com.genersoft.iot.vmp.service.impl.*;
|
| | | import org.apache.commons.lang3.StringUtils;
|
| | |
| | | import org.springframework.context.annotation.Bean;
|
| | | import org.springframework.context.annotation.Configuration;
|
| | | import org.springframework.data.redis.connection.RedisConnectionFactory;
|
| | | import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
|
| | | import org.springframework.data.redis.core.RedisTemplate;
|
| | | import org.springframework.data.redis.listener.PatternTopic;
|
| | | import org.springframework.data.redis.listener.RedisMessageListenerContainer;
|
| | | import org.springframework.data.redis.serializer.StringRedisSerializer;
|
| | |
|
| | | import com.alibaba.fastjson.parser.ParserConfig;
|
| | | import com.genersoft.iot.vmp.utils.redis.FastJsonRedisSerializer;
|
| | | import redis.clients.jedis.JedisPool;
|
| | | import redis.clients.jedis.JedisPoolConfig;
|
| | |
|
| | |
|
| | | /**
|
| | | * @description:Redis中间件配置类,使用spring-data-redis集成,自动从application.yml中加载redis配置
|
| | |
| | | */
|
| | | @Configuration
|
| | | public class RedisConfig extends CachingConfigurerSupport {
|
| | |
|
| | | @Value("${spring.redis.host}")
|
| | | private String host;
|
| | | @Value("${spring.redis.port}")
|
| | | private int port;
|
| | | @Value("${spring.redis.database}")
|
| | | private int database;
|
| | | @Value("${spring.redis.password}")
|
| | | private String password;
|
| | | @Value("${spring.redis.timeout}")
|
| | | private int timeout;
|
| | | @Value("${spring.redis.poolMaxTotal:1000}")
|
| | | private int poolMaxTotal;
|
| | | @Value("${spring.redis.poolMaxIdle:500}")
|
| | | private int poolMaxIdle;
|
| | | @Value("${spring.redis.poolMaxWait:5}")
|
| | | private int poolMaxWait;
|
| | |
|
| | | @Autowired
|
| | | private RedisGpsMsgListener redisGPSMsgListener;
|
| | |
| | | private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;
|
| | |
|
| | | @Bean
|
| | | public JedisPool jedisPool() {
|
| | | if (StringUtils.isBlank(password)) {
|
| | | password = null;
|
| | | }
|
| | | JedisPoolConfig poolConfig = new JedisPoolConfig();
|
| | | poolConfig.setMaxIdle(poolMaxIdle);
|
| | | poolConfig.setMaxTotal(poolMaxTotal);
|
| | | // 秒转毫秒
|
| | | poolConfig.setMaxWaitMillis(poolMaxWait * 1000L);
|
| | | JedisPool jp = new JedisPool(poolConfig, host, port, timeout * 1000, password, database);
|
| | | return jp;
|
| | | public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
|
| | | RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
|
| | | // 使用fastJson序列化
|
| | | FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(Object.class);
|
| | | // value值的序列化采用fastJsonRedisSerializer
|
| | | redisTemplate.setValueSerializer(fastJsonRedisSerializer);
|
| | | redisTemplate.setHashValueSerializer(fastJsonRedisSerializer);
|
| | | // 全局开启AutoType,不建议使用
|
| | | ParserConfig.getGlobalInstance().setAutoTypeSupport(true);
|
| | | // 建议使用这种方式,小范围指定白名单,需要序列化的类
|
| | | // ParserConfig.getGlobalInstance().addAccept("com.avatar");
|
| | | // key的序列化采用StringRedisSerializer
|
| | | redisTemplate.setKeySerializer(new StringRedisSerializer());
|
| | | redisTemplate.setHashKeySerializer(new StringRedisSerializer());
|
| | | redisTemplate.setConnectionFactory(redisConnectionFactory);
|
| | | return redisTemplate;
|
| | | }
|
| | |
|
| | | @Bean("redisTemplate")
|
| | | public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
|
| | | RedisTemplate<Object, Object> template = new RedisTemplate<>();
|
| | | template.setConnectionFactory(redisConnectionFactory);
|
| | | // 使用fastjson进行序列化处理,提高解析效率
|
| | | FastJsonRedisSerializer<Object> serializer = new FastJsonRedisSerializer<Object>(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监听器,只需要把消息监听器和相应的消息订阅处理器绑定,该消息监听器
|