How to connect to redis cluster in asynchronous mode using lettuce connection factory.

[Pramit2512]

We have connected to redis cluster with sentinel from our application as:
`

public LettuceConnectionFactory connectToRedis() {
    LOG.info("Connecting to Redis cluster with sentinel");
    
    LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
            .readFrom(ReadFrom.REPLICA_PREFERRED)
            .build();


    RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration();
    sentinelConfig.setPassword(getMasterPassword());
    sentinelConfig.setSentinelPassword(getSentinelPassword());
    sentinelConfig.master(getMasterName())
            .sentinel(getSentinelHost_1(), getSentinelPort_1())
            .sentinel(getSentinelHost_2(), getSentinelPort_2())
            .sentinel(getSentinelHost_3(), getSentinelPort_3());

    LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(sentinelConfig, clientConfig);

    LOG.info("Connected to Redis cluster with sentinel");
    return lettuceConnectionFactory;
}

public StringRedisTemplate stringRedisTemplate() {
    LOG.info("Initialising StringRedisTemplate");
    StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(connectToRedis());
    return stringRedisTemplate;
}

`
And using StringRedis template we are performing get/put calls from redis as:

String s = (String) this.stringRedisTemplate.opsForHash().get(key, key);

But these operations are synchronous .We want to create asynchrounous call from redis ,something like :

CompletableFuture<> future = client.asyncget(key, key);

Is there a way we can implement this.Does anyone has idea on this. Will we have to change from lettuce connection factory to some other library?

Thanks already.

[Pramit2512]

Well finally using lettuce library i am able to create a asynchronous connection which both sentinel and data nodes as password protected:

   @Bean
    public StatefulRedisMasterReplicaConnection statefulRedisMasterReplicaConnection() {


        RedisClient redisClient = RedisClient.create();

        LOG.info("created the redis client");

        RedisURI source = RedisURI.Builder
                .sentinel(getSentinelHost_1(), getSentinelPort_1())
                .withSentinel(getSentinelHost_2(), getSentinelPort_2())
                .withSentinel(getSentinelHost_3(), getSentinelPort_3())
                .withSentinelMasterId(getMasterName()).withPassword(getMasterPassword())
                .build();

        for (RedisURI sentinel : source.getSentinels()) {
            sentinel.setPassword(getSentinelPassword());
        }

        StatefulRedisMasterReplicaConnection<String, String> connection = MasterReplica.connect(redisClient, StringCodec.UTF8,
                source);

        connection.setReadFrom(ReadFrom.REPLICA_PREFERRED);
        LOG.info("created the redis connection");
        return connection;
    }
    @Bean
    public RedisAsyncCommands<String, String> redisAsyncCommands() {

        RedisAsyncCommands<String, String> redisAsyncCommands = statefulRedisMasterReplicaConnection().async();
        return redisAsyncCommands;
    }