@Configuration public class RedisConfig {

@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {

    //Redis消息监听器
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    //设置Redis链接工厂
    container.setConnectionFactory(connectionFactory);

    return container;
} }