我正在尝试使用vertx-redis-client库实现一个比较和删除（CAD）函数。
this answer如何做到这一点。我已经实现了Lua脚本方法，它工作得很好。然而，由于redis安装可能会禁止使用任意Lua脚本运行eval命令，我认为我还必须使用WATCH/GET/MULTI/compare/DELETE/UNWATCH命令序列来实现此功能。
然而，我真的很难用vert.x响应式编程的正确方法来完成这件事。
下面是我的代码，它实现了这两种方法来执行CAD操作：

private Future<Boolean> deleteLua(final String key, final String value) {
        final RedisAPI redis = RedisAPI.api(client);

        final Promise<Boolean> promise = Promise.promise();
        redis.eval(List.of("if redis.call('get', KEYS[1]) == ARGV[1] then redis.call('del', KEYS[1]); return 1; else return 0; end", "1", key, value))
                .onSuccess(res -> {
                    System.out.println("Success: " + res);
                    promise.complete(res.toInteger() == 1);
                })
                .onFailure(err -> {
                    System.out.println("Error: " + err);
                    promise.fail(err);
                });

        return promise.future();
    }

private Future<Boolean> deleteMulti(final String key, final String value) {
        final RedisAPI redis = RedisAPI.api(client);

        final Promise<Boolean> promise = Promise.promise();
        redis.watch(List.of(key))
                .onSuccess(watchResult -> {
                    redis.get(key)
                            .onSuccess(getResult -> {
                                redis.multi()
                                        .onSuccess(multiResult -> {
                                            if (value.equals(String.valueOf(getResult))) {
                                                redis.del(List.of(key))
                                                        .onSuccess(delResult -> {
                                                            System.out.println("key deleted");
                                                        });
                                            } else {
                                                System.out.println("value did not match, key not deleted");
                                                promise.complete(false);
                                            }
                                            redis.exec().onSuccess(execResult -> {
                                                System.out.println("execResult: " + execResult);
                                                redis.unwatch().onSuccess(unwatchResult -> {
                                                    System.out.println("unwatched key");
                                                    promise.complete(true);
                                                });
                                            });
                                        })
                                        .onFailure(multiErr -> {
                                            System.out.println("The multi failed: " + multiErr);
                                            promise.fail(multiErr);
                                        });
                            });
                });
        return Future.succeededFuture(true);
    }

这两种方法似乎都能工作，但我真的不确定deleteMulti方法。首先，它只是看起来很丑。。它是如此无休止的嵌套！我相信我可以使用compose在某种程度上解决这个问题，但我已经尝试过这样做，但一直碰壁，不知道如何做到这一点。例如，我需要multi的onSuccess块中的getResult，但当我尝试使用compose结构时，一切都变得有点混乱，我不清楚在每个compose块中到底有什么结果。另一件我不太清楚的事情是Redis交易在这里是如何工作的。我的redis对象是否跟踪会话，以便我对watch的调用对于我使用同一对象进行的任何后续redis调用都是“活动的”？如何治疗unwatch？我目前只在onSuccess中调用watch->get->multi->exec块，但是如果get或multi失败了怎么办？我是否也需要取消对失败的监视，或者只是通过某种方式使会话无效来处理？这实际上似乎不太可能，因为这都是React式的，并且方法（实际创建RedisAPI redis对象的地方）可能会在所有操作完成之前返回。
所以是的...很困惑。
任何帮助，使这个代码块的形状将非常感谢。