根据redis消息更新推流列表

jiang

2022-08-18 8f77d0c25cdd37d4cc96c923b46ae28607bae51d

 src/main/java/com/genersoft/iot/vmp/conf/RedisConfig.java

@@ -1,18 +1,26 @@
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.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.cache.annotation.CachingConfigurerSupport;

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;





/**

 * @Description:Redis中间件配置类，使用spring-data-redis集成，自动从application.yml中加载redis配置

 * @description:Redis中间件配置类，使用spring-data-redis集成，自动从application.yml中加载redis配置

 * @author: swwheihei

 * @date: 2019年5月30日 上午10:58:25

 * 

@@ -20,30 +28,49 @@
@Configuration

public class RedisConfig extends CachingConfigurerSupport {



   @Bean("redisTemplate")

   @Autowired

   private RedisGpsMsgListener redisGPSMsgListener;



   @Autowired

   private RedisAlarmMsgListener redisAlarmMsgListener;



   @Autowired

   private RedisStreamMsgListener redisStreamMsgListener;



   @Autowired

   private RedisGbPlayMsgListener redisGbPlayMsgListener;



   @Autowired

   private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;



   @Autowired

   private RedisPushStreamListMsgListener redisPushStreamListMsgListener;



   @Bean

   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);

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

      // 使用fastJson序列化

      FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(Object.class);

      // value值的序列化采用fastJsonRedisSerializer

      template.setValueSerializer(serializer);

      template.setHashValueSerializer(serializer);

      redisTemplate.setValueSerializer(fastJsonRedisSerializer);

      redisTemplate.setHashValueSerializer(fastJsonRedisSerializer);

      // 全局开启AutoType，不建议使用

       ParserConfig.getGlobalInstance().setAutoTypeSupport(true);

      // 建议使用这种方式，小范围指定白名单，需要序列化的类

//      ParserConfig.getGlobalInstance().addAccept("com.avatar");

      // key的序列化采用StringRedisSerializer

      template.setKeySerializer(new StringRedisSerializer());

      template.setHashKeySerializer(new StringRedisSerializer());

      template.setConnectionFactory(redisConnectionFactory);

      // 使用fastjson时需设置此项，否则会报异常not support type

      ParserConfig.getGlobalInstance().setAutoTypeSupport(true); 
      return template;

      redisTemplate.setKeySerializer(new StringRedisSerializer());

      redisTemplate.setHashKeySerializer(new StringRedisSerializer());

      redisTemplate.setConnectionFactory(redisConnectionFactory);

      return redisTemplate;

   }





   /**

    * redis消息监听器容器 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器

    * 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理

    * 

    * @param connectionFactory

    * @param listenerAdapter

    * @return

    */

   @Bean

@@ -51,6 +78,12 @@


        RedisMessageListenerContainer container = new RedisMessageListenerContainer();

        container.setConnectionFactory(connectionFactory);

      container.addMessageListener(redisGPSMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_GPS));

      container.addMessageListener(redisAlarmMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_SUBSCRIBE_ALARM_RECEIVE));

      container.addMessageListener(redisStreamMsgListener, new PatternTopic(VideoManagerConstants.WVP_MSG_STREAM_CHANGE_PREFIX + "PUSH"));

      container.addMessageListener(redisGbPlayMsgListener, new PatternTopic(RedisGbPlayMsgListener.WVP_PUSH_STREAM_KEY));

      container.addMessageListener(redisPushStreamStatusMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_PUSH_STREAM_STATUS_CHANGE));

      container.addMessageListener(redisPushStreamListMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_PUSH_STREAM_LIST_CHANGE));

        return container;

    }