我在使用 Firebase SDK Admin (Java) 的服务中工作。在我添加一个 Redis 客户端 (Jedis) 来管理队列之前，它曾经工作得很好。自那次更改以来，我的 firebase 监听器停止工作。我没有任何错误。

Firebase 监听器 - Java 管理 SDK

LOGGER.info("1. Se inicio la sesion de firebase.");
  final FirebaseDatabase database = FirebaseDatabase.getInstance();
  listenerRef = database.getReference(ENVIRONMENT);
  DatabaseReference checkinRef = listenerRef.child(EFirebaseField.CHECKINS.getField());
  DatabaseReference collectRef;

  LOGGER.info("2. Carga de listeners de checkin para registro en base de datos.");

  checkinRef.orderByChild(EFirebaseField.STATUS.getField())
      .equalTo(EStatusFirebase.STARTED.getField())
      .addChildEventListener(new ChildEventListener() {

        @Override
        public void onChildRemoved(DataSnapshot dataSnapshot) {
          LOGGER.debug("Se elimino un checkin STARTED: {} {}", dataSnapshot.getKey(),
              dataSnapshot.getRef());
        }

        @Override
        public void onChildMoved(DataSnapshot dataSnapshot, String prevChildKey) {
          LOGGER.debug("Se reubico un checkin STARTED: {} {}", dataSnapshot.getKey(),
              dataSnapshot.getRef());
        }

        @Override
        public void onChildChanged(DataSnapshot dataSnapshot, String prevChildKey) {
          LOGGER.debug("Se modifico un checkin STARTED: {} {}", dataSnapshot.getKey(),
              dataSnapshot.getRef());
        }

        @Override
        public void onChildAdded(DataSnapshot dataSnapshot, String prevChildKey) {
          LOGGER.info("A. Se agrego un nuevo checkin STARTED: {} {}", dataSnapshot.getKey(),
              dataSnapshot.getRef());
          firebaseActuators.processCheckin(dataSnapshot);
        }

        @Override
        public void onCancelled(DatabaseError error) {
          LOGGER.error("Ocurrio un error en checkin STARTED: {}", error.getMessage());
        }
      });

Redis 客户端 - Jedis 客户端

@Configuration
@PropertySource({"${propertiesDir:}/database-${envTarget:dev}.properties"})

public class RedisConfig {
private static final Logger LOGGER_REDIS = LogManager.getLogger(RedisConfig.class);

@Value("${redis.url}")
private String redisUrl;

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

@Value("${redis.pw}")
private String redisPw;

@Value("${redis.maxTotal}")
private int maxTotal;

@Value("${redis.maxIdle}")
private int maxIdle;

@Value("${redis.minIdle}")
private int minIdle;

@Value("${redis.ssl.trustStore}")
private String trustStore;
@Value("${redis.ssl.trustStoreType}")
private String trustStoreType;
@Value("${redis.ssl.trustStorePassword}")
private String trustStorePassword;
@Value("${redis.ssl.keyStore}")
private String keyStore;
@Value("${redis.ssl.keyStorePassword}")
private String keyStorePassword;
@Value("${redis.ssl.keyStoreType}")
private String keyStoreType;

@Bean
public RedisConnectionFactory connectionFactory() {
try {

  System.setProperty("javax.net.ssl.trustStore", trustStore);
  System.setProperty("javax.net.ssl.trustStoreType", trustStoreType);
  System.setProperty("javax.net.ssl.trustStorePassword", trustStorePassword);     
  System.setProperty("javax.net.ssl.keyStore", keyStore);
  System.setProperty("javax.net.ssl.keyStorePassword", keyStorePassword);
  System.setProperty("javax.net.ssl.keyStoreType", keyStoreType);

  JedisConnectionFactory cf = new JedisConnectionFactory(jedisPoolConfig());
  cf.setHostName(redisUrl);
  cf.setPort(redisPort);
  cf.setUseSsl(true);
  cf.setUsePool(true);
  cf.afterPropertiesSet();
  return cf;
} catch (RedisConnectionFailureException e) {
  LOGGER_REDIS.error("Error de conexion con Redis:" + e.getMessage(), e);
  return null;
}
}

@Bean
public JedisPoolConfig jedisPoolConfig() {
  JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
  jedisPoolConfig.setMaxTotal(maxTotal);
  jedisPoolConfig.setMaxIdle(maxIdle);
  jedisPoolConfig.setMinIdle(minIdle);
  jedisPoolConfig.setTestOnBorrow(true);
  jedisPoolConfig.setTestOnReturn(true);
  jedisPoolConfig.setTestWhileIdle(true);
  jedisPoolConfig.setMinEvictableIdleTimeMillis(
      Duration.ofSeconds(60).toMillis());

  jedisPoolConfig.setTimeBetweenEvictionRunsMillis(
      Duration.ofSeconds(30).toMillis());
  jedisPoolConfig.setNumTestsPerEvictionRun(3);
  jedisPoolConfig.setBlockWhenExhausted(true);

  return jedisPoolConfig;
 }

 @Bean
 public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
 RedisTemplate<String, Object> template = new RedisTemplate<>();

 if (null == connectionFactory) {
    LOGGER_REDIS.error("Redis template service is not available");
    return null;
 };

 template.setConnectionFactory(connectionFactory);
 template.afterPropertiesSet();

 return template;
 }

如果我在使用 firebase 监听器时有不止一种监听器，会有什么问题吗？ ¿或者，我的 Redis 配置有问题吗？

最佳答案

问题实际上既不是 Redis 也不是 Firebase，而是在 System.setProperties 上设置的信任库。 Redis 在 JVM 上设置信任库，当 Firebase 尝试读取信任库时，会识别出来自 Redis 的信任库。这就是你遇到问题的原因。要么是这样，要么是您的 Bean 配置有问题。问候。

关于java - Redis 客户端阻止 Java 中的 firebase 监听器，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/48104591/