JedisConnectionException - Ошибка чтения тайм-аута

Question

Я пытаюсь подключиться к AWS ElastiCache Redis, используя комбинацию Spring Data Redis + Jedis. [Redis Cluster включен, поэтому у него есть конечная точка Cluster Config с 3 шардами - каждый шард имеет 1 основной узел + 2 узла реплики]

Я получаю ошибку тайм-аута чтения.

Caused by: redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketTimeoutException: Read timed out

AWS Redis Server Версия: 5.0.3 / Кластерный режим: включен / SSL: включен / Auth: включен (по паролю)

Библиотека - Spring-data-redis: 2.1.6. Выпуск / джедай: 2.9.0

Telnet работает с AWS Redis для всех узлов и конечной точки конфигурации кластера на 6379 портах.

Я попробовал Redisson самостоятельно, он подключается к AWS Redis, без каких-либо проблем.

Итак, никаких проблем с самим Redis, проблема с Spring Data Redis в сочетании с Jedis.

Мой код выглядит так -

        RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
        redisClusterConfiguration.setClusterNodes(listOfRedisNode);
        redisClusterConfiguration.setPassword(passwordString);


        JedisClientConfiguration.JedisClientConfigurationBuilder jedisClientConfiguration = JedisClientConfiguration.builder();
        jedisClientConfiguration.connectTimeout(Duration.ofSeconds(60));
        jedisClientConfiguration.useSsl();
        jedisClientConfiguration.usePooling();


        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration, jedisClientConfiguration.build() );
        jedisConnectionFactory.afterPropertiesSet();

        final RedisTemplate<String, Serializable> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(jedisConnectionFactory);
        redisTemplate.setKeySerializer(new JdkSerializationRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
        redisTemplate.afterPropertiesSet();

        System.out.println(redisTemplate.getClientList().size());

        StringRedisConnection stringRedisConnectionlettuce = new DefaultStringRedisConnection(redisTemplate.getConnectionFactory().getConnection());
        final String message2 = stringRedisConnectionlettuce.echo("Hello");
        System.out.println("Hello".equals(message2));

Ошибка тайм-аута чтения -

Exception in thread "main" java.lang.reflect.InvocationTargetException
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48)
    at org.springframework.boot.loader.Launcher.launch(Launcher.java:87)
    at org.springframework.boot.loader.Launcher.launch(Launcher.java:50)
    at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:51)
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketTimeoutException: Read timed out
    at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:202)
    at redis.clients.util.RedisInputStream.readByte(RedisInputStream.java:40)
    at redis.clients.jedis.Protocol.process(Protocol.java:151)
    at redis.clients.jedis.Protocol.read(Protocol.java:215)
    at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:340)
    at redis.clients.jedis.Connection.getStatusCodeReply(Connection.java:239)
    at redis.clients.jedis.BinaryClient.connect(BinaryClient.java:96)
    at redis.clients.jedis.Connection.sendCommand(Connection.java:126)
    at redis.clients.jedis.Connection.sendCommand(Connection.java:117)
    at redis.clients.jedis.BinaryClient.auth(BinaryClient.java:564)
    at redis.clients.jedis.BinaryJedis.auth(BinaryJedis.java:2138)
    at redis.clients.jedis.JedisClusterConnectionHandler.initializeSlotsCache(JedisClusterConnectionHandler.java:36)
    at redis.clients.jedis.JedisClusterConnectionHandler.<init>(JedisClusterConnectionHandler.java:17)
    at redis.clients.jedis.JedisSlotBasedConnectionHandler.<init>(JedisSlotBasedConnectionHandler.java:24)
    at redis.clients.jedis.BinaryJedisCluster.<init>(BinaryJedisCluster.java:54)
    at redis.clients.jedis.JedisCluster.<init>(JedisCluster.java:93)
    at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.createCluster(JedisConnectionFactory.java:418)
    at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.createCluster(JedisConnectionFactory.java:388)
    at org.springframework.data.redis.connection.jedis.JedisConnectionFactory.afterPropertiesSet(JedisConnectionFactory.java:345)
    at io.github.deepshiv126.springdataredis.example.MySpringBootApplication.main(MySpringBootApplication.java:306)
    ... 8 more
Caused by: java.net.SocketTimeoutException: Read timed out
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
    at java.net.SocketInputStream.read(SocketInputStream.java:171)
    at java.net.SocketInputStream.read(SocketInputStream.java:141)
    at java.net.SocketInputStream.read(SocketInputStream.java:127)
    at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:196)
    ... 27 more

Я изучил исходный код Spring и исходный код Jedis - я предполагаю, что он не использует SSL-соединение;

JedisConnectionFactory - afterPropertiesSet () - пытается создать кластер - при этом он пытается initializeSlotsCache, который выдал команду AUTH для Redis Server, с паролем - здесь происходит «Тайм-аут чтения»;

Я понимаю локальный redis - вы можете зайти внутрь и запустить команду auth, чтобы пройти аутентификацию. Но я полагаю, что AWS Redis, возможно, не сможет этого сделать, ему нужно SSL-соединение даже до того, как он запустит команду AUTH. Почему Jedis не использует SSL-соединение?

Это еще один поток "Не удается установить соединение с Jedis" при использовании SSL с Redis и Spring Data Redis говорит, используйте что-то вроде JedisPool - но JedisConnectionFactory из Spring-data-redis не принимает JedisPool. Есть ли другой способ сделать это?

JedisPool jedisPool = new JedisPool("rediss://" + clusterConfigEndPoint + ":6379");

Еще один вопрос - другие библиотеки используют redis ssl-соединение как rediss:// - как Jedis Client использовать SSL-соединение,

Любая помощь будет по достоинству оценена !!

Спасибо!