Tair (Redis® OSS-Compatible)：Mekanisme retry untuk klien Redis

Retry hanya operasi idempotent

Timeout dapat terjadi pada tahap mana pun dalam eksekusi perintah:

• Perintah belum sampai ke server.

• Perintah telah sampai ke server, tetapi eksekusinya timeout.

• Perintah telah dieksekusi di server, tetapi responsnya timeout.

Karena operasi yang diretry mungkin dieksekusi lebih dari sekali, lakukan retry hanya untuk operasi idempotent.

Idempotent — SET a b: Menjalankan perintah ini beberapa kali selalu menghasilkan hasil yang sama.

Non-idempotent — LPUSH mylist a: Menjalankan perintah ini beberapa kali akan menambahkan elemen a duplikat ke mylist.

Konfigurasikan jumlah retry dan interval yang sesuai

Tentukan jumlah retry dan interval berdasarkan workload Anda:

• Terlalu sedikit retry atau interval terlalu lama: Aplikasi mungkin gagal menyelesaikan operasi selama gangguan transient singkat.

• Terlalu banyak retry atau interval terlalu pendek: Aplikasi mengonsumsi sumber daya berlebihan dan berpotensi membebani server.

Hindari retry nesting

Retry nesting—di mana operasi retry memicu loop retry lain—dapat menyebabkan retry berulang atau tak terbatas. Implementasikan logika retry hanya pada satu lapisan dalam stack aplikasi Anda.

Catat kegagalan retry

Buat log retry pada level WARN. Catat hanya ketika retry terakhir gagal, bukan pada setiap percobaan individual, untuk menghindari kebisingan log.

Instans Standard atau Cluster dalam mode proxy (JedisPool)

Untuk instans standard atau instans cluster dalam mode proxy, gunakan PooledConnectionProvider dengan UnifiedJedis.

Contoh ini melakukan retry perintah SET hingga 5 kali dalam waktu 10 detik, dengan waktu tunggu yang meningkat secara eksponensial. Jika semua retry gagal, sebuah exception akan dilemparkan.

PooledConnectionProvider provider = new PooledConnectionProvider(HostAndPort.from("127.0.0.1:6379"));
int maxAttempts = 5; // Jumlah maksimum retry
Duration maxTotalRetriesDuration = Duration.ofSeconds(10); // Durasi total maksimum untuk retry
UnifiedJedis jedis = new UnifiedJedis(provider, maxAttempts, maxTotalRetriesDuration);
try {
    System.out.println("set key: " + jedis.set("key", "value"));
} catch (Exception e) {
    // Operasi gagal setelah mencapai maxAttempts atau melebihi maxTotalRetriesDuration.
    e.printStackTrace();
}

Instans Cluster dalam mode koneksi langsung (JedisCluster)

Untuk instans cluster dalam mode koneksi langsung, gunakan JedisCluster. Parameter maxAttempts menentukan jumlah percobaan retry. Nilai default-nya adalah 5. Jika operasi gagal setelah mencapai jumlah maksimum percobaan, sebuah exception akan dilemparkan.

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) {
    // Operasi gagal setelah maxAttempts retry.
    e.printStackTrace();
}