Tair (Redis® OSS-Compatible):Retry mechanisms for Redis clients

Repita apenas operações idempotentes

Um timeout pode ocorrer em qualquer etapa da execução do comando:

• O comando não chegou ao servidor.

• O comando chegou ao servidor, mas a execução excedeu o tempo limite.

• O comando foi executado no servidor, mas a resposta excedeu o tempo limite.

Como uma operação repetida pode ser executada mais de uma vez, repita apenas operações idempotentes.

Idempotente -- SET a b: A execução deste comando várias vezes sempre produz o mesmo resultado.

Não idempotente -- LPUSH mylist a: A execução deste comando várias vezes adiciona elementos a duplicados à mylist.

Configure contagem e intervalo adequados para novas tentativas

Defina a quantidade de tentativas e o intervalo com base na carga de trabalho:

• Poucas tentativas ou intervalo muito longo: A aplicação pode não concluir operações durante falhas transitórias curtas.

• Muitas tentativas ou intervalo muito curto: A aplicação consome recursos excessivos e pode sobrecarregar o servidor.

Evite aninhamento de novas tentativas

O aninhamento de novas tentativas — quando uma operação de repetição aciona outro loop de tentativa — pode causar repetições excessivas ou ilimitadas. Implemente a lógica de nova tentativa em uma única camada da pilha da aplicação.

Registre falhas de nova tentativa em log

Gere logs de nova tentativa no nível WARN. Registre apenas quando a tentativa final falhar, e não em cada tentativa, para evitar ruído nos logs.

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>5.0.0</version>
</dependency>

Instância padrão ou cluster em modo proxy (JedisPool)

Para instâncias padrão ou instâncias de cluster em modo proxy, use PooledConnectionProvider com UnifiedJedis.

O exemplo abaixo tenta executar o comando SET até 5 vezes em 10 segundos usando backoff exponencial. Se todas as tentativas falharem, o sistema lança uma exceção.

PooledConnectionProvider provider = new PooledConnectionProvider(HostAndPort.from("127.0.0.1:6379"));
int maxAttempts = 5; // Maximum number of retries
Duration maxTotalRetriesDuration = Duration.ofSeconds(10); // Maximum total retry duration
UnifiedJedis jedis = new UnifiedJedis(provider, maxAttempts, maxTotalRetriesDuration);
try {
    System.out.println("set key: " + jedis.set("key", "value"));
} catch (Exception e) {
    // The operation failed after maxAttempts retries or after maxTotalRetriesDuration elapsed.
    e.printStackTrace();
}

Instância de cluster em modo de conexão direta (JedisCluster)

Para instâncias de cluster em modo de conexão direta, use JedisCluster. O parâmetro maxAttempts define o número máximo de tentativas e tem 5 como valor padrão. O sistema lança uma exceção se todas as tentativas falharem.

HostAndPort hostAndPort = HostAndPort.from("127.0.0.1:30001");
int connectionTimeout = 5000;
int soTimeout = 2000;
int maxAttempts = 5;
ConnectionPoolConfig config = new ConnectionPoolConfig();
JedisCluster jedisCluster = new JedisCluster(hostAndPort, connectionTimeout, soTimeout, maxAttempts, config);
try {
    System.out.println("set key: " + jedisCluster.set("key", "value"));
} catch (Exception e) {
    // The operation failed after maxAttempts retries.
    e.printStackTrace();
}

Config config = new Config();
config.useSingleServer()
    .setTimeout(1000)
    .setRetryAttempts(3)
    .setRetryInterval(1500) // ms
    .setAddress("redis://127.0.0.1:6379");
RedissonClient connect = Redisson.create(config);

var conn = ConnectionMultiplexer.Connect("redis0:6380,redis1:6380,connectRetry=3");

clientOptions.isAutoReconnect() ? Reliability.AT_LEAST_ONCE : Reliability.AT_MOST_ONCE;