（Redis使用系列） Springboot 实现Redis消息的订阅与分布

在Spring Boot中，可以使用spring-boot-starter-data-redis库来实现Redis消息的订阅与分布。以下是一个简单的例子，展示如何使用Spring Data Redis实现发布/订阅模式。

首先，在pom.xml中添加依赖：

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

然后，配置Redis消息监听器容器：

@Configuration
public class RedisConfig {
 
    @Autowired
    private RedisConnectionFactory redisConnectionFactory;
 
    @Bean
    RedisMessageListenerContainer redisMessageListenerContainer() {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisConnectionFactory);
        return container;
    }
}

创建一个消息监听器来处理接收到的消息：

@Component
public class RedisMessageSubscriber implements MessageListener {
 
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String receivedMessage = new String(message.getBody(), StandardCharsets.UTF_8);
        System.out.println("Received Message: " + receivedMessage);
        // 根据接收到的消息进行业务逻辑处理
    }
}

最后，发布消息：

@Service
public class RedisMessagePublisher {
 
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
 
    public void publish(String channel, String message) {
        stringRedisTemplate.convertAndSend(channel, message);
    }
}

在上述代码中，我们定义了一个配置类RedisConfig来创建RedisMessageListenerContainer，并设置了连接工厂。我们还实现了一个RedisMessageSubscriber类来监听消息，并在其中处理接收到的消息。RedisMessagePublisher服务用于发布消息到指定的频道。

要订阅一个频道，你需要在RedisMessageSubscriber中设置你感兴趣的频道，并将其注册到RedisMessageListenerContainer。

@Component
public class RedisMessageSubscriber implements MessageListener {
 
    @Autowired
    private RedisMessageListenerContainer redisMessageListenerContainer;
 
    @PostConstruct
    public void subscribe()