Spring Cloud 集成 Redis 发布订阅

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
 
@Configuration
public class RedisPubSubConfig {
 
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        return container;
    }
 
    // 如果需要订阅特定频道，可以创建相应的监听器并注册到container中
    // @Bean
    // MessageListener myListener() {
    //     return new MessageListener() {
    //         public void onMessage(Message message, byte[] pattern) {
    //             // 处理接收到的消息
    //         }
    //     };
    // }
 
    // 注册监听器
    // container.addMessageListener(myListener(), topic());
}

这个配置类创建了一个RedisMessageListenerContainer，它是Spring用于监听来自Redis的消息的容器。可以通过注释掉的myListener方法来创建一个消息监听器，并通过注释掉的container.addMessageListener方法将其注册到容器中，以便监听特定频道的消息。