关于后端:基于Redis的消息发布和订阅广播模式

最近在优化一个redis的大key问题, 原先的共事写法是将所有的配置都放在一个key外面, value是一个map. 然而随着配置越来越多, 这个map也变得很大, 曾经影响redis的性能.遂决定将map外面的每个配置独自进去一个key, 当有配置变动的时候, 通过redis的音讯队列告诉到其余程序. 上面是在springboot中具体实现形式:

1.引入依赖

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2.配置监听

如下如所示, 定义了2个Linstener, 模仿2个利用监听同一个通道. 依据发送和接管的数据类型咱们能够抉择适合的数据序列化和反序列化形式, 默认序列化形式为RedisSerializer.java(). 对于一般的Bean来说应用json()和java()的序列形式都能够.不同点在于:

• RedisSerializer.java()应用JdkSerializationRedisSerializer,JDK提供的序列化性能。长处是反序列化时不须要提供类型信息(class)，但毛病是须要实现Serializable接口，还有序列化后的后果十分宏大，是JSON格局的5倍左右，这样就会耗费redis服务器的大量内存

• RedisSerializer.json()应用Jackson2JsonRedisSerializer, 借助Jackson库将对象序列化为JSON字符串。长处是速度快，序列化后的字符串短小精悍，不须要实现Serializable接口。但毛病也十分致命，那就是此类的构造函数中有一个类型参数，必须提供要序列化对象的类型信息(.class对象)。 通过查看源代码，发现其只在反序列化过程中用到了类型信息

  @Configuration
  public class RedisConfig {
  
    public static final String TOPIC = "topic_1";
  
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter,
                                            MessageListenerAdapter listenerAdapter2) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, new PatternTopic(TOPIC));
        container.addMessageListener(listenerAdapter2, new PatternTopic(TOPIC));
        return container;
    }
  
    @Bean
    MessageListenerAdapter listenerAdapter(Listener1 listener1) {
        System.out.println("listener1 register");
        MessageListenerAdapter listenerAdapter = new MessageListenerAdapter(listener1, "onMessage");
        listenerAdapter.setSerializer(RedisSerializer.json());
        return listenerAdapter;
    }
  
    @Bean
    MessageListenerAdapter listenerAdapter2(Listener2 listener2) {
        System.out.println("listener2 register");
        MessageListenerAdapter listenerAdapter = new MessageListenerAdapter(listener2, "onMessage");
        listenerAdapter.setSerializer(RedisSerializer.java());
        return listenerAdapter;
    }
  }

  3. 创立监听类

• 监听类需实现MessageListener 接口,并实现OnMessage办法

  @Component
  public class Listener1 implements MessageListener {
  
    @Override
    public void onMessage(Message message, byte[] pattern) {
        UserDTO userDTO = JSONObject.parseObject(message.toString(), UserDTO.class);
        System.err.println("listener1--->" + userDTO);
    }
  }

• 创立Listener2类, 模仿另外一个程序

  @Component
  public class Listener2 implements MessageListener {
  
    @Override
    public void onMessage(Message message, byte[] pattern) {
        UserDTO userDTO = JSONObject.parseObject(message.toString(), UserDTO.class);
        System.err.println("listener2--->" + userDTO);
    }
  }

4.发送音讯(播送模式)

• 调用redisTemplate.convertAndSend()办法, 发送音讯到topic_1. 音讯会通过redis播送至所有的消费者.

  @RestController
  public class TestController {
  
    @Autowired
    private RedisTemplate redisTemplate;
  
    @GetMapping("/test")
    public String test() {
        redisTemplate.setValueSerializer(RedisSerializer.string());
        UserDTO userDTO = new UserDTO("sharloon", 18, 1);
        redisTemplate.convertAndSend("topic_1", JSON.toJSONString(userDTO));
  
        return "test ok";
    }
  }

5. 成果展现

listener2--->UserDTO(name=sharloon, age=18, sex=1)
listener1--->UserDTO(name=sharloon, age=18, sex=1)

6. demo地址

https://gitee.com/sharloon/redis-message

本文由mdnice多平台公布