如何在Vert.x中实现代金券生成的数据库存在性循环检查

在同步Java里你那套循环生成+查重的逻辑很直接，但到了Vert.x的异步非阻塞环境，直接用while循环肯定行不通——异步方法不会立刻返回结果，循环会直接空转或者拿到错误的状态。下面给你两种实用的实现思路，都是贴合Vert.x异步模型的：

方法一：递归+Future链式调用 #

Vert.x里异步操作通常用Future来处理结果，我们可以把生成和查重逻辑包装成返回Future的方法，然后通过递归实现“重复就重试”的逻辑：

// 对外暴露的方法，返回包含唯一代金券的Future
private Future<String> generateUniqueVoucher() {
    // 先生成一个6位字母数字的代金券
    String voucher = generateVoucher();
    // 异步检查是否存在，然后根据结果决定返回还是重试
    return checkVoucherExists(voucher)
        .flatMap(exists -> {
            if (exists) {
                // 重复了，递归调用自己重新生成
                return generateUniqueVoucher();
            } else {
                // 没问题，返回这个代金券
                return Future.succeededFuture(voucher);
            }
        });
}

// 把同步的valueExists改成异步方法，返回Future<Boolean>
private Future<Boolean> checkVoucherExists(String voucher) {
    // 这里用Vert.x SQL Client做异步查询（替换成你的数据库操作）
    return sqlClient.preparedQuery("SELECT COUNT(*) FROM vouchers WHERE code = ?")
        .execute(Tuple.of(voucher))
        .map(resultSet -> {
            // 检查查询结果是否有记录
            return resultSet.iterator().next().getInteger(0) > 0;
        });
}

// 你的生成6位字母数字代金券的方法
private String generateVoucher() {
    // 这里写你的UUID转6位字母数字的逻辑，比如：
    String uuid = UUID.randomUUID().toString().replace("-", "");
    return uuid.substring(0, 6).toUpperCase();
}

调用的时候就可以通过Future的回调处理结果：

generateUniqueVoucher()
    .onSuccess(voucher -> {
        // 拿到唯一代金券，做后续操作（比如存入数据库）
        System.out.println("生成的唯一代金券：" + voucher);
    })
    .onFailure(err -> {
        // 处理异常（比如数据库连接失败）
        err.printStackTrace();
    });

方法二：基于Promise的循环重试 #

如果你不想用递归（虽然这种场景下递归深度极低，因为6位字母数字有21亿+组合，重复概率极小），可以用Promise来封装结果，通过辅助方法循环调用生成+查重逻辑：

private Future<String> generateUniqueVoucher() {
    Promise<String> resultPromise = Promise.promise();
    // 启动第一次生成检查
    retryGenerate(resultPromise, 0);
    return resultPromise.future();
}

// 带重试次数的辅助方法，防止极端情况无限循环
private void retryGenerate(Promise<String> resultPromise, int retryCount) {
    // 加个最大重试次数限制，比如10次
    if (retryCount >= 10) {
        resultPromise.fail("超过最大重试次数，无法生成唯一代金券");
        return;
    }

    String voucher = generateVoucher();
    checkVoucherExists(voucher)
        .onSuccess(exists -> {
            if (exists) {
                // 重复了，重试次数+1，再次调用
                retryGenerate(resultPromise, retryCount + 1);
            } else {
                // 成功拿到唯一值，完成Promise
                resultPromise.complete(voucher);
            }
        })
        .onFailure(err -> {
            // 数据库异常，直接把错误传给Promise
            resultPromise.fail(err);
        });
}

额外注意事项 #

• 必须用异步数据库操作：绝对不能在Vert.x的Event Loop里用同步JDBC查询，会阻塞整个线程，破坏异步模型。一定要用Vert.x官方的SQL Client或者其他异步数据库驱动。
• 数据库层面加唯一约束：高并发场景下，可能出现两个请求同时生成相同代金券、都查到不存在，然后同时插入的情况。给代金券字段加唯一约束，能在数据库层面做最后一道保障，此时你的代码要捕获插入失败的异常，然后重试生成。
• 重试次数限制：虽然重复概率极低，但还是建议加个最大重试次数，避免极端情况下（比如数据库bug导致一直返回存在）无限循环。

内容的提问来源于stack exchange，提问作者oentoro