Tair (Redis® OSS-Compatible)：Mekanisme Pengulangan untuk Klien

Penyebab kesalahan sementara

Aturan pengulangan yang direkomendasikan

Jedis

Kami merekomendasikan agar Anda menggunakan Jedis 4.0.0 atau yang lebih baru, lebih disukai versi Jedis terbaru. Dalam contoh berikut, Jedis 5.0.0 digunakan.

1. Tambahkan dependensi berikut ke file pom.xml Anda untuk menyertakan Jedis:

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

2. Gunakan Jedis untuk mencoba ulang operasi.

   • Jika instance adalah instance standar atau instance kluster dalam mode proxy, Anda harus menggunakan mode JedisPool.

     Kode sampel berikut secara otomatis mencoba ulang perintah SET hingga 5 kali dalam durasi total pengulangan 10 detik, dengan waktu tunggu yang meningkat secara eksponensial di antara setiap pengulangan. Jika semua pengulangan gagal, pengecualian dilemparkan.

     PooledConnectionProvider provider = new PooledConnectionProvider(HostAndPort.from("127.0.0.1:6379"));
     int maxAttempts = 5; // Jumlah maksimum pengulangan.
     Duration maxTotalRetriesDuration = Duration.ofSeconds(10); // Durasi total maksimum pengulangan.
     UnifiedJedis jedis = new UnifiedJedis(provider, maxAttempts, maxTotalRetriesDuration);
     try {
         System.out.println("set key: " + jedis.set("key", "value"));
     } catch (Exception e) {
         // Jika pengecualian ditangkap di blok ini, itu berarti operasi gagal meskipun sudah mencapai jumlah percobaan maksimum (maxAttempts) atau durasi total pengulangan maksimum (maxTotalRetriesDuration).
         e.printStackTrace();
     }

   • Jika instance adalah instance kluster dalam mode koneksi langsung, Anda harus menggunakan mode JedisCluster.

     Anda dapat mengonfigurasi parameter maxAttempts untuk menentukan jumlah percobaan pengulangan dalam kasus kegagalan, dengan nilai default 5. Jika operasi masih gagal setelah jumlah percobaan maksimum, pengecualian 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) {
         // Jika pengecualian ditangkap di blok ini, itu berarti operasi gagal meskipun sudah mencapai jumlah percobaan maksimum (maxAttempts).
         e.printStackTrace();
     }

Redisson

Klien Redisson menyediakan dua parameter untuk mengontrol logika pengulangan:

• retryAttempts: jumlah pengulangan. Nilai default: 3.

• retryInterval: interval pengulangan. Nilai default: 1500. Unit: milidetik.

Contoh pengaturan pengulangan pada klien Jedis:

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);

StackExchange.Redis

Klien StackExchange.Redis hanya mendukung pengulangan koneksi. Contoh pengaturan pengulangan pada klien StackExchange.Redis:

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

Lettuce

Meskipun klien Lettuce tidak menyediakan parameter untuk pengulangan setelah perintah timeout, Anda dapat menggunakan parameter berikut untuk mengimplementasikan mekanisme pengulangan:

• Eksekusi paling banyak sekali: Perintah dapat dieksekusi paling banyak sekali. Jika klien terputus dan kemudian tersambung kembali, perintah mungkin hilang.

• Eksekusi minimal sekali (default): Setidaknya satu eksekusi perintah yang berhasil dijamin. Ini menunjukkan bahwa beberapa percobaan mungkin dilakukan untuk memastikan eksekusi yang berhasil. Jika metode ini digunakan dan pergantian master/replika terjadi dalam instance sementara klien melakukan beberapa percobaan pengulangan, sejumlah besar perintah pengulangan mungkin terakumulasi di klien. Setelah pergantian master/replika selesai, pemanfaatan CPU instance mungkin melonjak.

Contoh pengaturan pengulangan pada klien Lettuce:

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