Tair (Redis® OSS-Compatible):Redisクライアントの再試行メカニズム

一時的な障害の原因

推奨される再試行ルール

ジェディス

Jedis 4.0.0以降、できれば最新のJedisバージョンを使用することを推奨します。 次の例では、Jedis 5.0.0が使用されます。

1. 次の依存関係をpom.xmlファイルに追加して、Jedisを含めます。

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

2. Jedisを使用してTair操作を再試行します。

   • インスタンスが標準インスタンスまたはプロキシモードのクラスターインスタンスの場合、JedisPoolモードを使用する必要があります。

     次のサンプルコードは、合計10秒間の再試行時間内にSETコマンドを最大5回まで自動的に再試行します。 すべての再試行が失敗すると、例外がスローされます。

     PooledConnectionProvider provider = new PooledConnectionProvider(HostAndPort.from("127.0.0.1:6379"));
     int maxAttempts = 5; // The maximum number of retries.
     Duration maxTotalRetriesDuration = Duration.ofSeconds(10); // The maximum total retry duration.
     UnifiedJedis jedis = new UnifiedJedis(provider, maxAttempts, maxTotalRetriesDuration);
     try {
         System.out.println("set key: " + jedis.set("key", "value"));
     } catch (Exception e) {
         // If the exception is caught in this block, it implies that the operation failed even after the maximum number of attempts (maxAttempts) or after the maximum total retry duration (maxTotalRetriesDuration) is reached. 
         e.printStackTrace();
     }

   • インスタンスが直接接続モードのクラスターインスタンスの場合、JedisClusterモードを使用する必要があります。

     maxAttemptsパラメーターを設定して、失敗した場合の再試行回数を定義できます。既定値は5です。 最大試行回数後も操作が失敗した場合は、例外がスローされます。

     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) {
         // If the exception is caught in this block, it implies that the operation failed even after the maximum number of attempts (maxAttempts). 
         e.printStackTrace();
     }

リディソン

Redissonクライアントは、再試行ロジックを制御する2つのパラメーターを提供します。

• retryAttempts: 再試行の数。 デフォルト値: 3。

• retryInterval: 再試行間隔。 デフォルト値: 1500 単位：ミリ秒。

Jedisクライアントの再試行設定の例:

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

StackExchange.Redis

StackExchang.Redisクライアントは、接続の再試行のみをサポートします。 StackExchange.Redisクライアントでの再試行設定の例:

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

レタス

Lettuceクライアントは、コマンドがタイムアウトした後の再試行のパラメーターを提供しませんが、次のパラメーターを使用して再試行メカニズムを実装できます。

• at-most-once execution: コマンドは最大で1回実行できます。 クライアントが切断されてから再接続されると、コマンドが失われる可能性があります。

• at-least-once execution (default): コマンドの実行が1回以上成功することが保証されます。 これは、実行の成功を保証するために複数の試みがなされ得ることを示す。 この方法を使用して、クライアントが複数回の再試行を行っているときにTairインスタンスでマスター /レプリカの切り替えが発生した場合、クライアントで多数の再試行コマンドが蓄積される可能性があります。 マスター /レプリカの切り替えが完了すると、TairインスタンスのCPU使用率が急上昇する可能性があります。

Lettuceクライアントの再試行設定の例:

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