Spring:RedisMessageListenerContainer 在通过 java -jar 从命令行运行应用程

Question

我的 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 命令从终端运行项目时，才会发生这种情况。如果我从日食开始，它可以正常工作：/

Answer 1

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