如何将原子计数器与 Spring Data Couchbase Reactive 一起使用

How to use Atomic counters with Spring Data Couchbase Reactive

我正在使用 Spring Data couchbase reactive 来执行读取、写入和更新操作。现在我需要像 Couchbase 中的原子计数器这样的属性之一。我读到 Spring reactive 尚不支持此功能(可能现在支持),因此希望获得有关如何处理此功能的指导。

我已经看过其他票中提供的解决方案:Atomic counters in Spring with Couchbase 但这不是阻塞调用,所以我想知道我是否可以有类似的东西来进行非阻塞调用。

我可以为此使用 Couchbase 的反应式客户端,但这意味着我需要结合 Couchbase 的反应式客户端和 Spring Data Couchbase 反应式,我不太确定它是否是好的方法。

原子计数器不是 Spring 数据规范的一部分(Spring 数据最初是为 RDBMS 设计的)

几个选项是:

1) 通过存储桶对象进行简单的同步调用:

myRepository.getCouchbaseOperations().getCouchbaseBucket().counter("mycounter", 1L, 1L );

2) 使用标准的 Couchbase Java Reactive SDK (RxJava) 并转换 Observable: