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

べき等な操作のみをリトライ

コマンド実行のどの段階でもタイムアウトが発生する可能性があります。

• コマンドがサーバーに到達していない。

• コマンドはサーバーに到達したが、実行がタイムアウトした。

• コマンドはサーバーで実行されたが、レスポンスがタイムアウトした。

リトライされた操作は複数回実行される可能性があるため、べき等な操作のみをリトライしてください。

べき等 -- SET a b: このコマンドを複数回実行しても、常に同じ結果が生成されます。

非べき等 -- LPUSH mylist a: このコマンドを複数回実行すると、重複する a 要素が mylist に追加されます。

適切なリトライ回数と間隔の設定

ご利用のワークロードに基づいて、リトライ回数と間隔を設定してください。

• リトライ回数が少なすぎる、または間隔が長すぎる場合: アプリケーションは、短い一時的なエラー中に操作を完了できない可能性があります。

• リトライ回数が多すぎる、または間隔が短すぎる場合: アプリケーションは過剰なリソースを消費し、サーバーに過負荷をかける可能性があります。

リトライのネストの回避

リトライのネスト (リトライ操作が別のリトライループをトリガーする場合) は、繰り返されるリトライまたは無制限のリトライを引き起こす可能性があります。アプリケーションスタックの単一レイヤーでリトライロジックを実装してください。

リトライ失敗のログ記録

WARN レベルでリトライログを生成します。ログノイズを避けるため、個々の試行時ではなく、最終的なリトライが失敗した場合にのみログを記録してください。

プロキシモードの標準またはクラスターインスタンス (JedisPool)

プロキシモードの標準インスタンスまたはクラスターインスタンスには、PooledConnectionProvider と UnifiedJedis を使用します。

この例では、SET コマンドを 10 秒以内に最大 5 回、指数関数的に増加する待機時間でリトライします。すべてのリトライが失敗した場合、例外がスローされます。

PooledConnectionProvider provider = new PooledConnectionProvider(HostAndPort.from("127.0.0.1:6379"));
int maxAttempts = 5; // 最大リトライ試行回数
Duration maxTotalRetriesDuration = Duration.ofSeconds(10); // 最大合計リトライ期間
UnifiedJedis jedis = new UnifiedJedis(provider, maxAttempts, maxTotalRetriesDuration);
try {
    System.out.println("set key: " + jedis.set("key", "value"));
} catch (Exception e) {
    // 操作は maxAttempts 回のリトライ後、または maxTotalRetriesDuration が経過した後に失敗しました。
    e.printStackTrace();
}

直接接続モードのクラスターインスタンス (JedisCluster)

直接接続モードのクラスターインスタンスには、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) {
    // 操作は maxAttempts 回のリトライ後に失敗しました。
    e.printStackTrace();
}