关于后端:基于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 多平台公布