Spring：通过 java -jar 从命令行运行应用程序时，RedisMessageListenerContainer 不起作用答案

【问题标题】：Spring: RedisMessageListenerContainer not working when running app from command line via java -jarSpring：通过 java -jar 从命令行运行应用程序时，RedisMessageListenerContainer 不起作用
【发布时间】：2017-08-04 09:47:00
【问题描述】：

我的 spring 应用中有以下 RedisConfig

@Configuration
public class RedisConfig {

    @Value("${redis.hostname}")
    private String redisHostName;

    @Value("${redis.port}")
    private String redisPort;

    @Value("${intercom.chats.sync.enable}")
    Boolean enableSync;

    private static final Logger log = LoggerFactory.getLogger(RedisConfig.class.getName());

    @Bean
    public RedisMessageSubscriber redisMessageSubscriber() {
        log.debug("Entered redisMessageSubscriber()");
        return new RedisMessageSubscriber();
    }

    @Bean
    public MessageListenerAdapter messageListenerAdapter() {
        log.debug("Entered messageListenerAdapter()");
        MessageListenerAdapter listener = new MessageListenerAdapter(redisMessageSubscriber());
        listener.setSerializer(new StringRedisSerializer());
        return listener;
    }

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisFactory) {
        log.debug("Entered redisMessageListenerContainer");

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisFactory);
        if (!enableSync) {
            log.debug("Subscribing to the redis queue {}");
            // Only set the listener if the sync is not enabled
            container.addMessageListener(messageListenerAdapter(),
                    Arrays.asList(new ChannelTopic(Constants.EVENT_MESSAGE_KEY)));
        }
        container.afterPropertiesSet();
        return container;
    }

    @Bean
    public JedisConnectionFactory jedisConnectionFactory() {
        JedisConnectionFactory factory = new JedisConnectionFactory();
        factory.setHostName(redisHostName);

        // Checking if redisPort string is an integer or not, this is used in
        // the case of CI environment
        if (redisPort.matches("^-?\\d+$")) {
            factory.setPort(Integer.parseInt(redisPort));
        }
        factory.setUsePool(true);
        return factory;
    }

}

redisMessageSubscriber() 打印日志，messageListenerAdapter() 也是如此，但 redisMessageListenerContainer() 不打印任何内容，这意味着它永远不会被输入。甚至没有输入该函数，因此其中的 2 个日志都没有显示。

结果是它不订阅任何事件。我不明白为什么它不适合我。有人可以分享他们的想法。谢谢！！

编辑：我发现只有当我使用 jar -jar 命令从终端运行项目时才会发生这种情况。如果我从 eclipse 开始它工作正常：/

【问题讨论】：

调用afterPropertiesSet()后需要用RedisMessageListenerContainer.start()启动容器。
@mp911de 嘿，我已经更新了 q 你可能想看看，不过我也会试试这个
看起来像是 IDE 与构建问题。

标签： java spring redis spring-data-redis

【解决方案1】：

我能够让它工作。我在配置类上添加了注释@EnableRedisHttpSession，这导致了问题。我猜他们两个（@EnableRedisHttpSession 和RedisMessageListenerContainer）不能同时工作，但我想得到一个更好的答案。 :/

【讨论】：