重试逻辑以检查数据库中的现有密钥

Question

我正在使用 Java 8 和 Spring Boot。如何实现以下场景的重试逻辑？

1. 我将为数据库生成一个随机密钥。
2. 在数据库中查询该密钥（如果存在），然后使用新密钥重试。
3. 使用新生成的密钥保留数据。

示例代码：

int attempts = 1;
while (attempts <= PRESCRIBED_ATTEMPTS) {
  String key = generateSomeRandomAlphaNum();
  Future<String> resultFromDb = someRepository.getById(key);
  resultFromDb.onSuccess(
    result -> {
      // since the key is already present
      // retry here
      Future<String> newAttempt = someRepository.getById(key);
      attempts++;
    }
  );
}

我使用的是Couchbase，所以这里的关键基本上是参考文档。

Answer 1

我做了以下静态测试，只做了一个小小的改变。
最重要的是 while 循环。
请注意，您使用 0 而不是 1 来初始化尝试。
推荐使用驼峰命名法（ PRESCRIBED_ATTEMPTS->specifiedAttempts ）

注意：这个解决方案是同步的，您可以通过实现未来的回调来使该函数异步

public class DemoApplication {
    private static int random = 0;

    public static int generateSomeRandomAlphaNum() {
        return random++;
    }

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication2.class, args);


        int attempts = 0; // 0 because you didnt had an attempt yet. 1 predicts you had one already.
        int predscribedAttempts= 10;

        int key = generateSomeRandomAlphaNum();
        System.out.println("key: " + key);

        while (key != 7 && attempts <= predscribedAttempts) {
            key = generateSomeRandomAlphaNum();
            System.out.println("key: " + key);
            attempts++;
        }
        //finished within x attempts
        System.out.println("finished within " + attempts + " attempts");
    }

}

使用您的代码，它看起来像：

 public static void main(String[] args) {
        SpringApplication.run(DemoApplication2.class, args);
        
        int attempts = 0;
        int predscribedAttempts= 10;

        Future<String> resultFromDb = someRepository.getById(key);    
        while (!resultFromDb.isEmpty() && attempts <= predscribedAttempts) {
            resultFromDb = someRepository.getById(key);
            attempts++;
        }
        //finished
    }

Answer 2

你的做法是不正确的。主键生成是数据库的责任，而不是您的责任。因此，当您想要插入新对象时，您的实体应该以这样的方式正确注释，以便数据库将为您生成有保证的唯一 ID。要了解它是如何完成的，请参阅这篇文章：Hibernate/JPA 中标识符概述。然而，一般来说，如果您想自己出于任何目的生成一些唯一的 ID，那么您应该创建自己的生成器来负责创建唯一的 ID。如果您需要在正在运行的程序范围内提供唯一的 id，那么最简单的方法是使用 AtomicLong 类，并在每次需要新 ID 时递增它。如果您想创建全球唯一 ID，请使用 UUID 类

Answer 3

建议使用resilience4j库以遵守DRY原则。 Resilience4j 的众多模块之一是“重试”，这是一种自动重试失败机制的机制。希望这个 https://reflectoring.io/retry-with-resilience4j/ 会对您有所帮助。